org.jacorb.orb

Class Delegate

java.lang.Object

org.omg.CORBA.portable.Delegate

org.omg.CORBA_2_3.portable.Delegate

org.jacorb.orb.Delegate

public final class Delegate
extends Delegate

JacORB implementation of CORBA object reference

Author:

Gerald Brose

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Delegate.INVOCATION_KEY

Constructor Summary

Constructors

Constructor and Description
Delegate(ORB orb, IOR ior)
Delegate(ORB orb, IOR ior, boolean parseIORLazy)
Delegate(ORB orb, ParsedIOR pior)

Method Summary

Methods

Modifier and Type	Method and Description
int	_get_TCKind()
static void	clearInvocationContext() clear the current invocation context.
Request	create_request(Object self, Context ctx, String operation, NVList args, NamedValue result)
Request	create_request(Object self, Context ctx, String operation, NVList args, NamedValue result, ExceptionList exceptions, ContextList contexts)
Object	duplicate(Object self)
boolean	equals(Object obj)
boolean	equals(Object self, Object obj)
void	forwardToObj(Object obj)
Policy	get_client_policy(int policy_type) Gets the effective overriding policy with the given type from the client-side, or null if this policy type is unset.
String	get_codebase(Object self)
Object	get_component(Object self)
DomainManager[]	get_domain_managers(Object self)
Object	get_interface_def(Object self)
InterfaceDef	get_interface(Object self) Deprecated.
Policy	get_policy(Object self, int policy_type) The get_policy operation returns the policy object of the specified type, which applies to this object.
Policy	get_policy(Object self, int policy_type, OutputStream os)
ParsedIOR	getBaseIOR()
org.omg.RTCORBA.Protocol[]	getClientProtocols()
String	getIDString()
static ArrayDeque<Map<Delegate.INVOCATION_KEY,org.omg.TimeBase.UtcT>>	getInvocationContext() access the current invocation context (its a ArrayDeque of Maps).
IOR	getIOR()
byte[]	getObjectId()
byte[]	getObjectKey()
ParsedIOR	getParsedIOR()
POA	getPOA()
ObjectImpl	getReference(POA _poa)
long	getRelativeRequestTimeout()
long	getRelativeRoundtripTimeout()
org.omg.TimeBase.UtcT	getReplyEndTime()
org.omg.TimeBase.UtcT	getReplyStartTime()
org.omg.TimeBase.UtcT	getRequestEndTime()
org.omg.TimeBase.UtcT	getRequestStartTime()
short	getSyncScope()
int	hash(Object self, int x)
int	hashCode()
int	hashCode(Object self)
InputStream	invoke(Object self, OutputStream os) Invokes a synchronous operation using this object reference by sending the request marshalled in the OutputStream.
void	invoke(Object self, OutputStream os, ReplyHandler replyHandler) Invokes an asynchronous operation using this object reference by sending the request marshalled in the OutputStream.
void	invokeInterceptors(ClientRequestInfoImpl info, short op)
boolean	is_a(Object self, String logical_type_id) Determines whether the object denoted by self has type logical_type_id or a subtype of it
boolean	is_equivalent(Object self, Object obj)
boolean	is_local(Object self)
boolean	is_nil()
boolean	non_existent(Object self)
ORB	orb(Object self)
void	release(Object self) Called to indicate that this Delegate will no longer be used by the client.
void	releaseReply(Object self, InputStream is) releases the InputStream
String	repository_id(Object self) repository_id returns a repository ID.
Request	request(Object self, String operation)
OutputStream	request(Object self, String operation, boolean responseExpected)
void	resolvePOA(Object self)
void	servant_postinvoke(Object self, ServantObject servant) Overrides servant_postinvoke() in org.omg.CORBA.portable.Delegate called from generated stubs after a local operation
ServantObject	servant_preinvoke(Object self, String operation, Class expectedType) Overrides servant_preinvoke() in org.omg.CORBA.portable.Delegate called from generated stubs before a local operation
Object	set_policy_override(Object self, Policy[] policies, SetOverrideType set_add)
Object	set_policy_overrides(Object self, Policy[] policies, SetOverrideType set_add)
String	toString()
String	toString(Object self)
String	typeId()
boolean	validate_connection(Object self, PolicyListHolder inconsistent_policies)

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

