org.ros.internal.transport.queue

Class IncomingMessageQueue<T>

java.lang.Object

org.ros.internal.transport.queue.IncomingMessageQueue<T>

public class IncomingMessageQueue<T>
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
IncomingMessageQueue(org.ros.message.MessageDeserializer<T> deserializer, java.util.concurrent.ExecutorService executorService)

Method Summary

Methods

Modifier and Type	Method and Description
void	addListener(org.ros.message.MessageListener<T> messageListener, int queueCapacity)
boolean	getLatchMode()
NamedChannelHandler	getMessageReceiver()
void	setLatchMode(boolean enabled)
void	shutdown()

Methods inherited from class java.lang.Object

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

Constructor Detail

IncomingMessageQueue

public IncomingMessageQueue(org.ros.message.MessageDeserializer<T> deserializer,
                    java.util.concurrent.ExecutorService executorService)

Method Detail

setLatchMode

public void setLatchMode(boolean enabled)

See Also:

MessageDispatcher.setLatchMode(boolean)

getLatchMode

public boolean getLatchMode()

See Also:

MessageDispatcher.getLatchMode()

addListener

public void addListener(org.ros.message.MessageListener<T> messageListener,
               int queueCapacity)

See Also:

MessageDispatcher.addListener(MessageListener, int)

shutdown

public void shutdown()

getMessageReceiver

public NamedChannelHandler getMessageReceiver()

Returns:

a NamedChannelHandler that will receive messages and add them to the queue