java.lang.Object
org.activemq.io.impl.AbstractPacketReader
org.activemq.io.impl.AbstractPacketMarshaller
org.activemq.transport.openwire.OpenWirePacketMarshallerSupport
org.activemq.transport.openwire.io.ActiveMQMessageMarshaller
org.activemq.transport.openwire.io.ActiveMQStreamMessageMarshaller
- All Implemented Interfaces:
- org.activemq.io.impl.PacketReader, org.activemq.io.impl.PacketWriter
- public class ActiveMQStreamMessageMarshaller
- extends ActiveMQMessageMarshaller
AUTOGENERATED Marshaller for OpenWire command ActiveMQStreamMessage
- Version:
- $Revision: 1.1 $
| Methods inherited from class org.activemq.transport.openwire.OpenWirePacketMarshallerSupport |
readBoolean, readBytes, readDestination, readProperties, readString, writeBoolean, writeBytes, writeDestination, writeDestination, writeProperties, writeProperties, writeString |
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ActiveMQStreamMessageMarshaller
public ActiveMQStreamMessageMarshaller()
getPacketType
public int getPacketType()
- Return the type of Packet
- Specified by:
getPacketType in interface org.activemq.io.impl.PacketWriter- Overrides:
getPacketType in class ActiveMQMessageMarshaller
createPacket
public org.activemq.message.Packet createPacket()
- Specified by:
createPacket in interface org.activemq.io.impl.PacketReader- Overrides:
createPacket in class ActiveMQMessageMarshaller
buildPacket
public void buildPacket(org.activemq.message.Packet packet,
java.io.DataInput dataIn)
throws java.io.IOException
- build a Packet instance from the data input stream
- Specified by:
buildPacket in interface org.activemq.io.impl.PacketReader- Overrides:
buildPacket in class ActiveMQMessageMarshaller
writePacket
public void writePacket(org.activemq.message.Packet packet,
java.io.DataOutput dataOut)
throws java.io.IOException
- Write a Packet instance to data output stream
- Specified by:
writePacket in interface org.activemq.io.impl.PacketWriter- Overrides:
writePacket in class ActiveMQMessageMarshaller