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

java.lang.Object
  org.ros.internal.transport.OutgoingMessageQueue<T>

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

Constructor Summary

OutgoingMessageQueue(MessageSerializer<T> serializer, java.util.concurrent.ScheduledExecutorService executorService)

Method Summary

void	addChannel(org.jboss.netty.channel.Channel channel)
boolean	getLatchMode()
int	getLimit()
int	getNumberOfChannels()
void	put(T message)
void	setLatchMode(boolean enabled)
void	setLimit(int limit)
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(MessageSerializer<T> serializer,
                            java.util.concurrent.ScheduledExecutorService executorService)

Method Detail

setLatchMode

public void setLatchMode(boolean enabled)

getLatchMode

public boolean getLatchMode()

put

public void put(T message)

Parameters:

message - the message to add to the queue

shutdown

public void shutdown()

Stop writing messages and close all outgoing connections.

setLimit

public void setLimit(int limit)

See Also:

CircularBlockingQueue.setLimit(int)

getLimit

public int getLimit()

See Also:

CircularBlockingQueue.getLimit()

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