Package org.ros.internal.transport.queue

Class IncomingMessageQueue<T>

java.lang.Object

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

public class IncomingMessageQueue<T>
extends Object

Author:

damonkohler@google.com (Damon Kohler)

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	addListener(org.ros.message.MessageListener<T> messageListener, int queueCapacity)
boolean	getLatchMode()
NamedChannelHandler	getMessageReceiver()
void	removeAllListeners()
boolean	removeListener(org.ros.message.MessageListener<T> messageListener)
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 Details

IncomingMessageQueue

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

Method Details

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)

removeListener

public boolean removeListener(org.ros.message.MessageListener<T> messageListener)

See Also:

• MessageDispatcher.removeListener(MessageListener)

removeAllListeners

public void removeAllListeners()

See Also:

• MessageDispatcher.removeAllListeners()

shutdown

public void shutdown()

getMessageReceiver

public NamedChannelHandler getMessageReceiver()

Returns:

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