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) |
Performs a handshake with the connected ServiceServer.
<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.
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.
String org.ros.internal.node.service.ServiceClientHandshakeHandler< T, S >.getName | ( | ) | [inline] |
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] |
Implements org.ros.internal.transport.BaseClientHandshakeHandler.
Definition at line 74 of file ServiceClientHandshakeHandler.java.
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.
incommingConnectionHeader | |
ctx | |
e |
Implements org.ros.internal.transport.BaseClientHandshakeHandler.
Definition at line 63 of file ServiceClientHandshakeHandler.java.
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.