Class MqttDecoder

All Implemented Interfaces:
ChannelHandler, ChannelInboundHandler

public final class MqttDecoder extends ReplayingDecoder<MqttDecoder.DecoderState>
Decodes Mqtt messages from bytes, following the MQTT protocol specification v3.1 or v5.0, depending on the version specified in the CONNECT message that first goes through the channel.