org.ros.internal.transport
Class IncomingMessageQueue<T>
java.lang.Object
org.ros.internal.transport.IncomingMessageQueue<T>
public class IncomingMessageQueue<T>
- extends java.lang.Object
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
IncomingMessageQueue
public IncomingMessageQueue(MessageDeserializer<T> deserializer,
java.util.concurrent.ScheduledExecutorService executorService)
setLatchMode
public void setLatchMode(boolean enabled)
getLatchMode
public boolean getLatchMode()
addListener
public void addListener(MessageListener<T> listener)
removeListener
public void removeListener(MessageListener<T> listener)
shutdown
public void shutdown()
setLimit
public void setLimit(int limit)
- See Also:
CircularBlockingQueue.setLimit(int)
getLimit
public int getLimit()
- See Also:
CircularBlockingQueue.getLimit()
newChannelHandler
public org.jboss.netty.channel.ChannelHandler newChannelHandler()
- Returns:
- a new
ChannelHandler
that will receive messages and add
them to the queue