Package org.ros.internal.transport.queue

Class OutgoingMessageQueue<T>

java.lang.Object
org.ros.internal.transport.queue.OutgoingMessageQueue<T>
public class OutgoingMessageQueue<T> extends Object
Author:
damonkohler@google.com (Damon Kohler)

  • Constructor Details

    • OutgoingMessageQueue

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

  • Method Details

    • 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()