Delegate

public Delegate(ORB orb,
        ParsedIOR pior)

Delegate

public Delegate(ORB orb,
        IOR ior,
        boolean parseIORLazy)

Delegate

public Delegate(ORB orb,
        IOR ior)

Method Detail

getInvocationContext

public static final ArrayDeque<Map<Delegate.INVOCATION_KEY,org.omg.TimeBase.UtcT>> getInvocationContext()

access the current invocation context (its a ArrayDeque of Maps). this context lives as long as the invocation is active. especially it outlives RemarshalExceptions and thus can be used to share information between mutiple requests that are done as part of an invocation.

clearInvocationContext

public static void clearInvocationContext()

clear the current invocation context. must be invoked before control is returned to the client (exceptions, orderly termination). mustn't be reset in case of RemarshalExceptions.

_get_TCKind

public int _get_TCKind()

forwardToObj

public void forwardToObj(Object obj)

create_request

public Request create_request(Object self,
                     Context ctx,
                     String operation,
                     NVList args,
                     NamedValue result)

Specified by:

create_request in class Delegate

create_request

public Request create_request(Object self,
                     Context ctx,
                     String operation,
                     NVList args,
                     NamedValue result,
                     ExceptionList exceptions,
                     ContextList contexts)

Specified by:

create_request in class Delegate

duplicate

public Object duplicate(Object self)

Specified by:

duplicate in class Delegate

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

equals

public boolean equals(Object self,
             Object obj)

Overrides:

equals in class Delegate

get_domain_managers

public DomainManager[] get_domain_managers(Object self)

Overrides:

get_domain_managers in class Delegate

get_policy

public Policy get_policy(Object self,
                int policy_type)

The get_policy operation returns the policy object of the specified type, which applies to this object. It returns the effective Policy for the object reference. The effective Policy is the one that would be used if a request were made. This Policy is determined first by obtaining the effective override for the PolicyType as returned by get_client_policy. The effective override is then compared with the Policy as specified in the IOR.

The effective Policy is determined by reconciling the effective override and the IOR-specified Policy. If the two policies cannot be reconciled, the standard system exception INV_POLICY is raised with standard minor code 1. The absence of a Policy value in the IOR implies that any legal value may be used.

Overrides:

get_policy in class Delegate

get_client_policy

public Policy get_client_policy(int policy_type)

