org.apache.activemq.transport.mqtt

Class MQTTProtocolConverter

java.lang.Object

org.apache.activemq.transport.mqtt.MQTTProtocolConverter

public class MQTTProtocolConverter
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
MQTTProtocolConverter(MQTTTransport mqttTransport, BrokerService brokerService)

Method Summary

Methods

Modifier and Type	Method and Description
org.fusesource.mqtt.codec.PUBLISH	convertMessage(ActiveMQMessage message)
void	deleteDurableSubs(java.util.List<SubscriptionInfo> subs)
int	getActiveMQSubscriptionPrefetch()
long	getDefaultKeepAlive()
MQTTTransport	getMQTTTransport()
MQTTPacketIdGenerator	getPacketIdGenerator()
void	onActiveMQCommand(Command command) Dispatch a ActiveMQ command
void	onMQTTCommand(org.fusesource.mqtt.codec.MQTTFrame frame) Convert a MQTT command
void	onTransportError()
void	restoreDurableSubs(java.util.List<SubscriptionInfo> subs)
void	setActiveMQSubscriptionPrefetch(int activeMQSubscriptionPrefetch) set the default prefetch size when mapping the MQTT subscription to an ActiveMQ one The default = 1
void	setDefaultKeepAlive(long keepAlive) Set the default keep alive time (in milliseconds) that would be used if configured on server side and the client sends a keep-alive value of 0 (zero) on a CONNECT frame

Methods inherited from class java.lang.Object

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

Constructor Detail

MQTTProtocolConverter

public MQTTProtocolConverter(MQTTTransport mqttTransport,
                     BrokerService brokerService)

Method Detail

onMQTTCommand

public void onMQTTCommand(org.fusesource.mqtt.codec.MQTTFrame frame)
                   throws java.io.IOException,
                          javax.jms.JMSException

Convert a MQTT command

Throws:

java.io.IOException

javax.jms.JMSException

deleteDurableSubs

public void deleteDurableSubs(java.util.List<SubscriptionInfo> subs)

restoreDurableSubs

public void restoreDurableSubs(java.util.List<SubscriptionInfo> subs)

onActiveMQCommand

public void onActiveMQCommand(Command command)
                       throws java.lang.Exception

Dispatch a ActiveMQ command

Throws:

java.lang.Exception

convertMessage

public org.fusesource.mqtt.codec.PUBLISH convertMessage(ActiveMQMessage message)
                                                 throws java.io.IOException,
                                                        javax.jms.JMSException,
                                                        java.util.zip.DataFormatException

Throws:

java.io.IOException

javax.jms.JMSException

java.util.zip.DataFormatException

getMQTTTransport

public MQTTTransport getMQTTTransport()

onTransportError

public void onTransportError()

getDefaultKeepAlive

public long getDefaultKeepAlive()

setDefaultKeepAlive

public void setDefaultKeepAlive(long keepAlive)

Set the default keep alive time (in milliseconds) that would be used if configured on server side and the client sends a keep-alive value of 0 (zero) on a CONNECT frame

Parameters:

keepAlive - the keepAlive in milliseconds

getActiveMQSubscriptionPrefetch

public int getActiveMQSubscriptionPrefetch()

setActiveMQSubscriptionPrefetch

public void setActiveMQSubscriptionPrefetch(int activeMQSubscriptionPrefetch)

set the default prefetch size when mapping the MQTT subscription to an ActiveMQ one The default = 1

Parameters:

activeMQSubscriptionPrefetch - set the prefetch for the corresponding ActiveMQ subscription

getPacketIdGenerator

public MQTTPacketIdGenerator getPacketIdGenerator()