Modifier and Type | Class and Description |
---|---|
static interface |
MQTTCodec.MQTTFrameSink
Sink for newly decoded MQTT Frames.
|
Constructor and Description |
---|
MQTTCodec(MQTTCodec.MQTTFrameSink sink) |
MQTTCodec(MQTTCodec.MQTTFrameSink sink,
MQTTWireFormat wireFormat) |
MQTTCodec(TcpTransport transport) |
MQTTCodec(TcpTransport transport,
MQTTWireFormat wireFormat) |
Modifier and Type | Method and Description |
---|---|
void |
parse(org.fusesource.hawtbuf.DataByteArrayInputStream input,
int readSize) |
public MQTTCodec(MQTTCodec.MQTTFrameSink sink)
public MQTTCodec(MQTTCodec.MQTTFrameSink sink, MQTTWireFormat wireFormat)
public MQTTCodec(TcpTransport transport)
public MQTTCodec(TcpTransport transport, MQTTWireFormat wireFormat)
Copyright © 2005–2018. All rights reserved.