Gets the effective overriding policy with the given type from the client-side, or null if this policy type is unset. (Implementation is incomplete, we don't check PolicyCurrent, i.e. at the thread-level)

get_policy

public Policy get_policy(Object self,
                int policy_type,
                OutputStream os)

getRequestEndTime

public org.omg.TimeBase.UtcT getRequestEndTime()

getReplyEndTime

public org.omg.TimeBase.UtcT getReplyEndTime()

getRequestStartTime

public org.omg.TimeBase.UtcT getRequestStartTime()

getReplyStartTime

public org.omg.TimeBase.UtcT getReplyStartTime()

getRelativeRoundtripTimeout

public long getRelativeRoundtripTimeout()

getRelativeRequestTimeout

public long getRelativeRequestTimeout()

getSyncScope

public short getSyncScope()

getClientProtocols

public org.omg.RTCORBA.Protocol[] getClientProtocols()

get_interface

@Deprecated
public InterfaceDef get_interface(Object self)

Deprecated.

Deprecated by CORBA 2.3

get_interface_def

public Object get_interface_def(Object self)

Specified by:

get_interface_def in class Delegate

getIOR

public IOR getIOR()

getObjectId

public byte[] getObjectId()

getObjectKey

public byte[] getObjectKey()

getBaseIOR

public ParsedIOR getBaseIOR()

getParsedIOR

public ParsedIOR getParsedIOR()

resolvePOA

public void resolvePOA(Object self)

getPOA

public POA getPOA()

getReference

public ObjectImpl getReference(POA _poa)

hash

public int hash(Object self,
       int x)

Specified by:

hash in class Delegate

hashCode

public int hashCode()

Overrides:

hashCode in class Object

hashCode

public int hashCode(Object self)

Overrides:

hashCode in class Delegate

invoke

public void invoke(Object self,
          OutputStream os,
          ReplyHandler replyHandler)
            throws ApplicationException,
                   RemarshalException

Invokes an asynchronous operation using this object reference by sending the request marshalled in the OutputStream. The reply will be directed to the supplied ReplyHandler.

Throws:

ApplicationException

RemarshalException

invoke

public InputStream invoke(Object self,
                 OutputStream os)
                   throws ApplicationException,
                          RemarshalException

Invokes a synchronous operation using this object reference by sending the request marshalled in the OutputStream.

Overrides:

invoke in class Delegate

Returns:

the reply, if a reply is expected for this request. If no reply is expected, returns null.

Throws:

ApplicationException

RemarshalException

invokeInterceptors

public void invokeInterceptors(ClientRequestInfoImpl info,
                      short op)
                        throws RemarshalException

Throws:

RemarshalException

repository_id

public String repository_id(Object self)

repository_id returns a repository ID.

Returns:

a String value

is_a

public boolean is_a(Object self,
           String logical_type_id)

Determines whether the object denoted by self has type logical_type_id or a subtype of it

Specified by:

is_a in class Delegate

is_equivalent

public boolean is_equivalent(Object self,
                    Object obj)

Specified by:

is_equivalent in class Delegate

getIDString

public String getIDString()

is_local

public boolean is_local(Object self)

Overrides:

is_local in class Delegate

Returns:

true if this object lives on a local POA and interceptors are not installed. When interceptors are installed this returns false so that stubs do not call direct to implementation, avoiding installed interceptors.

is_nil

public boolean is_nil()

non_existent

public boolean non_existent(Object self)

Specified by:

non_existent in class Delegate

get_component

public Object get_component(Object self)

orb

public ORB orb(Object self)

Overrides:

orb in class Delegate

release

public void release(Object self)

Called to indicate that this Delegate will no longer be used by the client. The Delegate unregisters itself from the underlying GIOPConnection. If there are no other Delegates using that connection, it will be closed and disposed of altogether.

Specified by:

release in class Delegate

releaseReply

public void releaseReply(Object self,
                InputStream is)

releases the InputStream

Overrides:

releaseReply in class Delegate

request

public Request request(Object self,
              String operation)

Specified by:

request in class Delegate

request

public OutputStream request(Object self,
                   String operation,
                   boolean responseExpected)

Overrides:

request in class Delegate

servant_postinvoke

public void servant_postinvoke(Object self,
                      ServantObject servant)

Overrides servant_postinvoke() in org.omg.CORBA.portable.Delegate
called from generated stubs after a local operation

Overrides:

servant_postinvoke in class Delegate

servant_preinvoke

public ServantObject servant_preinvoke(Object self,
                              String operation,
                              Class expectedType)

Overrides servant_preinvoke() in org.omg.CORBA.portable.Delegate
called from generated stubs before a local operation

Overrides:

servant_preinvoke in class Delegate

toString

public String toString()

Overrides:

toString in class Object

toString

public String toString(Object self)

Overrides:

toString in class Delegate

typeId

public String typeId()

set_policy_override

public Object set_policy_override(Object self,
                         Policy[] policies,
                         SetOverrideType set_add)

Overrides:

set_policy_override in class Delegate

set_policy_overrides

public Object set_policy_overrides(Object self,
                          Policy[] policies,
                          SetOverrideType set_add)

get_codebase

public String get_codebase(Object self)

Overrides:

get_codebase in class Delegate

validate_connection

public boolean validate_connection(Object self,
                          PolicyListHolder inconsistent_policies)