org.codehaus.activemq.message
Class ActiveMQMessageWriter

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

All Implemented Interfaces:

PacketWriter

Direct Known Subclasses:

ActiveMQBytesMessageWriter, ActiveMQMapMessageWriter, ActiveMQObjectMessageWriter, ActiveMQStreamMessageWriter, ActiveMQTextMessageWriter

public class ActiveMQMessageWriter

extends AbstractPacketWriter

Writes a ProducerInfo object to a Stream

Constructor Summary

ActiveMQMessageWriter()

Method Summary

int	getPacketType() Return the type of Packet
protected void	writeMessage(ActiveMQMessage msg, java.io.DataOutput dataOut)
void	writePacket(Packet packet, java.io.DataOutput dataOut) Write a Packet instance to data output stream

Methods inherited from class org.codehaus.activemq.message.AbstractPacketWriter

canWrite, writeObject, writePacketToByteArray, writeUTF

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ActiveMQMessageWriter

public ActiveMQMessageWriter()

Method Detail

getPacketType

public int getPacketType()

Return the type of Packet

Returns:

integer representation of the type of Packet

writePacket

public void writePacket(Packet packet,
                        java.io.DataOutput dataOut)
                 throws java.io.IOException

Write a Packet instance to data output stream

Specified by:

writePacket in interface PacketWriter

Overrides:

writePacket in class AbstractPacketWriter

Parameters:

packet - the instance to be seralized

dataOut - the output stream

Throws:

java.io.IOException - thrown if an error occurs

writeMessage

protected void writeMessage(ActiveMQMessage msg,
                            java.io.DataOutput dataOut)
                     throws java.io.IOException

Parameters:

msg -

dataOut -

Throws:

java.io.IOException