All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type |
Method and Description |
(package private) static ByteBuf |
doEncode(ByteBufAllocator byteBufAllocator,
MqttMessage message)
This is the main encoding method.
|
protected void |
encode(ChannelHandlerContext ctx,
MqttMessage msg,
java.util.List<java.lang.Object> out)
Encode from one message to an other.
|
private static ByteBuf |
encodeConnAckMessage(ByteBufAllocator byteBufAllocator,
MqttConnAckMessage message) |
private static ByteBuf |
encodeConnectMessage(ByteBufAllocator byteBufAllocator,
MqttConnectMessage message) |
private static ByteBuf |
encodeMessageWithOnlySingleByteFixedHeader(ByteBufAllocator byteBufAllocator,
MqttMessage message) |
private static ByteBuf |
encodeMessageWithOnlySingleByteFixedHeaderAndMessageId(ByteBufAllocator byteBufAllocator,
MqttMessage message) |
private static ByteBuf |
encodePublishMessage(ByteBufAllocator byteBufAllocator,
MqttPublishMessage message) |
private static byte[] |
encodeStringUtf8(java.lang.String s) |
private static ByteBuf |
encodeSubAckMessage(ByteBufAllocator byteBufAllocator,
MqttSubAckMessage message) |
private static ByteBuf |
encodeSubscribeMessage(ByteBufAllocator byteBufAllocator,
MqttSubscribeMessage message) |
private static ByteBuf |
encodeUnsubscribeMessage(ByteBufAllocator byteBufAllocator,
MqttUnsubscribeMessage message) |
private static int |
getConnVariableHeaderFlag(MqttConnectVariableHeader variableHeader) |
private static int |
getFixedHeaderByte1(MqttFixedHeader header) |
private static int |
getVariableLengthInt(int num) |
private static void |
writeVariableLengthInt(ByteBuf buf,
int num) |