org.apache.activemq.kaha: public class: CommandMarshaller

org.apache.activemq.kaha
public class: CommandMarshaller [javadoc | source]

java.lang.Object
   org.apache.activemq.kaha.CommandMarshaller

All Implemented Interfaces:
Marshaller

Marshall a Message or a MessageReference

version: $ - Revision: 1.10 $

Constructor:
public CommandMarshaller() { this(new OpenWireFormat()); }
public CommandMarshaller(WireFormat wireFormat) { this.wireFormat = wireFormat; }

Constructor:

 public CommandMarshaller() {
        this(new OpenWireFormat());
}

 public CommandMarshaller(WireFormat wireFormat) {
        this.wireFormat = wireFormat;
}

Method from org.apache.activemq.kaha.CommandMarshaller Summary:
readPayload, writePayload

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

Method from org.apache.activemq.kaha.CommandMarshaller Detail:
public Object readPayload(DataInput dataIn) throws IOException { int size = dataIn.readInt(); byte[] data = new byte[size]; dataIn.readFully(data); return wireFormat.unmarshal(new ByteSequence(data)); }
public void writePayload(Object object, DataOutput dataOut) throws IOException { ByteSequence packet = wireFormat.marshal(object); dataOut.writeInt(packet.length); dataOut.write(packet.data, packet.offset, packet.length); }

Method from org.apache.activemq.kaha.CommandMarshaller Detail:

 public Object readPayload(DataInput dataIn) throws IOException {
        int size = dataIn.readInt();
        byte[] data = new byte[size];
        dataIn.readFully(data);
        return wireFormat.unmarshal(new ByteSequence(data));
}

 public  void writePayload(Object object,
    DataOutput dataOut) throws IOException {
        ByteSequence packet = wireFormat.marshal(object);
        dataOut.writeInt(packet.length);
        dataOut.write(packet.data, packet.offset, packet.length);
}