Public Member Functions | |
void | addListener (final MessageListener< T > messageListener, int queueCapacity) |
boolean | getLatchMode () |
NamedChannelHandler | getMessageReceiver () |
IncomingMessageQueue (MessageDeserializer< T > deserializer, ExecutorService executorService) | |
void | setLatchMode (boolean enabled) |
void | shutdown () |
Private Attributes | |
final MessageDispatcher< T > | messageDispatcher |
final MessageReceiver< T > | messageReceiver |
Static Private Attributes | |
static final int | DEQUE_CAPACITY = 16 |
Definition at line 29 of file IncomingMessageQueue.java.
org.ros.internal.transport.queue.IncomingMessageQueue< T >.IncomingMessageQueue | ( | MessageDeserializer< T > | deserializer, |
ExecutorService | executorService | ||
) | [inline] |
Definition at line 45 of file IncomingMessageQueue.java.
void org.ros.internal.transport.queue.IncomingMessageQueue< T >.addListener | ( | final MessageListener< T > | messageListener, |
int | queueCapacity | ||
) | [inline] |
Definition at line 70 of file IncomingMessageQueue.java.
boolean org.ros.internal.transport.queue.IncomingMessageQueue< T >.getLatchMode | ( | ) | [inline] |
Definition at line 63 of file IncomingMessageQueue.java.
NamedChannelHandler org.ros.internal.transport.queue.IncomingMessageQueue< T >.getMessageReceiver | ( | ) | [inline] |
Definition at line 82 of file IncomingMessageQueue.java.
void org.ros.internal.transport.queue.IncomingMessageQueue< T >.setLatchMode | ( | boolean | enabled | ) | [inline] |
Definition at line 56 of file IncomingMessageQueue.java.
void org.ros.internal.transport.queue.IncomingMessageQueue< T >.shutdown | ( | ) | [inline] |
Definition at line 74 of file IncomingMessageQueue.java.
final int org.ros.internal.transport.queue.IncomingMessageQueue< T >.DEQUE_CAPACITY = 16 [static, private] |
The maximum number of incoming messages that will be queued.
This limit applies to dispatching LazyMessages as they arrive over the network. It is independent of MessageDispatcher queue capacities specified by IncomingMessageQueue#addListener(MessageListener, int) which are consumed by user provided MessageListeners.
Definition at line 40 of file IncomingMessageQueue.java.
final MessageDispatcher<T> org.ros.internal.transport.queue.IncomingMessageQueue< T >.messageDispatcher [private] |
Definition at line 43 of file IncomingMessageQueue.java.
final MessageReceiver<T> org.ros.internal.transport.queue.IncomingMessageQueue< T >.messageReceiver [private] |
Definition at line 42 of file IncomingMessageQueue.java.