org.codehaus.activemq.transport.xstream
Class XStreamWireFormat

java.lang.Object
  extended byorg.codehaus.activemq.io.AbstractWireFormat
      extended byorg.codehaus.activemq.io.TextWireFormat
          extended byorg.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

Constructor Summary
XStreamWireFormat()
           
 
Method Summary
 boolean canProcessWireFormatVersion(int version)
          Can this wireformat process packets of this version
 org.codehaus.activemq.io.WireFormat copy()
           
protected  com.thoughtworks.xstream.XStream createXStream()
           
 org.codehaus.activemq.message.Packet fromString(String xml)
           
 int getCurrentWireFormatVersion()
           
 com.thoughtworks.xstream.XStream getXStream()
           
 org.codehaus.activemq.message.Packet readPacket(DataInput in)
           
 org.codehaus.activemq.message.Packet readPacket(int firstByte, DataInput in)
           
 void setXStream(com.thoughtworks.xstream.XStream xStream)
           
 String toString(org.codehaus.activemq.message.Packet packet)
           
 void writePacket(org.codehaus.activemq.message.Packet packet, DataOutput out)
           
 
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
 

Constructor Detail

XStreamWireFormat

public XStreamWireFormat()
Method Detail

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.