addListener(final MessageListener< T > messageListener, int queueCapacity) | org.ros.internal.transport.queue.IncomingMessageQueue< T > | [inline] |
DEQUE_CAPACITY | org.ros.internal.transport.queue.IncomingMessageQueue< T > | [private, static] |
getLatchMode() | org.ros.internal.transport.queue.IncomingMessageQueue< T > | [inline] |
getMessageReceiver() | org.ros.internal.transport.queue.IncomingMessageQueue< T > | [inline] |
IncomingMessageQueue(MessageDeserializer< T > deserializer, ExecutorService executorService) | org.ros.internal.transport.queue.IncomingMessageQueue< T > | [inline] |
messageDispatcher | org.ros.internal.transport.queue.IncomingMessageQueue< T > | [private] |
messageReceiver | org.ros.internal.transport.queue.IncomingMessageQueue< T > | [private] |
setLatchMode(boolean enabled) | org.ros.internal.transport.queue.IncomingMessageQueue< T > | [inline] |
shutdown() | org.ros.internal.transport.queue.IncomingMessageQueue< T > | [inline] |