universal
Class ClientInterceptor

java.lang.Object
  |
  +--org.omg.CORBA.LocalObject
        |
        +--universal.ClientInterceptor
All Implemented Interfaces:
org.omg.PortableInterceptor.ClientRequestInterceptor, org.omg.PortableInterceptor.ClientRequestInterceptorOperations, org.omg.CORBA.portable.IDLEntity, org.omg.PortableInterceptor.Interceptor, org.omg.PortableInterceptor.InterceptorOperations, org.omg.CORBA.Object, java.io.Serializable

public class ClientInterceptor
extends org.omg.CORBA.LocalObject
implements org.omg.PortableInterceptor.ClientRequestInterceptor

Intercepts the CORBA request in order to add it a service context to identify it uniquely.

See Also:
Serialized Form

Field Summary
(package private)  int ft_slot
           
(package private)  org.omg.PortableInterceptor.ORBInitInfo info
           
(package private)  java.lang.String location
           
(package private)  org.omg.CORBA.ORB orb
           
(package private)  java.io.RandomAccessFile trace_file
           
 
Fields inherited from class org.omg.CORBA.LocalObject
 
Constructor Summary
ClientInterceptor(org.omg.PortableInterceptor.ORBInitInfo inf, int t_slot)
           
 
Method Summary
 void destroy()
           
 java.lang.String name()
           
 void receive_exception(org.omg.PortableInterceptor.ClientRequestInfo ri)
           
 void receive_other(org.omg.PortableInterceptor.ClientRequestInfo ri)
           
 void receive_reply(org.omg.PortableInterceptor.ClientRequestInfo ri)
           
 void send_poll(org.omg.PortableInterceptor.ClientRequestInfo ri)
           
 void send_request(org.omg.PortableInterceptor.ClientRequestInfo ri)
          Add the service context to the request : retention_id,client_id ,request_start_time.
 
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
clone, equals, finalize, 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
 

Field Detail

info

org.omg.PortableInterceptor.ORBInitInfo info

ft_slot

int ft_slot

orb

org.omg.CORBA.ORB orb

location

java.lang.String location

trace_file

java.io.RandomAccessFile trace_file
Constructor Detail

ClientInterceptor

public ClientInterceptor(org.omg.PortableInterceptor.ORBInitInfo inf,
                         int t_slot)
Method Detail

send_request

public void send_request(org.omg.PortableInterceptor.ClientRequestInfo ri)
                  throws org.omg.PortableInterceptor.ForwardRequest
Add the service context to the request : retention_id,client_id ,request_start_time.
This is for identifying the request uniquely.
If we intercept the messages to inform all the replicas in which port the client and the replicas are listenning we don't add any service context.

Specified by:
send_request in interface org.omg.PortableInterceptor.ClientRequestInterceptorOperations
org.omg.PortableInterceptor.ForwardRequest

send_poll

public void send_poll(org.omg.PortableInterceptor.ClientRequestInfo ri)
Specified by:
send_poll in interface org.omg.PortableInterceptor.ClientRequestInterceptorOperations

receive_reply

public void receive_reply(org.omg.PortableInterceptor.ClientRequestInfo ri)
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
Specified by:
receive_exception in interface org.omg.PortableInterceptor.ClientRequestInterceptorOperations
org.omg.PortableInterceptor.ForwardRequest

receive_other

public void receive_other(org.omg.PortableInterceptor.ClientRequestInfo ri)
                   throws org.omg.PortableInterceptor.ForwardRequest
Specified by:
receive_other in interface org.omg.PortableInterceptor.ClientRequestInterceptorOperations
org.omg.PortableInterceptor.ForwardRequest

name

public java.lang.String name()
Specified by:
name in interface org.omg.PortableInterceptor.InterceptorOperations

destroy

public void destroy()
Specified by:
destroy in interface org.omg.PortableInterceptor.InterceptorOperations