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
final class	MqttConnAckMessage	See MQTTV3.1/connack
final class	MqttConnectMessage	See MQTTV3.1/connect
final class	MqttPubAckMessage	See MQTTV3.1/puback
class	MqttPublishMessage	See MQTTV3.1/publish
final class	MqttSubAckMessage	See MQTTV3.1/suback
final class	MqttSubscribeMessage	See MQTTV3.1/subscribe
final class	MqttUnsubAckMessage	See MQTTV3.1/unsuback
final class	MqttUnsubscribeMessage	See MQTTV3.1/unsubscribe

Fields in io.netty.handler.codec.mqtt declared as MqttMessage

Modifier and Type	Field	Description
static final MqttMessage	MqttMessage.DISCONNECT
static final MqttMessage	MqttMessage.PINGREQ
static final 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(Throwable cause)
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)

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, List<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)