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

public class MessageReceiver<T>
extends AbstractNamedChannelHandler

Nested Class Summary

Nested classes/interfaces inherited from interface org.jboss.netty.channel.ChannelHandler

org.jboss.netty.channel.ChannelHandler.Sharable

Constructor Summary

Constructors

Constructor and Description
MessageReceiver(CircularBlockingDeque<LazyMessage<T>> lazyMessages, org.ros.message.MessageDeserializer<T> deserializer)

Method Summary

Methods

Modifier and Type	Method and Description
java.lang.String	getName()
void	messageReceived(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.channel.MessageEvent e)

Methods inherited from class org.ros.internal.transport.tcp.AbstractNamedChannelHandler

toString

Methods 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, writeRequested

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.jboss.netty.channel.ChannelUpstreamHandler

handleUpstream

Methods inherited from interface org.jboss.netty.channel.ChannelDownstreamHandler

handleDownstream

Constructor Detail

MessageReceiver

public MessageReceiver(CircularBlockingDeque<LazyMessage<T>> lazyMessages,
               org.ros.message.MessageDeserializer<T> deserializer)

Method Detail

getName

public java.lang.String getName()

Returns:

the name of this ChannelHandler

messageReceived

public void messageReceived(org.jboss.netty.channel.ChannelHandlerContext ctx,
                   org.jboss.netty.channel.MessageEvent e)
                     throws java.lang.Exception

Overrides:

messageReceived in class org.jboss.netty.channel.SimpleChannelHandler

Throws:

java.lang.Exception