org.ros.internal.transport.queue

Class MessageDispatcher<T>

java.lang.Object

org.ros.concurrent.CancellableLoop

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

Type Parameters:

T - the message type

All Implemented Interfaces:

java.lang.Runnable

public class MessageDispatcher<T>
extends CancellableLoop

Constructor Summary

Constructors

Constructor and Description
MessageDispatcher(CircularBlockingDeque<LazyMessage<T>> lazyMessages, java.util.concurrent.ExecutorService executorService)

Method Summary

Methods

Modifier and Type	Method and Description
void	addListener(org.ros.message.MessageListener<T> messageListener, int limit) Adds the specified MessageListener to the internal ListenerGroup.
boolean	getLatchMode()
protected void	handleInterruptedException(java.lang.InterruptedException e) An InterruptedException was thrown.
void	loop() The body of the loop.
void	setLatchMode(boolean enabled)

Methods inherited from class org.ros.concurrent.CancellableLoop

cancel, isRunning, run, setup

Methods inherited from class java.lang.Object

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

Constructor Detail

MessageDispatcher

public MessageDispatcher(CircularBlockingDeque<LazyMessage<T>> lazyMessages,
                 java.util.concurrent.ExecutorService executorService)

Method Detail

addListener

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

Adds the specified MessageListener to the internal ListenerGroup. If latchMode is true, the latchedMessage will be immediately dispatched to the specified MessageListener.

See Also:

ListenerGroup.add(Object, int)

setLatchMode

public void setLatchMode(boolean enabled)

Parameters:

enabled - true if latch mode should be enabled, false otherwise

getLatchMode

public boolean getLatchMode()

Returns:

true if latch mode is enabled, false otherwise

loop

public void loop()
          throws java.lang.InterruptedException

Description copied from class: CancellableLoop

The body of the loop. This will run continuously until the CancellableLoop has been interrupted externally or by calling CancellableLoop.cancel().

Specified by:

loop in class CancellableLoop

Throws:

java.lang.InterruptedException

handleInterruptedException

protected void handleInterruptedException(java.lang.InterruptedException e)

Description copied from class: CancellableLoop

An InterruptedException was thrown.

Overrides:

handleInterruptedException in class CancellableLoop