Public Member Functions | Protected Member Functions | Private Attributes | Static Private Attributes
org.ros.internal.node.service.ServiceClientHandshakeHandler< T, S > Class Reference
Inheritance diagram for org.ros.internal.node.service.ServiceClientHandshakeHandler< T, S >:
Inheritance graph
[legend]

List of all members.

Public Member Functions

String getName ()
 ServiceClientHandshakeHandler (ConnectionHeader outgoingConnectionHeader, Queue< ServiceResponseListener< S >> responseListeners, MessageDeserializer< S > deserializer, ExecutorService executorService)

Protected Member Functions

void onFailure (String errorMessage, ChannelHandlerContext ctx, MessageEvent e)
void onSuccess (ConnectionHeader incommingConnectionHeader, ChannelHandlerContext ctx, MessageEvent e)

Private Attributes

final MessageDeserializer< S > deserializer
final ExecutorService executorService
final Queue
< ServiceResponseListener< S > > 
responseListeners

Static Private Attributes

static final Log log = LogFactory.getLog(ServiceClientHandshakeHandler.class)

Detailed Description

Performs a handshake with the connected ServiceServer.

Author:
damonkohler@google.com (Damon Kohler)
Parameters:
<T>the connected ServiceServer responds to requests of this type
<S>the connected ServiceServer returns responses of this type

Definition at line 45 of file ServiceClientHandshakeHandler.java.


Constructor & Destructor Documentation

org.ros.internal.node.service.ServiceClientHandshakeHandler< T, S >.ServiceClientHandshakeHandler ( ConnectionHeader  outgoingConnectionHeader,
Queue< ServiceResponseListener< S >>  responseListeners,
MessageDeserializer< S >  deserializer,
ExecutorService  executorService 
) [inline]

Definition at line 53 of file ServiceClientHandshakeHandler.java.


Member Function Documentation

String org.ros.internal.node.service.ServiceClientHandshakeHandler< T, S >.getName ( ) [inline]
Returns:
the name of this ChannelHandler

Implements org.ros.internal.transport.tcp.NamedChannelHandler.

Definition at line 80 of file ServiceClientHandshakeHandler.java.

void org.ros.internal.node.service.ServiceClientHandshakeHandler< T, S >.onFailure ( String  errorMessage,
ChannelHandlerContext  ctx,
MessageEvent  e 
) [inline, protected, virtual]
void org.ros.internal.node.service.ServiceClientHandshakeHandler< T, S >.onSuccess ( ConnectionHeader  incommingConnectionHeader,
ChannelHandlerContext  ctx,
MessageEvent  e 
) [inline, protected, virtual]

Called when the ClientHandshake succeeds and will block the network thread until it returns.

This must block in order to allow changes to the pipeline to be made before further messages arrive.

Parameters:
incommingConnectionHeader
ctx
e

Implements org.ros.internal.transport.BaseClientHandshakeHandler.

Definition at line 63 of file ServiceClientHandshakeHandler.java.


Member Data Documentation

final MessageDeserializer<S> org.ros.internal.node.service.ServiceClientHandshakeHandler< T, S >.deserializer [private]

Definition at line 50 of file ServiceClientHandshakeHandler.java.

final ExecutorService org.ros.internal.node.service.ServiceClientHandshakeHandler< T, S >.executorService [private]

Definition at line 51 of file ServiceClientHandshakeHandler.java.

final Log org.ros.internal.node.service.ServiceClientHandshakeHandler< T, S >.log = LogFactory.getLog(ServiceClientHandshakeHandler.class) [static, private]

Definition at line 47 of file ServiceClientHandshakeHandler.java.

final Queue<ServiceResponseListener<S> > org.ros.internal.node.service.ServiceClientHandshakeHandler< T, S >.responseListeners [private]

Definition at line 49 of file ServiceClientHandshakeHandler.java.


The documentation for this class was generated from the following file:


rosjava_core
Author(s):
autogenerated on Wed Aug 26 2015 16:06:51