org.apache.activemq.artemis.core.protocol.mqtt

Class MQTTUtil

java.lang.Object

org.apache.activemq.artemis.core.protocol.mqtt.MQTTUtil

public class MQTTUtil
extends Object

A Utility Class for creating Server Side objects and converting MQTT concepts to/from Artemis.

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_KEEP_ALIVE_FREQUENCY
static int	DEFAULT_SERVER_MESSAGE_BUFFER_SIZE
static boolean	DURABLE_MESSAGES
static int	MAX_MESSAGE_SIZE
static String	MQTT_MESSAGE_ID_KEY
static String	MQTT_MESSAGE_RETAIN_KEY
static String	MQTT_MESSAGE_TYPE_KEY
static String	MQTT_QOS_LEVEL_KEY
static String	MQTT_RETAIN_ADDRESS_PREFIX
static boolean	SESSION_AUTO_COMMIT_ACKS
static boolean	SESSION_AUTO_COMMIT_SENDS
static boolean	SESSION_AUTO_CREATE_QUEUE
static boolean	SESSION_PREACKNOWLEDGE
static boolean	SESSION_XA

Constructor Summary

Constructors

Constructor and Description
MQTTUtil()

Method Summary

Modifier and Type	Method and Description
static String	convertCoreAddressFilterToMQTT(String filter)
static String	convertMQTTAddressFilterToCore(String filter)
static String	convertMQTTAddressFilterToCoreRetain(String filter)
static ServerMessage	createPubRelMessage(MQTTSession session, org.apache.activemq.artemis.api.core.SimpleString address, int messageId)
static ServerMessage	createServerMessageFromByteBuf(MQTTSession session, String topic, boolean retain, int qos, io.netty.buffer.ByteBuf payload)
static ServerMessage	createServerMessageFromString(MQTTSession session, String payload, String topic, int qos, boolean retain)
static void	logMessage(MQTTSessionState state, io.netty.handler.codec.mqtt.MqttMessage message, boolean inbound)
static String	swapMQTTAndCoreWildCards(String filter)

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_SERVER_MESSAGE_BUFFER_SIZE

public static final int DEFAULT_SERVER_MESSAGE_BUFFER_SIZE

See Also:

Constant Field Values

DURABLE_MESSAGES

public static final boolean DURABLE_MESSAGES

See Also:

Constant Field Values

SESSION_AUTO_COMMIT_SENDS

public static final boolean SESSION_AUTO_COMMIT_SENDS

See Also:

Constant Field Values

SESSION_AUTO_COMMIT_ACKS

public static final boolean SESSION_AUTO_COMMIT_ACKS

See Also:

Constant Field Values

SESSION_PREACKNOWLEDGE

public static final boolean SESSION_PREACKNOWLEDGE

See Also:

Constant Field Values

SESSION_XA

public static final boolean SESSION_XA

See Also:

Constant Field Values

SESSION_AUTO_CREATE_QUEUE

public static final boolean SESSION_AUTO_CREATE_QUEUE

See Also:

Constant Field Values

MAX_MESSAGE_SIZE

public static final int MAX_MESSAGE_SIZE

See Also:

Constant Field Values

MQTT_RETAIN_ADDRESS_PREFIX

public static final String MQTT_RETAIN_ADDRESS_PREFIX

See Also:

Constant Field Values

MQTT_QOS_LEVEL_KEY

public static final String MQTT_QOS_LEVEL_KEY

See Also:

Constant Field Values

MQTT_MESSAGE_ID_KEY

public static final String MQTT_MESSAGE_ID_KEY

See Also:

Constant Field Values

MQTT_MESSAGE_TYPE_KEY

public static final String MQTT_MESSAGE_TYPE_KEY

See Also:

Constant Field Values

MQTT_MESSAGE_RETAIN_KEY

public static final String MQTT_MESSAGE_RETAIN_KEY

See Also:

Constant Field Values

DEFAULT_KEEP_ALIVE_FREQUENCY

public static final int DEFAULT_KEEP_ALIVE_FREQUENCY

See Also:

Constant Field Values

Constructor Detail

MQTTUtil

public MQTTUtil()

Method Detail

convertMQTTAddressFilterToCore

public static String convertMQTTAddressFilterToCore(String filter)

convertCoreAddressFilterToMQTT

public static String convertCoreAddressFilterToMQTT(String filter)

convertMQTTAddressFilterToCoreRetain

public static String convertMQTTAddressFilterToCoreRetain(String filter)

swapMQTTAndCoreWildCards

public static String swapMQTTAndCoreWildCards(String filter)

createServerMessageFromByteBuf

public static ServerMessage createServerMessageFromByteBuf(MQTTSession session,
                                                           String topic,
                                                           boolean retain,
                                                           int qos,
                                                           io.netty.buffer.ByteBuf payload)

createServerMessageFromString

public static ServerMessage createServerMessageFromString(MQTTSession session,
                                                          String payload,
                                                          String topic,
                                                          int qos,
                                                          boolean retain)

createPubRelMessage

public static ServerMessage createPubRelMessage(MQTTSession session,
                                                org.apache.activemq.artemis.api.core.SimpleString address,
                                                int messageId)

logMessage

public static void logMessage(MQTTSessionState state,
                              io.netty.handler.codec.mqtt.MqttMessage message,
                              boolean inbound)