Save This Page
Home » activemq-parent-5.3.1-source-release » org.apache » activemq » transport » udp » [javadoc | source]
org.apache.activemq.transport.udp
public class: CommandDatagramSocket [javadoc | source]
java.lang.Object
   org.apache.activemq.transport.udp.CommandChannelSupport
      org.apache.activemq.transport.udp.CommandDatagramSocket

All Implemented Interfaces:
    CommandChannel

A strategy for reading datagrams and de-fragmenting them together.
Fields inherited from org.apache.activemq.transport.udp.CommandChannelSupport:
wireFormat,  datagramSize,  targetAddress,  replayAddress,  name,  sequenceGenerator,  headerMarshaller
Constructor:
 public CommandDatagramSocket(UdpTransport transport,
    OpenWireFormat wireFormat,
    int datagramSize,
    SocketAddress targetAddress,
    DatagramHeaderMarshaller headerMarshaller,
    DatagramSocket channel) 
Method from org.apache.activemq.transport.udp.CommandDatagramSocket Summary:
createByteArrayOutputStream,   createDatagramPacket,   getDatagramSize,   getReceiveCounter,   read,   remaining,   sendBuffer,   sendWriteBuffer,   sendWriteBuffer,   setDatagramSize,   start,   stop,   write
Methods from org.apache.activemq.transport.udp.CommandChannelSupport:
getDatagramSize,   getHeaderMarshaller,   getReplayAddress,   getReplayBuffer,   getTargetAddress,   setDatagramSize,   setHeaderMarshaller,   setReplayAddress,   setReplayBuffer,   setTargetAddress,   toString,   write
Methods from java.lang.Object:
clone,   equals,   finalize,   getClass,   hashCode,   notify,   notifyAll,   toString,   wait,   wait,   wait
Method from org.apache.activemq.transport.udp.CommandDatagramSocket Detail:
 protected ByteArrayOutputStream createByteArrayOutputStream() 
 protected DatagramPacket createDatagramPacket() 
 public int getDatagramSize() 
 public int getReceiveCounter() 
 public Command read() throws IOException 
 protected int remaining(ByteArrayOutputStream buffer) 
 public  void sendBuffer(int commandId,
    Object buffer) throws IOException 
 protected  void sendWriteBuffer(SocketAddress address,
    ByteArrayOutputStream writeBuffer,
    int commandId) throws IOException 
 protected  void sendWriteBuffer(int commandId,
    SocketAddress address,
    byte[] data,
    boolean redelivery) throws IOException 
 public  void setDatagramSize(int datagramSize) 
 public  void start() throws Exception 
 public  void stop() throws Exception 
 public  void write(Command command,
    SocketAddress address) throws IOException