Inheritance diagram for org.ros.internal.node.topic.SubscriberHandshakeHandler< T >:

Public Member Functions
String	getName ()
	SubscriberHandshakeHandler (ConnectionHeader outgoingConnectionHeader, final IncomingMessageQueue< T > incomingMessageQueue, ExecutorService executorService)
Protected Member Functions
void	onFailure (String errorMessage, ChannelHandlerContext ctx, MessageEvent e)
void	onSuccess (ConnectionHeader incomingConnectionHeader, ChannelHandlerContext ctx, MessageEvent e)
Private Attributes
final IncomingMessageQueue< T >	incomingMessageQueue
Static Private Attributes
static final Log	log = LogFactory.getLog(SubscriberHandshakeHandler.class)

Detailed Description

Performs a handshake with the connected Publisher and connects the Publisher to the IncomingMessageQueue on success.

Parameters:

<T>	the Subscriber may only subscribe to messages of this type

Constructor & Destructor Documentation

org.ros.internal.node.topic.SubscriberHandshakeHandler< T >.SubscriberHandshakeHandler	(	ConnectionHeader	outgoingConnectionHeader,
		final IncomingMessageQueue< T >	incomingMessageQueue,
		ExecutorService	executorService
	)		`[inline]`

String org.ros.internal.node.topic.SubscriberHandshakeHandler< T >.getName ( ) [inline]

void org.ros.internal.node.topic.SubscriberHandshakeHandler< T >.onFailure	(	String	errorMessage,
		ChannelHandlerContext	ctx,
		MessageEvent	e
	)		`[inline, protected, virtual]`

void org.ros.internal.node.topic.SubscriberHandshakeHandler< T >.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

final IncomingMessageQueue<T> org.ros.internal.node.topic.SubscriberHandshakeHandler< T >.incomingMessageQueue [private]

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

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