public class MQTTProtocolSupport extends Object
Constructor and Description |
---|
MQTTProtocolSupport() |
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.
|
static void |
validate(String topicName)
Validate that the Topic names given by client commands are valid
based on the MQTT protocol specification.
|
public MQTTProtocolSupport()
public static String convertMQTTToActiveMQ(String name)
name
- the MQTT formatted topic name.public static String convertActiveMQToMQTT(String destinationName)
destinationName
- the ActiveMQ destination name to process.public static String commandType(byte header)
header
- the byte value for the MQTT frame header.public static void validate(String topicName) throws MQTTProtocolException
topicName
- the given Topic name provided by the client.MQTTProtocolException
- if the value given is invalid.Copyright © 2005–2017. All rights reserved.