Class MQTTCodec
- java.lang.Object
-
- org.apache.activemq.transport.mqtt.MQTTCodec
-
public class MQTTCodec extends Object
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static interface
MQTTCodec.MQTTFrameSink
Sink for newly decoded MQTT Frames.
-
Constructor Summary
Constructors Constructor Description MQTTCodec(MQTTCodec.MQTTFrameSink sink)
MQTTCodec(MQTTCodec.MQTTFrameSink sink, MQTTWireFormat wireFormat)
MQTTCodec(TcpTransport transport)
MQTTCodec(TcpTransport transport, MQTTWireFormat wireFormat)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
parse(org.fusesource.hawtbuf.DataByteArrayInputStream input, int readSize)
-
-
-
Constructor Detail
-
MQTTCodec
public MQTTCodec(MQTTCodec.MQTTFrameSink sink)
-
MQTTCodec
public MQTTCodec(MQTTCodec.MQTTFrameSink sink, MQTTWireFormat wireFormat)
-
MQTTCodec
public MQTTCodec(TcpTransport transport)
-
MQTTCodec
public MQTTCodec(TcpTransport transport, MQTTWireFormat wireFormat)
-
-