org.apache.activemq.transport.multicast: public class: MulticastDatagramHeaderMarshaller

org.apache.activemq.transport.multicast
public class: MulticastDatagramHeaderMarshaller [javadoc | source]

java.lang.Object
   org.apache.activemq.transport.udp.DatagramHeaderMarshaller
      org.apache.activemq.transport.multicast.MulticastDatagramHeaderMarshaller

version: $ - Revision: 564814 $

Constructor:
public MulticastDatagramHeaderMarshaller(String localUri) { this.localUriAsBytes = localUri.getBytes(); }

Method from org.apache.activemq.transport.multicast.MulticastDatagramHeaderMarshaller Summary:
createEndpoint, writeHeader

Methods from org.apache.activemq.transport.udp.DatagramHeaderMarshaller:
createEndpoint, createEndpoint, createEndpoint, getEndpoint, writeHeader, writeHeader

Methods from java.lang.Object:
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method from org.apache.activemq.transport.multicast.MulticastDatagramHeaderMarshaller Detail:
public Endpoint createEndpoint(ByteBuffer readBuffer, SocketAddress address) { int size = readBuffer.getInt(); byte[] data = new byte[size]; readBuffer.get(data); return new DatagramEndpoint(new String(data), address); }
public void writeHeader(Command command, ByteBuffer writeBuffer) { writeBuffer.putInt(localUriAsBytes.length); writeBuffer.put(localUriAsBytes); super.writeHeader(command, writeBuffer); }

Method from org.apache.activemq.transport.multicast.MulticastDatagramHeaderMarshaller Detail:

 public Endpoint createEndpoint(ByteBuffer readBuffer,
    SocketAddress address) {
        int size = readBuffer.getInt();
        byte[] data = new byte[size];
        readBuffer.get(data);
        return new DatagramEndpoint(new String(data), address);
}

 public  void writeHeader(Command command,
    ByteBuffer writeBuffer) {
        writeBuffer.putInt(localUriAsBytes.length);
        writeBuffer.put(localUriAsBytes);
        super.writeHeader(command, writeBuffer);
}