net.dreamlu.iot.mqtt.codec

类 MqttEncoder

java.lang.Object

net.dreamlu.iot.mqtt.codec.MqttEncoder

public final class MqttEncoder
extends Object

Encodes Mqtt messages into bytes following the protocol specification v3.1 as described here MQTTV3.1 or v5.0 as described here MQTTv5.0 - depending on the version specified in the first CONNECT message that goes through the channel.

作者:

netty, L.cm

字段概要

字段

限定符和类型	字段和说明
static MqttEncoder	INSTANCE

方法概要

限定符和类型	方法和说明
ByteBuffer	doEncode(org.tio.core.ChannelContext ctx, MqttMessage message, ByteBufferAllocator allocator) This is the main encoding method.

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

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

字段详细资料

INSTANCE

public static final MqttEncoder INSTANCE

方法详细资料

doEncode

public ByteBuffer doEncode(org.tio.core.ChannelContext ctx,
                           MqttMessage message,
                           ByteBufferAllocator allocator)

This is the main encoding method. It's only visible for testing.

参数:

ctx - ChannelContext

message - MQTT message to encode

allocator - ByteBuffer Allocator

返回:

ByteBuf with encoded bytes