org.apache.activemq.openwire
Class OpenWireFormat
java.lang.Object
org.apache.activemq.openwire.OpenWireFormat
- All Implemented Interfaces:
- WireFormat
public final class OpenWireFormat
- extends Object
- implements WireFormat
- Version:
- $Revision$
Method Summary |
Short |
addToMarshallCache(DataStructure o)
|
OpenWireFormat |
copy()
|
Object |
doUnmarshal(DataInput dis)
|
boolean |
equals(Object object)
|
DataStructure |
getFromUnmarshallCache(short index)
|
Short |
getMarshallCacheIndex(DataStructure o)
|
WireFormatInfo |
getPreferedWireFormatInfo()
|
int |
getVersion()
|
int |
hashCode()
|
boolean |
isCacheEnabled()
|
boolean |
isSizePrefixDisabled()
|
boolean |
isStackTraceEnabled()
|
boolean |
isTcpNoDelayEnabled()
|
boolean |
isTightEncodingEnabled()
|
void |
looseMarshalNestedObject(DataStructure o,
DataOutput dataOut)
|
DataStructure |
looseUnmarshalNestedObject(DataInput dis)
|
ByteSequence |
marshal(Object command)
Packet based marshaling |
void |
marshal(Object o,
DataOutput dataOut)
Stream based marshaling |
protected int |
min(int version1,
int version2)
|
void |
renegotiateWireFormat(WireFormatInfo info)
|
void |
runMarshallCacheEvictionSweep()
|
void |
setCacheEnabled(boolean cacheEnabled)
|
void |
setInUnmarshallCache(short index,
DataStructure o)
|
void |
setPreferedWireFormatInfo(WireFormatInfo info)
|
void |
setSizePrefixDisabled(boolean prefixPacketSize)
|
void |
setStackTraceEnabled(boolean b)
|
void |
setTcpNoDelayEnabled(boolean tcpNoDelayEnabled)
|
void |
setTightEncodingEnabled(boolean tightEncodingEnabled)
|
void |
setVersion(int version)
Allows you to dynamically switch the version of the openwire protocol
being used. |
int |
tightMarshal1(Object o,
BooleanStream bs)
Used by NIO or AIO transports |
void |
tightMarshal2(Object o,
DataOutput ds,
BooleanStream bs)
Used by NIO or AIO transports; note that the size is not written as part
of this method. |
int |
tightMarshalNestedObject1(DataStructure o,
BooleanStream bs)
|
void |
tightMarshalNestedObject2(DataStructure o,
DataOutput ds,
BooleanStream bs)
|
DataStructure |
tightUnmarshalNestedObject(DataInput dis,
BooleanStream bs)
|
String |
toString()
|
Object |
unmarshal(ByteSequence sequence)
Packet based un-marshaling |
Object |
unmarshal(DataInput dis)
Packet based un-marshaling |
DEFAULT_VERSION
public static final int DEFAULT_VERSION
- See Also:
- Constant Field Values
OpenWireFormat
public OpenWireFormat()
OpenWireFormat
public OpenWireFormat(int i)
hashCode
public int hashCode()
- Overrides:
hashCode
in class Object
copy
public OpenWireFormat copy()
equals
public boolean equals(Object object)
- Overrides:
equals
in class Object
toString
public String toString()
- Overrides:
toString
in class Object
getVersion
public int getVersion()
- Specified by:
getVersion
in interface WireFormat
- Returns:
- the version of the wire format
marshal
public ByteSequence marshal(Object command)
throws IOException
- Description copied from interface:
WireFormat
- Packet based marshaling
- Specified by:
marshal
in interface WireFormat
- Throws:
IOException
unmarshal
public Object unmarshal(ByteSequence sequence)
throws IOException
- Description copied from interface:
WireFormat
- Packet based un-marshaling
- Specified by:
unmarshal
in interface WireFormat
- Throws:
IOException
marshal
public void marshal(Object o,
DataOutput dataOut)
throws IOException
- Description copied from interface:
WireFormat
- Stream based marshaling
- Specified by:
marshal
in interface WireFormat
- Throws:
IOException
unmarshal
public Object unmarshal(DataInput dis)
throws IOException
- Description copied from interface:
WireFormat
- Packet based un-marshaling
- Specified by:
unmarshal
in interface WireFormat
- Throws:
IOException
tightMarshal1
public int tightMarshal1(Object o,
BooleanStream bs)
throws IOException
- Used by NIO or AIO transports
- Throws:
IOException
tightMarshal2
public void tightMarshal2(Object o,
DataOutput ds,
BooleanStream bs)
throws IOException
- Used by NIO or AIO transports; note that the size is not written as part
of this method.
- Throws:
IOException
setVersion
public void setVersion(int version)
- Allows you to dynamically switch the version of the openwire protocol
being used.
- Specified by:
setVersion
in interface WireFormat
- Parameters:
version
-
doUnmarshal
public Object doUnmarshal(DataInput dis)
throws IOException
- Throws:
IOException
tightMarshalNestedObject1
public int tightMarshalNestedObject1(DataStructure o,
BooleanStream bs)
throws IOException
- Throws:
IOException
tightMarshalNestedObject2
public void tightMarshalNestedObject2(DataStructure o,
DataOutput ds,
BooleanStream bs)
throws IOException
- Throws:
IOException
tightUnmarshalNestedObject
public DataStructure tightUnmarshalNestedObject(DataInput dis,
BooleanStream bs)
throws IOException
- Throws:
IOException
looseUnmarshalNestedObject
public DataStructure looseUnmarshalNestedObject(DataInput dis)
throws IOException
- Throws:
IOException
looseMarshalNestedObject
public void looseMarshalNestedObject(DataStructure o,
DataOutput dataOut)
throws IOException
- Throws:
IOException
runMarshallCacheEvictionSweep
public void runMarshallCacheEvictionSweep()
getMarshallCacheIndex
public Short getMarshallCacheIndex(DataStructure o)
addToMarshallCache
public Short addToMarshallCache(DataStructure o)
setInUnmarshallCache
public void setInUnmarshallCache(short index,
DataStructure o)
getFromUnmarshallCache
public DataStructure getFromUnmarshallCache(short index)
setStackTraceEnabled
public void setStackTraceEnabled(boolean b)
isStackTraceEnabled
public boolean isStackTraceEnabled()
isTcpNoDelayEnabled
public boolean isTcpNoDelayEnabled()
setTcpNoDelayEnabled
public void setTcpNoDelayEnabled(boolean tcpNoDelayEnabled)
isCacheEnabled
public boolean isCacheEnabled()
setCacheEnabled
public void setCacheEnabled(boolean cacheEnabled)
isTightEncodingEnabled
public boolean isTightEncodingEnabled()
setTightEncodingEnabled
public void setTightEncodingEnabled(boolean tightEncodingEnabled)
isSizePrefixDisabled
public boolean isSizePrefixDisabled()
setSizePrefixDisabled
public void setSizePrefixDisabled(boolean prefixPacketSize)
setPreferedWireFormatInfo
public void setPreferedWireFormatInfo(WireFormatInfo info)
getPreferedWireFormatInfo
public WireFormatInfo getPreferedWireFormatInfo()
renegotiateWireFormat
public void renegotiateWireFormat(WireFormatInfo info)
throws IOException
- Throws:
IOException
min
protected int min(int version1,
int version2)
Copyright © 2005-2011 Apache Software Foundation. All Rights Reserved.