java.lang.Object
org.activemq.io.AbstractWireFormat
org.activemq.transport.openwire.OpenWireFormatSupport
- All Implemented Interfaces:
- org.activemq.io.WireFormat
- public abstract class OpenWireFormatSupport
- extends org.activemq.io.AbstractWireFormat
Base class for the code generated org.activemq.transport.openwire.io.OpenWireFormat
- Version:
- $Revision: 1.1 $
| Methods inherited from class org.activemq.io.AbstractWireFormat |
doesSupportMessageCompression, doesSupportMessageFragmentation, fromBytes, fromBytes, getTransportDataIn, getTransportDataOut, initiateClientSideProtocol, initiateServerSideProtocol, isCachingEnabled, readPacket, registerTransportStreams, setCachingEnabled, setTransportDataIn, setTransportDataOut, toBytes, writePacket |
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
OpenWireFormatSupport
public OpenWireFormatSupport()
readPacket
public org.activemq.message.Packet readPacket(java.io.DataInput dataIn)
throws java.io.IOException
- Description copied from interface:
org.activemq.io.WireFormat
- Reads a packet from the given input stream
canProcessWireFormatVersion
public boolean canProcessWireFormatVersion(int version)
- Description copied from interface:
org.activemq.io.WireFormat
- Can this wireformat process packets of this version
copy
public org.activemq.io.WireFormat copy()
- Description copied from interface:
org.activemq.io.WireFormat
- Creates a new copy of this wire format so it can be used in another thread/context
getCurrentWireFormatVersion
public int getCurrentWireFormatVersion()
writePacket
public org.activemq.message.Packet writePacket(org.activemq.message.Packet packet,
java.io.DataOutput out)
throws java.io.IOException,
javax.jms.JMSException
- Description copied from interface:
org.activemq.io.WireFormat
- Writes the packet to the given output stream
readPacket
protected org.activemq.message.Packet readPacket(java.io.DataInput dataIn,
org.activemq.io.impl.AbstractPacketMarshaller marshaler)
throws java.io.IOException
getMarshaller
protected abstract org.activemq.io.impl.AbstractPacketMarshaller getMarshaller(org.activemq.message.Packet packet)