net.dreamlu.iot.mqtt.codec

类 MqttDecoder

java.lang.Object

net.dreamlu.iot.mqtt.codec.MqttDecoder

public final class MqttDecoder
extends Object

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.

作者:

netty, L.cm

构造器概要

构造器

构造器和说明
MqttDecoder()
MqttDecoder(int maxBytesInMessage)
MqttDecoder(int maxBytesInMessage, int maxClientIdLength)

方法概要

限定符和类型	方法和说明
MqttMessage	doDecode(org.tio.core.ChannelContext ctx, ByteBuffer buffer, int readableLength)

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

MqttDecoder

public MqttDecoder()

MqttDecoder

public MqttDecoder(int maxBytesInMessage)

MqttDecoder

public MqttDecoder(int maxBytesInMessage,
                   int maxClientIdLength)

方法详细资料

doDecode

public MqttMessage doDecode(org.tio.core.ChannelContext ctx,
                            ByteBuffer buffer,
                            int readableLength)
                     throws org.tio.core.exception.TioDecodeException

抛出:

org.tio.core.exception.TioDecodeException