|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.activemq.transport.mqtt.MQTTWireFormat
public class MQTTWireFormat
Implements marshalling and unmarsalling the MQTT protocol.
Constructor Summary | |
---|---|
MQTTWireFormat()
|
Method Summary | |
---|---|
int |
getVersion()
|
ByteSequence |
marshal(java.lang.Object command)
Packet based marshaling |
void |
marshal(java.lang.Object command,
java.io.DataOutput dataOut)
Stream based marshaling |
void |
setVersion(int version)
|
java.lang.Object |
unmarshal(ByteSequence packet)
Packet based un-marshaling |
java.lang.Object |
unmarshal(java.io.DataInput dataIn)
Packet based un-marshaling |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public MQTTWireFormat()
Method Detail |
---|
public ByteSequence marshal(java.lang.Object command) throws java.io.IOException
WireFormat
marshal
in interface WireFormat
java.io.IOException
public java.lang.Object unmarshal(ByteSequence packet) throws java.io.IOException
WireFormat
unmarshal
in interface WireFormat
java.io.IOException
public void marshal(java.lang.Object command, java.io.DataOutput dataOut) throws java.io.IOException
WireFormat
marshal
in interface WireFormat
java.io.IOException
public java.lang.Object unmarshal(java.io.DataInput dataIn) throws java.io.IOException
WireFormat
unmarshal
in interface WireFormat
java.io.IOException
public void setVersion(int version)
setVersion
in interface WireFormat
the
- version of the wire formatpublic int getVersion()
getVersion
in interface WireFormat
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |