public class OutgoingMessageQueue<T>
extends java.lang.Object
Constructor and Description |
---|
OutgoingMessageQueue(org.ros.message.MessageSerializer<T> serializer,
java.util.concurrent.ExecutorService executorService) |
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.
|
public OutgoingMessageQueue(org.ros.message.MessageSerializer<T> serializer, java.util.concurrent.ExecutorService executorService)
public void setLatchMode(boolean enabled)
public boolean getLatchMode()
public void add(T message)
message
- the message to add to the queuepublic void shutdown()
public void addChannel(org.jboss.netty.channel.Channel channel)
channel
- added to this OutgoingMessageQueue
's ChannelGroup
public int getNumberOfChannels()
Channel
s which have been added to this queuepublic org.jboss.netty.channel.group.ChannelGroup getChannelGroup()