Public Member Functions | Private Attributes | Static Private Attributes
org.ros.internal.transport.queue.IncomingMessageQueue< T > Class Reference

List of all members.

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

Detailed Description

Author:
damonkohler@google.com (Damon Kohler)

Definition at line 29 of file IncomingMessageQueue.java.


Constructor & Destructor Documentation

org.ros.internal.transport.queue.IncomingMessageQueue< T >.IncomingMessageQueue ( MessageDeserializer< T >  deserializer,
ExecutorService  executorService 
) [inline]

Definition at line 45 of file IncomingMessageQueue.java.


Member Function Documentation

void org.ros.internal.transport.queue.IncomingMessageQueue< T >.addListener ( final MessageListener< T >  messageListener,
int  queueCapacity 
) [inline]
See also:
MessageDispatcher::addListener(MessageListener, int)

Definition at line 70 of file IncomingMessageQueue.java.

boolean org.ros.internal.transport.queue.IncomingMessageQueue< T >.getLatchMode ( ) [inline]
See also:
MessageDispatcher::getLatchMode()

Definition at line 63 of file IncomingMessageQueue.java.

NamedChannelHandler org.ros.internal.transport.queue.IncomingMessageQueue< T >.getMessageReceiver ( ) [inline]
Returns:
a NamedChannelHandler that will receive messages and add them to the queue

Definition at line 82 of file IncomingMessageQueue.java.

void org.ros.internal.transport.queue.IncomingMessageQueue< T >.setLatchMode ( boolean  enabled) [inline]
See also:
MessageDispatcher::setLatchMode(boolean)

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.


Member Data Documentation

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.


The documentation for this class was generated from the following file:


rosjava_core
Author(s):
autogenerated on Wed Aug 26 2015 16:06:51