java.lang.Object
org.activemq.io.impl.AbstractPacketReader
- All Implemented Interfaces:
- PacketReader
- Direct Known Subclasses:
- AbstractPacketMarshaller, ActiveMQMessageReader, BrokerAdminCommandReader, BrokerInfoReader, CachedValueReader, CapacityInfoReader, CapacityInfoRequestReader, CleanupConnectionInfoReader, ConnectionInfoReader, ConsumerInfoReader, DurableUnsubscribeReader, KeepAliveReader, MessageAckReader, ProducerInfoReader, ReceiptReader, SessionInfoReader, TransactionInfoReader, WireFormatInfoReader, XATransactionInfoReader
- public abstract class AbstractPacketReader
- extends java.lang.Object
- implements PacketReader
Allows instances implementing Packet interface to be deserailized
- Version:
- $Revision: 1.1.1.1 $
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
wireFormatVersion
protected int wireFormatVersion
AbstractPacketReader
public AbstractPacketReader()
canRead
public boolean canRead(int packetType)
- Specified by:
canRead in interface PacketReader
readUTF
protected java.lang.String readUTF(java.io.DataInput dataIn)
throws java.io.IOException
- pointless method - but mirrors writer
readObject
protected java.lang.Object readObject(java.io.DataInput dataIn)
throws java.io.IOException
- ;
buildPacket
public void buildPacket(org.activemq.message.Packet p,
java.io.DataInput dataIn)
throws java.io.IOException
- build a Packet instance from the data input stream
- Specified by:
buildPacket in interface PacketReader
readPacketFromByteArray
public org.activemq.message.Packet readPacketFromByteArray(byte[] data)
throws java.io.IOException
- Deserailizes a Packet from a byte array
- Specified by:
readPacketFromByteArray in interface PacketReader
setWireFormatVersion
public void setWireFormatVersion(int version)
- Set the wire format version
- Specified by:
setWireFormatVersion in interface PacketReader
getWireFormatVersion
public int getWireFormatVersion()
- Specified by:
getWireFormatVersion in interface PacketReader