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 |
Modifier and Type | Method and Description |
---|---|
short |
MQTTPacketIdGenerator.setPacketId(String clientId,
MQTTSubscription subscription,
ActiveMQMessage message,
org.fusesource.mqtt.codec.PUBLISH publish) |
Modifier and Type | Field and Description |
---|---|
protected ConcurrentMap<String,MQTTSubscription> |
AbstractMQTTSubscriptionStrategy.mqttSubscriptionByTopic |
protected ConcurrentMap<ConsumerId,MQTTSubscription> |
AbstractMQTTSubscriptionStrategy.subscriptionsByConsumerId |
Modifier and Type | Method and Description |
---|---|
MQTTSubscription |
MQTTSubscriptionStrategy.getSubscription(ConsumerId consumer)
Lookup an
MQTTSubscription instance based on known ConsumerId value. |
MQTTSubscription |
AbstractMQTTSubscriptionStrategy.getSubscription(ConsumerId consumerId) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractMQTTSubscriptionStrategy.doUnSubscribe(MQTTSubscription subscription) |
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 |
AbstractMQTTSubscriptionStrategy.onReSubscribe(MQTTSubscription mqttSubscription) |
void |
MQTTVirtualTopicSubscriptionStrategy.onReSubscribe(MQTTSubscription mqttSubscription) |
void |
MQTTDefaultSubscriptionStrategy.onReSubscribe(MQTTSubscription mqttSubscription) |
Copyright © 2005–2017 The Apache Software Foundation. All rights reserved.