| 限定符和类型 | 类和说明 |
|---|---|
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() |
MqttMessage |
MqttDecoder.doDecode(org.tio.core.ChannelContext ctx,
ByteBuffer buffer,
int readableLength) |
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) |
| 限定符和类型 | 方法和说明 |
|---|---|
ByteBuffer |
MqttEncoder.doEncode(org.tio.core.ChannelContext ctx,
MqttMessage message,
ByteBufferAllocator allocator)
This is the main encoding method.
|
Copyright © 2023. All rights reserved.