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
AWireFormatimplementation which uses the-
-
Constructor Summary
Constructors Constructor Description XStreamWireFormat()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description booleancanProcessWireFormatVersion(int version)Can this wireformat process packets of this versionWireFormatcopy()protected com.thoughtworks.xstream.XStreamcreateXStream()intgetCurrentWireFormatVersion()intgetVersion()com.thoughtworks.xstream.XStreamgetXStream()StringmarshalText(Object command)voidsetVersion(int version)voidsetXStream(com.thoughtworks.xstream.XStream xStream)ObjectunmarshalText(Reader reader)ObjectunmarshalText(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:
unmarshalTextin classTextWireFormat
-
unmarshalText
public Object unmarshalText(Reader reader)
- Specified by:
unmarshalTextin classTextWireFormat
-
marshalText
public String marshalText(Object command) throws IOException
- Specified by:
marshalTextin 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()
-
-