public class StompWireFormat extends Object implements org.apache.activemq.wireformat.WireFormat
Modifier and Type | Field and Description |
---|---|
static long |
DEFAULT_CONNECTION_TIMEOUT |
static long |
DEFAULT_MAX_FRAME_SIZE |
Constructor and Description |
---|
StompWireFormat() |
Modifier and Type | Method and Description |
---|---|
long |
getConnectionAttemptTimeout() |
int |
getMaxDataLength() |
long |
getMaxFrameSize() |
String |
getStompVersion() |
int |
getVersion() |
ByteSequence |
marshal(Object command) |
void |
marshal(Object command,
DataOutput os) |
protected String |
parseAction(DataInput in,
AtomicLong frameSize) |
protected int |
parseContentLength(String contentLength,
AtomicLong frameSize) |
protected HashMap<String,String> |
parseHeaders(DataInput in,
AtomicLong frameSize) |
void |
setConnectionAttemptTimeout(long connectionAttemptTimeout) |
void |
setMaxDataLength(int maxDataLength) |
void |
setMaxFrameSize(long maxFrameSize) |
void |
setStompVersion(String stompVersion) |
void |
setVersion(int version) |
Object |
unmarshal(ByteSequence packet) |
Object |
unmarshal(DataInput in) |
public static final long DEFAULT_MAX_FRAME_SIZE
public static final long DEFAULT_CONNECTION_TIMEOUT
public StompWireFormat()
public ByteSequence marshal(Object command) throws IOException
marshal
in interface org.apache.activemq.wireformat.WireFormat
IOException
public Object unmarshal(ByteSequence packet) throws IOException
unmarshal
in interface org.apache.activemq.wireformat.WireFormat
IOException
public void marshal(Object command, DataOutput os) throws IOException
marshal
in interface org.apache.activemq.wireformat.WireFormat
IOException
public Object unmarshal(DataInput in) throws IOException
unmarshal
in interface org.apache.activemq.wireformat.WireFormat
IOException
protected String parseAction(DataInput in, AtomicLong frameSize) throws IOException
IOException
protected HashMap<String,String> parseHeaders(DataInput in, AtomicLong frameSize) throws IOException
IOException
protected int parseContentLength(String contentLength, AtomicLong frameSize) throws ProtocolException
ProtocolException
public int getVersion()
getVersion
in interface org.apache.activemq.wireformat.WireFormat
public void setVersion(int version)
setVersion
in interface org.apache.activemq.wireformat.WireFormat
public String getStompVersion()
public void setStompVersion(String stompVersion)
public void setMaxDataLength(int maxDataLength)
public int getMaxDataLength()
public long getMaxFrameSize()
public void setMaxFrameSize(long maxFrameSize)
public long getConnectionAttemptTimeout()
public void setConnectionAttemptTimeout(long connectionAttemptTimeout)
Copyright © 2005–2021 FuseSource, Corp.. All rights reserved.