Uses of Class
io.netty.handler.codec.mqtt.MqttMessage
-
Packages that use MqttMessage Package Description io.netty.handler.codec.mqtt Encoder, decoder and different Message Types for MQTT. -
-
Uses of MqttMessage in io.netty.handler.codec.mqtt
Subclasses of MqttMessage in io.netty.handler.codec.mqtt Modifier and Type Class Description class
MqttConnAckMessage
See MQTTV3.1/connackclass
MqttConnectMessage
See MQTTV3.1/connectclass
MqttPubAckMessage
See MQTTV3.1/pubackclass
MqttPublishMessage
See MQTTV3.1/publishclass
MqttSubAckMessage
See MQTTV3.1/subackclass
MqttSubscribeMessage
class
MqttUnsubAckMessage
class
MqttUnsubscribeMessage
Fields in io.netty.handler.codec.mqtt declared as MqttMessage Modifier and Type Field Description static MqttMessage
MqttMessage. DISCONNECT
static MqttMessage
MqttMessage. PINGREQ
static MqttMessage
MqttMessage. PINGRESP
Methods in io.netty.handler.codec.mqtt that return MqttMessage Modifier and Type Method Description MqttMessage
MqttMessageBuilders.AuthBuilder. build()
MqttMessage
MqttMessageBuilders.DisconnectBuilder. build()
MqttMessage
MqttMessageBuilders.PubAckBuilder. build()
private MqttMessage
MqttDecoder. invalidMessage(java.lang.Throwable cause)
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)
Methods in io.netty.handler.codec.mqtt with parameters of type MqttMessage Modifier and Type Method Description (package private) static ByteBuf
MqttEncoder. doEncode(ChannelHandlerContext ctx, 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)
private static ByteBuf
MqttEncoder. encodePubReplyMessage(ChannelHandlerContext ctx, MqttMessage message)
private static ByteBuf
MqttEncoder. encodeReasonCodePlusPropertiesMessage(ChannelHandlerContext ctx, MqttMessage message)
-