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 |
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.onConnect(org.fusesource.mqtt.codec.CONNECT connect) |
|
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) |
|
byte |
AbstractMQTTSubscriptionStrategy.onSubscribe(org.fusesource.mqtt.client.Topic topic) |
|
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 |
MQTTSubscriptionStrategy.onSubscribe(org.fusesource.mqtt.client.Topic topic) |
Called for each Topic that a client requests to subscribe to.
|
byte |
MQTTVirtualTopicSubscriptionStrategy.onSubscribe(String topicName,
org.fusesource.mqtt.client.QoS requestedQoS) |
|
void |
MQTTDefaultSubscriptionStrategy.onUnSubscribe(String topicName) |
|
void |
MQTTSubscriptionStrategy.onUnSubscribe(String topicName) |
Called when a client requests an un-subscribe a previous subscription.
|
void |
MQTTVirtualTopicSubscriptionStrategy.onUnSubscribe(String topicName) |
|