Class XStreamWireFormat
- java.lang.Object
-
- org.apache.activemq.transport.util.TextWireFormat
-
- org.apache.activemq.transport.xstream.XStreamWireFormat
-
- All Implemented Interfaces:
WireFormat
public class XStreamWireFormat extends TextWireFormat
AWireFormat
implementation which uses the-
-
Constructor Summary
Constructors Constructor Description XStreamWireFormat()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
canProcessWireFormatVersion(int version)
Can this wireformat process packets of this versionWireFormat
copy()
protected com.thoughtworks.xstream.XStream
createXStream()
int
getCurrentWireFormatVersion()
int
getVersion()
com.thoughtworks.xstream.XStream
getXStream()
String
marshalText(Object command)
void
setVersion(int version)
void
setXStream(com.thoughtworks.xstream.XStream xStream)
Object
unmarshalText(Reader reader)
Object
unmarshalText(String text)
-
-
-
Method Detail
-
getVersion
public int getVersion()
- Returns:
- the version of the wire format
-
setVersion
public void setVersion(int version)
- Parameters:
version
- the version of the wire format
-
copy
public WireFormat copy()
-
unmarshalText
public Object unmarshalText(String text)
- Specified by:
unmarshalText
in classTextWireFormat
-
unmarshalText
public Object unmarshalText(Reader reader)
- Specified by:
unmarshalText
in classTextWireFormat
-
marshalText
public String marshalText(Object command) throws IOException
- Specified by:
marshalText
in classTextWireFormat
- Throws:
IOException
-
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()
-
-