| Package | Description |
|---|---|
| com.hivemq.spi.callback.events | |
| com.hivemq.spi.message | |
| com.hivemq.spi.services |
| Modifier and Type | Method and Description |
|---|---|
SubackReturnCode |
OnTopicSubscriptionCallback.getSubackReturnCodeForClient(Topic topic,
SubackReturnCode authorizationResult,
ClientData clientData)
|
| Modifier and Type | Method and Description |
|---|---|
static Topic |
Topic.topicFromString(String s) |
| Modifier and Type | Method and Description |
|---|---|
List<Topic> |
SUBSCRIBE.getTopics() |
| Modifier and Type | Method and Description |
|---|---|
int |
Topic.compareTo(Topic o) |
| Modifier and Type | Method and Description |
|---|---|
void |
SUBSCRIBE.setTopics(List<Topic> topics) |
| Modifier and Type | Method and Description |
|---|---|
com.google.common.collect.Multimap<String,Topic> |
SubscriptionStore.getLocalSubscriptions()
Deprecated.
Use
BlockingSubscriptionStore or AsyncSubscriptionStore instead. |
com.google.common.collect.Multimap<String,Topic> |
BlockingSubscriptionStore.getLocalSubscriptions()
This method returns all subscriptions on this HiveMQ Node as a
Multimap of client identifiers and topics. |
com.google.common.util.concurrent.ListenableFuture<com.google.common.collect.Multimap<String,Topic>> |
AsyncSubscriptionStore.getLocalSubscriptions()
This method returns all subscriptions on this HiveMQ Node as a
Multimap of client identifiers and topics. |
Set<Topic> |
SubscriptionStore.getLocalTopics(String clientID)
Deprecated.
Use
BlockingSubscriptionStore or AsyncSubscriptionStore instead. |
Set<Topic> |
BlockingSubscriptionStore.getLocalTopics(String clientID)
Returns all topics a client is subscribed to, on this HiveMQ instance.
|
com.google.common.util.concurrent.ListenableFuture<Set<Topic>> |
AsyncSubscriptionStore.getLocalTopics(String clientID)
Returns all topics a client is subscribed to, on this HiveMQ instance.
|
com.google.common.util.concurrent.ListenableFuture<com.google.common.collect.Multimap<String,Topic>> |
SubscriptionStore.getSubscriptions()
Deprecated.
Use
BlockingSubscriptionStore or AsyncSubscriptionStore instead. |
com.google.common.collect.Multimap<String,Topic> |
BlockingSubscriptionStore.getSubscriptions()
This method returns all subscriptions this HiveMQ instance and all other nodes in a HiveMQ cluster,
as a
Multimap of client identifiers and topics. |
com.google.common.util.concurrent.ListenableFuture<com.google.common.collect.Multimap<String,Topic>> |
AsyncSubscriptionStore.getSubscriptions()
This method returns all subscriptions this HiveMQ instance and all other nodes in a HiveMQ cluster,
as a
Multimap of client identifiers and topics. |
com.google.common.util.concurrent.ListenableFuture<Set<Topic>> |
SubscriptionStore.getTopics(String clientID)
Deprecated.
Use
BlockingSubscriptionStore or AsyncSubscriptionStore instead. |
Set<Topic> |
BlockingSubscriptionStore.getTopics(String clientID)
Returns all topics a client is subscribed to, on this HiveMQ instance and all other nodes in a HiveMQ cluster.
|
com.google.common.util.concurrent.ListenableFuture<Set<Topic>> |
AsyncSubscriptionStore.getTopics(String clientID)
Returns all topics a client is subscribed to, on this HiveMQ instance and all other nodes in a HiveMQ cluster.
|
| Modifier and Type | Method and Description |
|---|---|
com.google.common.util.concurrent.ListenableFuture<Void> |
SubscriptionStore.addSubscription(String clientID,
Topic topic)
Deprecated.
Use
BlockingSubscriptionStore or AsyncSubscriptionStore instead. |
void |
BlockingSubscriptionStore.addSubscription(String clientID,
Topic topic)
This method adds a subscription for a certain client to a certain topic.
|
com.google.common.util.concurrent.ListenableFuture<Void> |
AsyncSubscriptionStore.addSubscription(String clientID,
Topic topic)
This method adds a subscription for a certain client to a certain topic.
|
| Modifier and Type | Method and Description |
|---|---|
void |
BlockingSubscriptionStore.addSubscriptions(String clientID,
Set<Topic> topics)
This method adds subscriptions for a certain client to certain topics.
|
com.google.common.util.concurrent.ListenableFuture<Void> |
AsyncSubscriptionStore.addSubscriptions(String clientID,
Set<Topic> topics)
This method adds subscriptions for a certain client to certain topics.
|
Copyright © 2013-2018 dc-square GmbH. All Rights Reserved.