public class MQTTWireFormat extends Object implements WireFormat
Constructor and Description |
---|
MQTTWireFormat() |
Modifier and Type | Method and Description |
---|---|
int |
getVersion() |
ByteSequence |
marshal(Object command)
Packet based marshaling
|
void |
marshal(Object command,
DataOutput dataOut)
Stream based marshaling
|
void |
setVersion(int version) |
Object |
unmarshal(ByteSequence packet)
Packet based un-marshaling
|
Object |
unmarshal(DataInput dataIn)
Packet based un-marshaling
|
public MQTTWireFormat()
public ByteSequence marshal(Object command) throws IOException
WireFormat
marshal
in interface WireFormat
IOException
public Object unmarshal(ByteSequence packet) throws IOException
WireFormat
unmarshal
in interface WireFormat
IOException
public void marshal(Object command, DataOutput dataOut) throws IOException
WireFormat
marshal
in interface WireFormat
IOException
public Object unmarshal(DataInput dataIn) throws IOException
WireFormat
unmarshal
in interface WireFormat
IOException
public void setVersion(int version)
setVersion
in interface WireFormat
the
- version of the wire formatpublic int getVersion()
getVersion
in interface WireFormat
Copyright © 2005–2017. All rights reserved.