Public Member Functions | |
void | addListener (ClientHandshakeListener clientHandshakeListener) |
BaseClientHandshakeHandler (ClientHandshake clientHandshake, ExecutorService executorService) | |
void | channelConnected (ChannelHandlerContext ctx, ChannelStateEvent e) throws Exception |
void | messageReceived (ChannelHandlerContext ctx, MessageEvent e) throws Exception |
Protected Member Functions | |
abstract void | onFailure (String errorMessage, ChannelHandlerContext ctx, MessageEvent e) |
abstract void | onSuccess (ConnectionHeader incommingConnectionHeader, ChannelHandlerContext ctx, MessageEvent e) |
Private Member Functions | |
void | signalOnFailure (final String errorMessage) |
void | signalOnSuccess (final ConnectionHeader incommingConnectionHeader) |
Private Attributes | |
final ClientHandshake | clientHandshake |
final ListenerGroup < ClientHandshakeListener > | clientHandshakeListeners |
Common functionality for ClientHandshake handlers.
Definition at line 34 of file BaseClientHandshakeHandler.java.
org.ros.internal.transport.BaseClientHandshakeHandler.BaseClientHandshakeHandler | ( | ClientHandshake | clientHandshake, |
ExecutorService | executorService | ||
) | [inline] |
Definition at line 39 of file BaseClientHandshakeHandler.java.
void org.ros.internal.transport.BaseClientHandshakeHandler.addListener | ( | ClientHandshakeListener | clientHandshakeListener | ) | [inline] |
Definition at line 44 of file BaseClientHandshakeHandler.java.
void org.ros.internal.transport.BaseClientHandshakeHandler.channelConnected | ( | ChannelHandlerContext | ctx, |
ChannelStateEvent | e | ||
) | throws Exception [inline] |
Definition at line 49 of file BaseClientHandshakeHandler.java.
void org.ros.internal.transport.BaseClientHandshakeHandler.messageReceived | ( | ChannelHandlerContext | ctx, |
MessageEvent | e | ||
) | throws Exception [inline] |
Definition at line 55 of file BaseClientHandshakeHandler.java.
abstract void org.ros.internal.transport.BaseClientHandshakeHandler.onFailure | ( | String | errorMessage, |
ChannelHandlerContext | ctx, | ||
MessageEvent | e | ||
) | [protected, pure virtual] |
abstract void org.ros.internal.transport.BaseClientHandshakeHandler.onSuccess | ( | ConnectionHeader | incommingConnectionHeader, |
ChannelHandlerContext | ctx, | ||
MessageEvent | e | ||
) | [protected, pure 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 |
Implemented in org.ros.internal.node.service.ServiceClientHandshakeHandler< T, S >, and org.ros.internal.node.topic.SubscriberHandshakeHandler< T >.
void org.ros.internal.transport.BaseClientHandshakeHandler.signalOnFailure | ( | final String | errorMessage | ) | [inline, private] |
Definition at line 92 of file BaseClientHandshakeHandler.java.
void org.ros.internal.transport.BaseClientHandshakeHandler.signalOnSuccess | ( | final ConnectionHeader | incommingConnectionHeader | ) | [inline, private] |
Definition at line 81 of file BaseClientHandshakeHandler.java.
final ClientHandshake org.ros.internal.transport.BaseClientHandshakeHandler.clientHandshake [private] |
Definition at line 36 of file BaseClientHandshakeHandler.java.
final ListenerGroup<ClientHandshakeListener> org.ros.internal.transport.BaseClientHandshakeHandler.clientHandshakeListeners [private] |
Definition at line 37 of file BaseClientHandshakeHandler.java.