Package io.netty.handler.codec.mqtt

Class MqttCodecUtil

java.lang.Object

io.netty.handler.codec.mqtt.MqttCodecUtil

final class MqttCodecUtil
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
(package private) static final AttributeKey<MqttVersion>	MQTT_VERSION_KEY
private static final char[]	TOPIC_WILDCARDS

Constructor Summary

Constructors

Modifier	Constructor	Description
private	MqttCodecUtil()

Method Summary

Modifier and Type	Method	Description
(package private) static MqttVersion	getMqttVersion(ChannelHandlerContext ctx)
(package private) static boolean	isValidClientId(MqttVersion mqttVersion, int maxClientIdLength, String clientId)
(package private) static boolean	isValidMessageId(int messageId)
(package private) static boolean	isValidPublishTopicName(String topicName)
(package private) static MqttFixedHeader	resetUnusedFields(MqttFixedHeader mqttFixedHeader)
(package private) static void	setMqttVersion(ChannelHandlerContext ctx, MqttVersion version)
(package private) static MqttFixedHeader	validateFixedHeader(ChannelHandlerContext ctx, MqttFixedHeader mqttFixedHeader)

Methods inherited from class java.lang.Object

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

Field Details

TOPIC_WILDCARDS

private static final char[] TOPIC_WILDCARDS

MQTT_VERSION_KEY

static final AttributeKey<MqttVersion> MQTT_VERSION_KEY

Constructor Details

MqttCodecUtil

private MqttCodecUtil()

Method Details

getMqttVersion

static MqttVersion getMqttVersion(ChannelHandlerContext ctx)

setMqttVersion

static void setMqttVersion(ChannelHandlerContext ctx,
 MqttVersion version)

isValidPublishTopicName

static boolean isValidPublishTopicName(String topicName)

isValidMessageId

static boolean isValidMessageId(int messageId)

isValidClientId

static boolean isValidClientId(MqttVersion mqttVersion,
 int maxClientIdLength,
 String clientId)

validateFixedHeader

static MqttFixedHeader validateFixedHeader(ChannelHandlerContext ctx,
 MqttFixedHeader mqttFixedHeader)

resetUnusedFields

static MqttFixedHeader resetUnusedFields(MqttFixedHeader mqttFixedHeader)