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 |
---|---|
void |
MQTTProtocolConverter.onUnSubscribe(org.fusesource.mqtt.codec.UNSUBSCRIBE command) |
static void |
MQTTProtocolSupport.validate(String topicName)
Validate that the Topic names given by client commands are valid
based on the MQTT protocol specification.
|
Modifier and Type | Method and Description |
---|---|
protected byte |
AbstractMQTTSubscriptionStrategy.doSubscribe(ConsumerInfo consumerInfo,
String topicName,
org.fusesource.mqtt.client.QoS qoS) |
void |
AbstractMQTTSubscriptionStrategy.initialize(MQTTProtocolConverter protocol) |
void |
MQTTSubscriptionStrategy.initialize(MQTTProtocolConverter protocol)
Initialize the strategy before first use.
|
protected List<SubscriptionInfo> |
AbstractMQTTSubscriptionStrategy.lookupSubscription(String clientId) |
void |
MQTTVirtualTopicSubscriptionStrategy.onConnect(org.fusesource.mqtt.codec.CONNECT connect) |
void |
MQTTDefaultSubscriptionStrategy.onConnect(org.fusesource.mqtt.codec.CONNECT connect) |
void |
MQTTSubscriptionStrategy.onConnect(org.fusesource.mqtt.codec.CONNECT connect)
Allows the strategy to perform any needed actions on client connect
prior to the CONNACK frame being sent back such as recovering old
subscriptions and performing any clean session actions.
|
void |
MQTTVirtualTopicSubscriptionStrategy.onReSubscribe(MQTTSubscription mqttSubscription) |
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.
|
byte |
MQTTVirtualTopicSubscriptionStrategy.onSubscribe(String topicName,
org.fusesource.mqtt.client.QoS requestedQoS) |
byte |
MQTTDefaultSubscriptionStrategy.onSubscribe(String topicName,
org.fusesource.mqtt.client.QoS requestedQoS) |
byte |
MQTTSubscriptionStrategy.onSubscribe(String topicName,
org.fusesource.mqtt.client.QoS requestedQoS)
Called when a new Subscription is being requested.
|
byte |
AbstractMQTTSubscriptionStrategy.onSubscribe(org.fusesource.mqtt.client.Topic topic) |
byte |
MQTTSubscriptionStrategy.onSubscribe(org.fusesource.mqtt.client.Topic topic)
Called for each Topic that a client requests to subscribe to.
|
void |
MQTTVirtualTopicSubscriptionStrategy.onUnSubscribe(String topicName) |
void |
MQTTDefaultSubscriptionStrategy.onUnSubscribe(String topicName) |
void |
MQTTSubscriptionStrategy.onUnSubscribe(String topicName)
Called when a client requests an un-subscribe a previous subscription.
|
Copyright © 2005–2016 The Apache Software Foundation. All rights reserved.