org.codehaus.activemq.message
Class AbstractPacketWriter

java.lang.Object
  org.codehaus.activemq.message.AbstractPacketWriter

All Implemented Interfaces:

PacketWriter

Direct Known Subclasses:

ActiveMQMessageWriter, BrokerInfoWriter, CapacityInfoRequestWriter, CapacityInfoWriter, ConnectionInfoWriter, ConsumerInfoWriter, DurableUnsubscribeWriter, MessageAckWriter, ProducerInfoWriter, ReceiptWriter, SessionInfoWriter, TransactionInfoWriter, WireFormatInfoWriter, XATransactionInfoWriter

public abstract class AbstractPacketWriter

extends Object

implements PacketWriter

Allows instances implementing Packet interface to be serailized/deserailized

Constructor Summary

AbstractPacketWriter()

Method Summary

boolean	canWrite(Packet packet)
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.message.PacketWriter

getPacketType

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