org.codehaus.activemq.transport.xstream
Class XStreamWireFormat
java.lang.Object
org.codehaus.activemq.io.AbstractWireFormat
org.codehaus.activemq.io.TextWireFormat
org.codehaus.activemq.transport.xstream.XStreamWireFormat
- All Implemented Interfaces:
- org.codehaus.activemq.io.WireFormat
- public class XStreamWireFormat
- extends org.codehaus.activemq.io.TextWireFormat
A WireFormat
implementation which uses the
Methods inherited from class org.codehaus.activemq.io.AbstractWireFormat |
fromBytes, fromBytes, initiateProtocol, readPacket, 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.codehaus.activemq.message.Packet readPacket(DataInput in)
throws IOException
- Throws:
IOException
readPacket
public org.codehaus.activemq.message.Packet readPacket(int firstByte,
DataInput in)
throws IOException
- Throws:
IOException
writePacket
public void writePacket(org.codehaus.activemq.message.Packet packet,
DataOutput out)
throws IOException,
JMSException
- Throws:
IOException
JMSException
copy
public org.codehaus.activemq.io.WireFormat copy()
toString
public String toString(org.codehaus.activemq.message.Packet packet)
fromString
public org.codehaus.activemq.message.Packet fromString(String xml)
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-2005 Protique, Ltd.. All Rights Reserved.