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 | Field and Description |
---|---|
static MqttMessage |
MqttMessage.DISCONNECT |
static MqttMessage |
MqttMessage.PINGREQ |
static MqttMessage |
MqttMessage.PINGRESP |
Modifier and Type | Method and Description |
---|---|
MqttMessage |
MqttMessageBuilders.PubAckBuilder.build() |
MqttMessage |
MqttMessageBuilders.DisconnectBuilder.build() |
MqttMessage |
MqttMessageBuilders.AuthBuilder.build() |
static MqttMessage |
MqttMessageFactory.newInvalidMessage(MqttFixedHeader mqttFixedHeader,
Object variableHeader,
Throwable cause) |
static MqttMessage |
MqttMessageFactory.newInvalidMessage(Throwable cause) |
static MqttMessage |
MqttMessageFactory.newMessage(MqttFixedHeader mqttFixedHeader,
Object variableHeader,
Object payload) |
Modifier and Type | Method and Description |
---|---|
protected void |
MqttEncoder.encode(ChannelHandlerContext ctx,
MqttMessage msg,
List<Object> out) |
Copyright © 2008–2024 The Netty Project. All rights reserved.