org.codehaus.activemq.io.impl
Class AbstractPacketWriter

java.lang.Object
  extended byorg.codehaus.activemq.io.impl.AbstractPacketWriter
All Implemented Interfaces:
PacketWriter
Direct Known Subclasses:
ActiveMQMessageWriter, BrokerAdminCommandWriter, BrokerInfoWriter, CapacityInfoRequestWriter, CapacityInfoWriter, ConnectionInfoWriter, ConsumerInfoWriter, DurableUnsubscribeWriter, KeepAliveWriter, MessageAckWriter, ProducerInfoWriter, ReceiptWriter, SessionInfoWriter, TransactionInfoWriter, WireFormatInfoWriter, XATransactionInfoWriter

public abstract class AbstractPacketWriter
extends Object
implements PacketWriter

Allows instances implementing Packet interface to be serailized/deserailized


Field Summary
protected  int wireFormatVersion
           
 
Constructor Summary
AbstractPacketWriter()
           
 
Method Summary
 boolean canWrite(Packet packet)
           
 int getWireFormatVersion()
           
 void setWireFormatVersion(int version)
          Set the wire format version
protected  void writeObject(Object object, DataOutput dataOut)
          Simple (but inefficent) utility method to write an object on to a stream
 void writePacket(Packet p, DataOutput dataOut)
          Write a Packet instance to data output stream
 byte[] writePacketToByteArray(Packet packet)
          Serializes a Packet int a byte array
protected  void writeUTF(String str, DataOutput dataOut)
          simple helper method to ensure null strings are catered for
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface org.codehaus.activemq.io.impl.PacketWriter
getPacketType
 

Field Detail

wireFormatVersion

protected int wireFormatVersion
Constructor Detail

AbstractPacketWriter

public AbstractPacketWriter()
Method Detail

writeUTF

protected void writeUTF(String str,
                        DataOutput dataOut)
                 throws IOException
simple helper method to ensure null strings are catered for

Parameters:
str -
dataOut -
Throws:
IOException

canWrite

public boolean canWrite(Packet packet)
Specified by:
canWrite in interface PacketWriter
Parameters:
packet -
Returns:
true if this PacketWriter can write this type of Packet

writeObject

protected void writeObject(Object object,
                           DataOutput dataOut)
                    throws IOException
Simple (but inefficent) utility method to write an object on to a stream

Parameters:
object -
dataOut -
Throws:
IOException

writePacketToByteArray

public byte[] writePacketToByteArray(Packet packet)
                              throws IOException
Serializes a Packet int a byte array

Specified by:
writePacketToByteArray in interface PacketWriter
Parameters:
packet -
Returns:
the byte[]
Throws:
IOException

writePacket

public void writePacket(Packet p,
                        DataOutput dataOut)
                 throws IOException
Write a Packet instance to data output stream

Specified by:
writePacket in interface PacketWriter
Parameters:
p - the instance to be seralized
dataOut - the output stream
Throws:
IOException - thrown if an error occurs

setWireFormatVersion

public void setWireFormatVersion(int version)
Set the wire format version

Specified by:
setWireFormatVersion in interface PacketWriter
Parameters:
version -

getWireFormatVersion

public int getWireFormatVersion()
Specified by:
getWireFormatVersion in interface PacketWriter
Returns:
the wire format version


Copyright © 2004-2005 Protique, Ltd.. All Rights Reserved.