public class MQTTWireFormat extends Object implements org.apache.activemq.wireformat.WireFormat
Constructor and Description |
---|
MQTTWireFormat() |
Modifier and Type | Method and Description |
---|---|
long |
getConnectAttemptTimeout() |
int |
getMaxFrameSize() |
int |
getVersion() |
ByteSequence |
marshal(Object command) |
void |
marshal(Object command,
DataOutput dataOut) |
void |
setConnectAttemptTimeout(long connectTimeout)
Sets the timeout value used to fail a connection if no CONNECT frame is read
in the given interval.
|
void |
setMaxFrameSize(int maxFrameSize)
Sets the maximum frame size for an incoming MQTT frame.
|
void |
setVersion(int version) |
Object |
unmarshal(ByteSequence packet) |
Object |
unmarshal(DataInput dataIn) |
public MQTTWireFormat()
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 dataOut) throws IOException
marshal
in interface org.apache.activemq.wireformat.WireFormat
IOException
public Object unmarshal(DataInput dataIn) throws IOException
unmarshal
in interface org.apache.activemq.wireformat.WireFormat
IOException
public void setVersion(int version)
setVersion
in interface org.apache.activemq.wireformat.WireFormat
the
- version of the wire formatpublic int getVersion()
getVersion
in interface org.apache.activemq.wireformat.WireFormat
public int getMaxFrameSize()
public void setMaxFrameSize(int maxFrameSize)
maxFrameSize
- the maximum allowed frame size for a single MQTT frame.public long getConnectAttemptTimeout()
public void setConnectAttemptTimeout(long connectTimeout)
connectTimeout
- the connection frame received timeout value.Copyright © 2005–2020 FuseSource, Corp.. All rights reserved.