org.ros.internal.transport.queue

Class OutgoingMessageQueue<T>

java.lang.Object

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

public class OutgoingMessageQueue<T>
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
OutgoingMessageQueue(org.ros.message.MessageSerializer<T> serializer, java.util.concurrent.ExecutorService executorService)

Method Summary

Methods

Modifier and Type	Method and Description
void	add(T message)
void	addChannel(org.jboss.netty.channel.Channel channel)
org.jboss.netty.channel.group.ChannelGroup	getChannelGroup()
boolean	getLatchMode()
int	getNumberOfChannels()
void	setLatchMode(boolean enabled)
void	shutdown() Stop writing messages and close all outgoing connections.

Methods inherited from class java.lang.Object

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

Constructor Detail

OutgoingMessageQueue

public OutgoingMessageQueue(org.ros.message.MessageSerializer<T> serializer,
                    java.util.concurrent.ExecutorService executorService)

Method Detail

setLatchMode

public void setLatchMode(boolean enabled)

getLatchMode

public boolean getLatchMode()

add

public void add(T message)

Parameters:

message - the message to add to the queue

shutdown

public void shutdown()

Stop writing messages and close all outgoing connections.

addChannel

public void addChannel(org.jboss.netty.channel.Channel channel)

Parameters:

channel - added to this OutgoingMessageQueue's ChannelGroup

getNumberOfChannels

public int getNumberOfChannels()

Returns:

the number of Channels which have been added to this queue

getChannelGroup

public org.jboss.netty.channel.group.ChannelGroup getChannelGroup()