程序包 | 说明 |
---|---|
io.netty.handler.codec.mqtt |
Benchmarks for
io.netty.handler.codec.mqtt . |
限定符和类型 | 类和说明 |
---|---|
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
|
限定符和类型 | 字段和说明 |
---|---|
static MqttMessage |
MqttMessage.DISCONNECT |
static MqttMessage |
MqttMessage.PINGREQ |
static MqttMessage |
MqttMessage.PINGRESP |
限定符和类型 | 方法和说明 |
---|---|
MqttMessage |
MqttMessageBuilders.PubAckBuilder.build() |
MqttMessage |
MqttMessageBuilders.DisconnectBuilder.build() |
MqttMessage |
MqttMessageBuilders.AuthBuilder.build() |
static MqttMessage |
MqttMessageFactory.newInvalidMessage(MqttFixedHeader mqttFixedHeader,
java.lang.Object variableHeader,
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) |
限定符和类型 | 方法和说明 |
---|---|
protected void |
MqttEncoder.encode(ChannelHandlerContext ctx,
MqttMessage msg,
java.util.List<java.lang.Object> out) |