org.activemq.transport.xstream
Class XStreamWireFormat
java.lang.Object
org.activemq.io.AbstractWireFormat
org.activemq.io.TextWireFormat
org.activemq.transport.xstream.XStreamWireFormat
- All Implemented Interfaces:
- org.activemq.io.WireFormat
public class XStreamWireFormat
- extends org.activemq.io.TextWireFormat
A WireFormat
implementation which uses the
Fields inherited from class org.activemq.io.AbstractWireFormat |
cachingEnabled, transportDataIn, transportDataOut |
Fields inherited from interface org.activemq.io.WireFormat |
DEFAULT_MAXIMUM_MESSAGE_SIZE |
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 |
XStreamWireFormat
public XStreamWireFormat()
readPacket
public org.activemq.message.Packet readPacket(DataInput in)
throws IOException
- Specified by:
readPacket
in interface org.activemq.io.WireFormat
- Overrides:
readPacket
in class org.activemq.io.AbstractWireFormat
- Throws:
IOException
readPacket
public org.activemq.message.Packet readPacket(int firstByte,
DataInput in)
throws IOException
- Throws:
IOException
writePacket
public org.activemq.message.Packet writePacket(org.activemq.message.Packet packet,
DataOutput out)
throws IOException,
JMSException
- Throws:
IOException
JMSException
copy
public org.activemq.io.WireFormat copy()
toString
public String toString(org.activemq.message.Packet packet)
- Specified by:
toString
in class org.activemq.io.TextWireFormat
fromString
public org.activemq.message.Packet fromString(String xml)
- Specified by:
fromString
in class org.activemq.io.TextWireFormat
canProcessWireFormatVersion
public boolean canProcessWireFormatVersion(int version)
- Can this wireformat process packets of this version
- Parameters:
version
- the version number to test
- Returns:
- true if can accept the version
getCurrentWireFormatVersion
public int getCurrentWireFormatVersion()
- Returns:
- the current version of this wire format
getXStream
public com.thoughtworks.xstream.XStream getXStream()
setXStream
public void setXStream(com.thoughtworks.xstream.XStream xStream)
createXStream
protected com.thoughtworks.xstream.XStream createXStream()
Copyright © 2004-2010 Protique, Ltd.. All Rights Reserved.