Public Member Functions | |
String | getName () |
void | messageReceived (ChannelHandlerContext ctx, MessageEvent e) throws Exception |
MessageReceiver (CircularBlockingDeque< LazyMessage< T >> lazyMessages, MessageDeserializer< T > deserializer) | |
Private Attributes | |
final MessageDeserializer< T > | deserializer |
final CircularBlockingDeque < LazyMessage< T > > | lazyMessages |
Static Private Attributes | |
static final boolean | DEBUG = false |
static final Log | log = LogFactory.getLog(MessageReceiver.class) |
<T> | the message type |
Definition at line 35 of file MessageReceiver.java.
org.ros.internal.transport.queue.MessageReceiver< T >.MessageReceiver | ( | CircularBlockingDeque< LazyMessage< T >> | lazyMessages, |
MessageDeserializer< T > | deserializer | ||
) | [inline] |
Definition at line 43 of file MessageReceiver.java.
String org.ros.internal.transport.queue.MessageReceiver< T >.getName | ( | ) | [inline] |
Implements org.ros.internal.transport.tcp.NamedChannelHandler.
Definition at line 50 of file MessageReceiver.java.
void org.ros.internal.transport.queue.MessageReceiver< T >.messageReceived | ( | ChannelHandlerContext | ctx, |
MessageEvent | e | ||
) | throws Exception [inline] |
Definition at line 55 of file MessageReceiver.java.
final boolean org.ros.internal.transport.queue.MessageReceiver< T >.DEBUG = false [static, private] |
Definition at line 37 of file MessageReceiver.java.
final MessageDeserializer<T> org.ros.internal.transport.queue.MessageReceiver< T >.deserializer [private] |
Definition at line 41 of file MessageReceiver.java.
final CircularBlockingDeque<LazyMessage<T> > org.ros.internal.transport.queue.MessageReceiver< T >.lazyMessages [private] |
Definition at line 40 of file MessageReceiver.java.
final Log org.ros.internal.transport.queue.MessageReceiver< T >.log = LogFactory.getLog(MessageReceiver.class) [static, private] |
Definition at line 38 of file MessageReceiver.java.