Package | Description |
---|---|
io.netty.handler.codec.mqtt |
Encoder, decoder and different Message Types for MQTT.
|
Modifier and Type | Class and Description |
---|---|
class |
MqttConnAckMessage
See MQTTV3.1/connack
|
class |
MqttConnectMessage
See MQTTV3.1/connect
|
class |
MqttPubAckMessage
See MQTTV3.1/puback
|
class |
MqttPublishMessage
See MQTTV3.1/publish
|
class |
MqttSubAckMessage
See MQTTV3.1/suback
|
class |
MqttSubscribeMessage
|
class |
MqttUnsubAckMessage
|
class |
MqttUnsubscribeMessage
|
Modifier and Type | Method and Description |
---|---|
private MqttMessage |
MqttDecoder.invalidMessage(java.lang.Throwable cause) |
static MqttMessage |
MqttMessageFactory.newInvalidMessage(java.lang.Throwable cause) |
static MqttMessage |
MqttMessageFactory.newMessage(MqttFixedHeader mqttFixedHeader,
java.lang.Object variableHeader,
java.lang.Object payload) |
Modifier and Type | Method and Description |
---|---|
(package private) static ByteBuf |
MqttEncoder.doEncode(ByteBufAllocator byteBufAllocator,
MqttMessage message)
This is the main encoding method.
|
protected void |
MqttEncoder.encode(ChannelHandlerContext ctx,
MqttMessage msg,
java.util.List<java.lang.Object> out) |
private static ByteBuf |
MqttEncoder.encodeMessageWithOnlySingleByteFixedHeader(ByteBufAllocator byteBufAllocator,
MqttMessage message) |
private static ByteBuf |
MqttEncoder.encodeMessageWithOnlySingleByteFixedHeaderAndMessageId(ByteBufAllocator byteBufAllocator,
MqttMessage message) |