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 |
MQTTSubscriptionStrategy.initialize(MQTTProtocolConverter protocol)
Initialize the strategy before first use.
|
void |
AbstractMQTTSubscriptionStrategy.initialize(MQTTProtocolConverter protocol) |
protected List<SubscriptionInfo> |
AbstractMQTTSubscriptionStrategy.lookupSubscription(String clientId) |
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.onConnect(org.fusesource.mqtt.codec.CONNECT connect) |
void |
MQTTDefaultSubscriptionStrategy.onConnect(org.fusesource.mqtt.codec.CONNECT connect) |
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) |
byte |
MQTTSubscriptionStrategy.onSubscribe(String topicName,
org.fusesource.mqtt.client.QoS requestedQoS)
Called when a new Subscription is being requested.
|
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(org.fusesource.mqtt.client.Topic topic)
Called for each Topic that a client requests to subscribe to.
|
byte |
AbstractMQTTSubscriptionStrategy.onSubscribe(org.fusesource.mqtt.client.Topic topic) |
void |
MQTTSubscriptionStrategy.onUnSubscribe(String topicName)
Called when a client requests an un-subscribe a previous subscription.
|
void |
MQTTVirtualTopicSubscriptionStrategy.onUnSubscribe(String topicName) |
void |
MQTTDefaultSubscriptionStrategy.onUnSubscribe(String topicName) |
Copyright © 2005–2024 The Apache Software Foundation. All rights reserved.