Package org.ros.internal.transport.queue
Class MessageReceiver<T>
java.lang.Object
org.jboss.netty.channel.SimpleChannelHandler
org.ros.internal.transport.tcp.AbstractNamedChannelHandler
org.ros.internal.transport.queue.MessageReceiver<T>
- Type Parameters:
T- the message type
- All Implemented Interfaces:
org.jboss.netty.channel.ChannelDownstreamHandler,org.jboss.netty.channel.ChannelHandler,org.jboss.netty.channel.ChannelUpstreamHandler,NamedChannelHandler
- Author:
- damonkohler@google.com (Damon Kohler)
-
Nested Class Summary
Nested classes/interfaces inherited from interface org.jboss.netty.channel.ChannelHandler
org.jboss.netty.channel.ChannelHandler.Sharable -
Constructor Summary
ConstructorsConstructorDescriptionMessageReceiver(CircularBlockingDeque<LazyMessage<T>> lazyMessages, org.ros.message.MessageDeserializer<T> deserializer) -
Method Summary
Modifier and TypeMethodDescriptiongetName()voidmessageReceived(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.channel.MessageEvent e) Methods inherited from class org.ros.internal.transport.tcp.AbstractNamedChannelHandler
toStringMethods inherited from class org.jboss.netty.channel.SimpleChannelHandler
bindRequested, channelBound, channelClosed, channelConnected, channelDisconnected, channelInterestChanged, channelOpen, channelUnbound, childChannelClosed, childChannelOpen, closeRequested, connectRequested, disconnectRequested, exceptionCaught, handleDownstream, handleUpstream, setInterestOpsRequested, unbindRequested, writeComplete, writeRequestedMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitMethods inherited from interface org.jboss.netty.channel.ChannelDownstreamHandler
handleDownstreamMethods inherited from interface org.jboss.netty.channel.ChannelUpstreamHandler
handleUpstream
-
Constructor Details
-
MessageReceiver
public MessageReceiver(CircularBlockingDeque<LazyMessage<T>> lazyMessages, org.ros.message.MessageDeserializer<T> deserializer)
-
-
Method Details