Docjar: A Java Source and Docuemnt Enginecom.*    java.*    javax.*    org.*    all    new    plug-in

Quick Search    Search Deep

org.activemq.io.impl
Class AbstractPacketReader  view AbstractPacketReader download AbstractPacketReader.java

java.lang.Object
  extended byorg.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 $

Field Summary
protected  int wireFormatVersion
           
 
Constructor Summary
AbstractPacketReader()
           
 
Method Summary
 void buildPacket(org.activemq.message.Packet p, java.io.DataInput dataIn)
          build a Packet instance from the data input stream
 boolean canRead(int packetType)
           
 int getWireFormatVersion()
           
protected  java.lang.Object readObject(java.io.DataInput dataIn)
          ;
 org.activemq.message.Packet readPacketFromByteArray(byte[] data)
          Deserailizes a Packet from a byte array
protected  java.lang.String readUTF(java.io.DataInput dataIn)
          pointless method - but mirrors writer
 void setWireFormatVersion(int version)
          Set the wire format version
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface org.activemq.io.impl.PacketReader
createPacket, getPacketType
 

Field Detail

wireFormatVersion

protected int wireFormatVersion
Constructor Detail

AbstractPacketReader

public AbstractPacketReader()
Method Detail

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