org.apache.activemq.transport.mqtt

Class MQTTProtocolSupport

java.lang.Object

org.apache.activemq.transport.mqtt.MQTTProtocolSupport

public class MQTTProtocolSupport
extends Object

A set of static methods useful for handling MQTT based client connections.

Constructor Summary

Constructors

Constructor and Description
MQTTProtocolSupport()

Method Summary

Modifier and Type	Method and Description
static String	commandType(byte header) Given an MQTT header byte, determine the command type that the header represents.
static String	convertActiveMQToMQTT(String destinationName) Converts an ActiveMQ destination name into a correctly formatted MQTT destination name.
static String	convertMQTTToActiveMQ(String name) Converts an MQTT formatted Topic name into a suitable ActiveMQ Destination name string.

Methods inherited from class java.lang.Object

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

Constructor Detail

MQTTProtocolSupport

public MQTTProtocolSupport()

Method Detail

convertMQTTToActiveMQ

public static String convertMQTTToActiveMQ(String name)

Converts an MQTT formatted Topic name into a suitable ActiveMQ Destination name string.

Parameters:

name - the MQTT formatted topic name.

Returns:

an destination name that fits the ActiveMQ conventions.

convertActiveMQToMQTT

public static String convertActiveMQToMQTT(String destinationName)

Converts an ActiveMQ destination name into a correctly formatted MQTT destination name.

Parameters:

destinationName - the ActiveMQ destination name to process.

Returns:

a destination name formatted for MQTT.

commandType

public static String commandType(byte header)

Given an MQTT header byte, determine the command type that the header represents.

Parameters:

header - the byte value for the MQTT frame header.

Returns:

a string value for the given command type.