org.openorb.ots.ORB
Class TransactionalClientInterceptor

java.lang.Object
  extended by org.omg.CORBA.LocalObject
      extended by org.openorb.ots.ORB.TransactionalClientInterceptor
All Implemented Interfaces:
java.io.Serializable, org.apache.avalon.framework.logger.LogEnabled, org.omg.CORBA.Object, org.omg.CORBA.portable.IDLEntity, org.omg.PortableInterceptor.ClientRequestInterceptor, org.omg.PortableInterceptor.ClientRequestInterceptorOperations, org.omg.PortableInterceptor.Interceptor, org.omg.PortableInterceptor.InterceptorOperations

public class TransactionalClientInterceptor
extends org.omg.CORBA.LocalObject
implements org.omg.PortableInterceptor.ClientRequestInterceptor, org.apache.avalon.framework.logger.LogEnabled

The Client side interceptor is used to transfer the propagation context in transaction requests

Author:
Marina Daniel
See Also:
Serialized Form

Constructor Summary
TransactionalClientInterceptor(org.omg.PortableInterceptor.ORBInitInfo info, int slot)
          Constructor which initializes the ORBInitInfo and the Sender reference
 
Method Summary
 void destroy()
          Destroy the interceptor.
 void enableLogging(org.apache.avalon.framework.logger.Logger logger)
           
 java.lang.String name()
          return the name of the Transactional Client Interceptor
 void receive_exception(org.omg.PortableInterceptor.ClientRequestInfo ri)
          Called when the client receive an exception from the server
 void receive_other(org.omg.PortableInterceptor.ClientRequestInfo ri)
          Called when the client receive a message from the server which is not a reply and not an exception
 void receive_reply(org.omg.PortableInterceptor.ClientRequestInfo ri)
          Called when the client receive a reply from the server get the transaction propagation context of the service context list, pass it to the sender which will set the propagation context to the current object
 void send_poll(org.omg.PortableInterceptor.ClientRequestInfo ri)
          used to query information during a Time Independent Invocation polling get reply sequence ??
 void send_request(org.omg.PortableInterceptor.ClientRequestInfo ri)
          Adds a transaction propagation context to the service context list, to be passed to the server.
 
Methods inherited from class org.omg.CORBA.LocalObject
_create_request, _create_request, _duplicate, _get_domain_managers, _get_interface_def, _get_interface, _get_policy, _hash, _invoke, _is_a, _is_equivalent, _is_local, _non_existent, _orb, _release, _releaseReply, _request, _request, _servant_postinvoke, _servant_preinvoke, _set_policy_override, validate_connection
 
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface org.omg.CORBA.Object
_create_request, _create_request, _duplicate, _get_domain_managers, _get_interface_def, _get_policy, _hash, _is_a, _is_equivalent, _non_existent, _release, _request, _set_policy_override
 

Constructor Detail

TransactionalClientInterceptor

public TransactionalClientInterceptor(org.omg.PortableInterceptor.ORBInitInfo info,
                                      int slot)
Constructor which initializes the ORBInitInfo and the Sender reference

Method Detail

send_request

public void send_request(org.omg.PortableInterceptor.ClientRequestInfo ri)
                  throws org.omg.PortableInterceptor.ForwardRequest
Adds a transaction propagation context to the service context list, to be passed to the server.

Specified by:
send_request in interface org.omg.PortableInterceptor.ClientRequestInterceptorOperations
Parameters:
ri - the client request
Throws:
org.omg.PortableInterceptor.ForwardRequest

send_poll

public void send_poll(org.omg.PortableInterceptor.ClientRequestInfo ri)
used to query information during a Time Independent Invocation polling get reply sequence ??

Specified by:
send_poll in interface org.omg.PortableInterceptor.ClientRequestInterceptorOperations

receive_reply

public void receive_reply(org.omg.PortableInterceptor.ClientRequestInfo ri)
Called when the client receive a reply from the server get the transaction propagation context of the service context list, pass it to the sender which will set the propagation context to the current object

Specified by:
receive_reply in interface org.omg.PortableInterceptor.ClientRequestInterceptorOperations

receive_exception

public void receive_exception(org.omg.PortableInterceptor.ClientRequestInfo ri)
                       throws org.omg.PortableInterceptor.ForwardRequest
Called when the client receive an exception from the server

Specified by:
receive_exception in interface org.omg.PortableInterceptor.ClientRequestInterceptorOperations
Throws:
org.omg.PortableInterceptor.ForwardRequest

receive_other

public void receive_other(org.omg.PortableInterceptor.ClientRequestInfo ri)
                   throws org.omg.PortableInterceptor.ForwardRequest
Called when the client receive a message from the server which is not a reply and not an exception

Specified by:
receive_other in interface org.omg.PortableInterceptor.ClientRequestInterceptorOperations
Throws:
org.omg.PortableInterceptor.ForwardRequest

name

public java.lang.String name()
return the name of the Transactional Client Interceptor

Specified by:
name in interface org.omg.PortableInterceptor.InterceptorOperations

destroy

public void destroy()
Destroy the interceptor.

Specified by:
destroy in interface org.omg.PortableInterceptor.InterceptorOperations

enableLogging

public void enableLogging(org.apache.avalon.framework.logger.Logger logger)
Specified by:
enableLogging in interface org.apache.avalon.framework.logger.LogEnabled