Uses of Class
org.apache.activemq.transport.mqtt.MQTTSubscription

Packages that use MQTTSubscription

Package	Description
org.apache.activemq.transport.mqtt	A Broker side implementation of the MQTT 3.1 protocol - see http://mqtt.org/
org.apache.activemq.transport.mqtt.strategy

Uses of MQTTSubscription in org.apache.activemq.transport.mqtt

Methods in org.apache.activemq.transport.mqtt with parameters of type MQTTSubscription

Modifier and Type	Method	Description
short	MQTTPacketIdGenerator.setPacketId(String clientId, MQTTSubscription subscription, ActiveMQMessage message, org.fusesource.mqtt.codec.PUBLISH publish)

Uses of MQTTSubscription in org.apache.activemq.transport.mqtt.strategy

Fields in org.apache.activemq.transport.mqtt.strategy with type parameters of type MQTTSubscription

Modifier and Type	Field	Description
protected ConcurrentMap<String,MQTTSubscription>	AbstractMQTTSubscriptionStrategy.mqttSubscriptionByTopic
protected ConcurrentMap<ConsumerId,MQTTSubscription>	AbstractMQTTSubscriptionStrategy.subscriptionsByConsumerId

Methods in org.apache.activemq.transport.mqtt.strategy that return MQTTSubscription

Modifier and Type	Method	Description
MQTTSubscription	AbstractMQTTSubscriptionStrategy.getSubscription(ConsumerId consumerId)
MQTTSubscription	MQTTSubscriptionStrategy.getSubscription(ConsumerId consumer)	Lookup an MQTTSubscription instance based on known ConsumerId value.

Methods in org.apache.activemq.transport.mqtt.strategy with parameters of type MQTTSubscription

Modifier and Type	Method	Description
void	AbstractMQTTSubscriptionStrategy.doUnSubscribe(MQTTSubscription subscription)
void	AbstractMQTTSubscriptionStrategy.onReSubscribe(MQTTSubscription mqttSubscription)
void	MQTTDefaultSubscriptionStrategy.onReSubscribe(MQTTSubscription mqttSubscription)
void	MQTTSubscriptionStrategy.onReSubscribe(MQTTSubscription subscription)	Called when a client sends a duplicate subscribe request which should force any retained messages on that topic to be replayed again as though the client had just subscribed for the first time.
void	MQTTVirtualTopicSubscriptionStrategy.onReSubscribe(MQTTSubscription mqttSubscription)