Uses of Class
com.hivemq.spi.annotations.NotNull

Packages that use NotNull

Package	Description
com.hivemq.spi.callback.security.authorization
com.hivemq.spi.callback.webui
com.hivemq.spi.message
com.hivemq.spi.security
com.hivemq.spi.services
com.hivemq.spi.services.configuration.entity
com.hivemq.spi.services.rest
com.hivemq.spi.services.rest.listener
com.hivemq.spi.services.rest.servlet

Uses of NotNull in com.hivemq.spi.callback.security.authorization

Methods in com.hivemq.spi.callback.security.authorization with annotations of type NotNull

Modifier and Type	Method and Description
AuthorizationBehaviour	AuthorizationResult.getDefaultBehaviour() The default AuthorizationBehaviour if the getMqttTopicPermissions() method returns an empty list.

Uses of NotNull in com.hivemq.spi.callback.webui

Methods in com.hivemq.spi.callback.webui with annotations of type NotNull

Modifier and Type	Method and Description
WebUIAuthenticationCallback.AuthenticationState	WebUIAuthenticationCallback.checkCredentials(String username, String password) Checks the credentials for a WebUI login.

Method parameters in com.hivemq.spi.callback.webui with annotations of type NotNull

Modifier and Type	Method and Description
WebUIAuthenticationCallback.AuthenticationState	WebUIAuthenticationCallback.checkCredentials(String username, String password) Checks the credentials for a WebUI login.
WebUIAuthenticationCallback.AuthenticationState	WebUIAuthenticationCallback.checkCredentials(String username, String password) Checks the credentials for a WebUI login.

Uses of NotNull in com.hivemq.spi.message

Methods in com.hivemq.spi.message with annotations of type NotNull

Modifier and Type	Method and Description
String	Topic.getTopic()

Method parameters in com.hivemq.spi.message with annotations of type NotNull

Modifier and Type	Method and Description
static Topic	Topic.topicFromString(String s)

Constructor parameters in com.hivemq.spi.message with annotations of type NotNull

Constructor and Description
Topic(String topic, QoS qoS)

Uses of NotNull in com.hivemq.spi.security

Methods in com.hivemq.spi.security with annotations of type NotNull

Modifier and Type	Method and Description
ConnectionAttributeStore	ClientData.getConnectionAttributeStore() Returns the ConnectionAttributeStore for the connected client.

Uses of NotNull in com.hivemq.spi.services

Methods in com.hivemq.spi.services with annotations of type NotNull

Modifier and Type	Method and Description
com.google.common.util.concurrent.ListenableFuture<Void>	AsyncClientGroupService.addClientToGroup(String group, ClientData clientData) Adds a client to a group.
com.google.common.util.concurrent.ListenableFuture<Void>	AsyncClientGroupService.addClientToGroup(String group, String clientIdentifier) Adds a client to a group.
com.google.common.util.concurrent.ListenableFuture<Void>	AsyncSessionAttributeStore.clear(String clientId) Clears all session attributes for a persistent client.
com.google.common.base.Optional<byte[]>	ConnectionAttributeStore.get(String key) Retrieves the value of the connection attribute with the given key for the connected client.
com.google.common.util.concurrent.ListenableFuture<com.google.common.base.Optional<byte[]>>	AsyncSessionAttributeStore.get(String clientId, String key) Retrieves the value of the session attribute with the given key for a persistent client.
com.google.common.base.Optional<byte[]>	BlockingSessionAttributeStore.get(String clientId, String key) Retrieves the value of the session attribute with the given key for a persistent client.
com.google.common.base.Optional<com.google.common.collect.ImmutableMap<String,byte[]>>	ConnectionAttributeStore.getAll() Retrieves all connection attributes for the connected client.
com.google.common.util.concurrent.ListenableFuture<com.google.common.base.Optional<com.google.common.collect.ImmutableMap<String,byte[]>>>	AsyncSessionAttributeStore.getAll(String clientId) Retrieves all session attributes for a persistent client.
com.google.common.base.Optional<com.google.common.collect.ImmutableMap<String,byte[]>>	BlockingSessionAttributeStore.getAll(String clientId) Retrieves all session attributes for a persistent client.
com.google.common.base.Optional<String>	ConnectionAttributeStore.getAsString(String key) Retrieves the value of the connection attribute with the given key for the connected client as UTF-8 string.
com.google.common.base.Optional<String>	ConnectionAttributeStore.getAsString(String key, Charset charset) Retrieves the value of the connection attribute with the given key for the connected client as string with the given charset.
com.google.common.util.concurrent.ListenableFuture<com.google.common.base.Optional<String>>	AsyncSessionAttributeStore.getAsString(String clientId, String key) Retrieves the value of the session attribute with the given key for a persistent client.
com.google.common.base.Optional<String>	BlockingSessionAttributeStore.getAsString(String clientId, String key) Retrieves the value of the session attribute with the given key for a persistent client.
com.google.common.util.concurrent.ListenableFuture<com.google.common.base.Optional<String>>	AsyncSessionAttributeStore.getAsString(String clientId, String key, Charset charset) Retrieves the value of the session attribute with the given key for a persistent client.
com.google.common.base.Optional<String>	BlockingSessionAttributeStore.getAsString(String clientId, String key, Charset charset) Retrieves the value of the session attribute with the given key for a persistent client.
com.google.common.collect.ImmutableSet<String>	BlockingClientGroupService.getAvailableGroups() Retrieves all available groups.
com.google.common.util.concurrent.ListenableFuture<com.google.common.collect.ImmutableSet<String>>	AsyncClientGroupService.getAvailableGroups() Retrieves all available groups.
com.google.common.collect.ImmutableSet<String>	BlockingClientGroupService.getClientsForGroup(String group) Retrieves the clients for a group.
com.google.common.util.concurrent.ListenableFuture<com.google.common.collect.ImmutableSet<String>>	AsyncClientGroupService.getClientsForGroup(String group) Retrieves the clients for a group.
com.google.common.util.concurrent.ListenableFuture<Void>	AsyncSessionAttributeStore.put(String clientId, String key, byte[] value) Sets the given session attribute for a persistent client.
com.google.common.util.concurrent.ListenableFuture<Void>	AsyncSessionAttributeStore.putAsString(String clientId, String key, String value) Sets the given session attribute for a persistent client.
com.google.common.util.concurrent.ListenableFuture<Void>	AsyncSessionAttributeStore.putAsString(String clientId, String key, String value, Charset charset) Sets the given session attribute for a persistent client.
com.google.common.util.concurrent.ListenableFuture<OptionalAttribute>	AsyncSessionAttributeStore.putIfNewer(String clientId, String key, byte[] value, long timestamp) Sets the given session attribute for a persistent client if the timestamp of the attribute is newer than the timestamp of the already stored attribute.
OptionalAttribute	BlockingSessionAttributeStore.putIfNewer(String clientId, String key, byte[] value, long timestamp) Sets the given session attribute for a persistent client if the timestamp of the attribute is newer than the timestamp of the already stored attribute.
com.google.common.util.concurrent.ListenableFuture<OptionalAttribute>	AsyncSessionAttributeStore.putIfNewerOrEquals(String clientId, String key, byte[] value, long timestamp) Sets the given session attribute for a persistent client if the timestamp of the attribute is newer than or equal to the timestamp of the already stored attribute.
OptionalAttribute	BlockingSessionAttributeStore.putIfNewerOrEquals(String clientId, String key, byte[] value, long timestamp) Sets the given session attribute for a persistent client if the timestamp of the attribute is newer than or equal to the timestamp of the already stored attribute.
com.google.common.base.Optional<byte[]>	ConnectionAttributeStore.remove(String key) Removes the connection attribute with the given key for the connected client.
com.google.common.util.concurrent.ListenableFuture<com.google.common.base.Optional<byte[]>>	AsyncSessionAttributeStore.remove(String clientId, String key) Removes the session attribute with the given key for a persistent client.
com.google.common.base.Optional<byte[]>	BlockingSessionAttributeStore.remove(String clientId, String key) Removes the session attribute with the given key for a persistent client.
com.google.common.util.concurrent.ListenableFuture<Void>	AsyncClientGroupService.removeClientFromGroup(String group, String clientIdentifier) Removes a client from a group.

Method parameters in com.hivemq.spi.services with annotations of type NotNull

Modifier and Type	Method and Description
void	BlockingClientGroupService.addClientToGroup(String group, ClientData clientData) Adds a client to a group.
void	BlockingClientGroupService.addClientToGroup(String group, ClientData clientData) Adds a client to a group.
com.google.common.util.concurrent.ListenableFuture<Void>	AsyncClientGroupService.addClientToGroup(String group, ClientData clientData) Adds a client to a group.
com.google.common.util.concurrent.ListenableFuture<Void>	AsyncClientGroupService.addClientToGroup(String group, ClientData clientData) Adds a client to a group.
void	BlockingClientGroupService.addClientToGroup(String group, String clientIdentifier) Adds a client to a group.
void	BlockingClientGroupService.addClientToGroup(String group, String clientIdentifier) Adds a client to a group.
com.google.common.util.concurrent.ListenableFuture<Void>	AsyncClientGroupService.addClientToGroup(String group, String clientIdentifier) Adds a client to a group.
com.google.common.util.concurrent.ListenableFuture<Void>	AsyncClientGroupService.addClientToGroup(String group, String clientIdentifier) Adds a client to a group.
void	SharedSubscriptionService.addSharedSubscriptions(String... sharedSubscriptions) Deprecated. Since 3.1 Shared subscriptions are created by using a specific marker in the topic. Use BlockingSubscriptionStore or AsyncSubscriptionStore to create such subscriptions. See the HiveMQ documentation about shared subscriptions for more detailed information.
com.google.common.util.concurrent.ListenableFuture<Void>	SubscriptionStore.addSubscription(String clientID, Topic topic) Deprecated. Use BlockingSubscriptionStore or AsyncSubscriptionStore instead.
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.
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.
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.
void	BlockingSubscriptionStore.addSubscriptions(String clientID, Set<Topic> topics) This method adds subscriptions for a certain client to certain topics.
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.
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.
com.google.common.util.concurrent.ListenableFuture<Void>	AsyncSessionAttributeStore.clear(String clientId) Clears all session attributes for a persistent client.
void	BlockingSessionAttributeStore.clear(String clientId) Clears all session attributes for the connected client.
com.google.common.base.Optional<byte[]>	ConnectionAttributeStore.get(String key) Retrieves the value of the connection attribute with the given key for the connected client.
com.google.common.util.concurrent.ListenableFuture<com.google.common.base.Optional<byte[]>>	AsyncSessionAttributeStore.get(String clientId, String key) Retrieves the value of the session attribute with the given key for a persistent client.
com.google.common.util.concurrent.ListenableFuture<com.google.common.base.Optional<byte[]>>	AsyncSessionAttributeStore.get(String clientId, String key) Retrieves the value of the session attribute with the given key for a persistent client.
com.google.common.base.Optional<byte[]>	BlockingSessionAttributeStore.get(String clientId, String key) Retrieves the value of the session attribute with the given key for a persistent client.
com.google.common.base.Optional<byte[]>	BlockingSessionAttributeStore.get(String clientId, String key) Retrieves the value of the session attribute with the given key for a persistent client.
com.google.common.util.concurrent.ListenableFuture<com.google.common.base.Optional<com.google.common.collect.ImmutableMap<String,byte[]>>>	AsyncSessionAttributeStore.getAll(String clientId) Retrieves all session attributes for a persistent client.
com.google.common.base.Optional<com.google.common.collect.ImmutableMap<String,byte[]>>	BlockingSessionAttributeStore.getAll(String clientId) Retrieves all session attributes for a persistent client.
com.google.common.base.Optional<String>	ConnectionAttributeStore.getAsString(String key) Retrieves the value of the connection attribute with the given key for the connected client as UTF-8 string.
com.google.common.base.Optional<String>	ConnectionAttributeStore.getAsString(String key, Charset charset) Retrieves the value of the connection attribute with the given key for the connected client as string with the given charset.
com.google.common.base.Optional<String>	ConnectionAttributeStore.getAsString(String key, Charset charset) Retrieves the value of the connection attribute with the given key for the connected client as string with the given charset.
com.google.common.util.concurrent.ListenableFuture<com.google.common.base.Optional<String>>	AsyncSessionAttributeStore.getAsString(String clientId, String key) Retrieves the value of the session attribute with the given key for a persistent client.
com.google.common.util.concurrent.ListenableFuture<com.google.common.base.Optional<String>>	AsyncSessionAttributeStore.getAsString(String clientId, String key) Retrieves the value of the session attribute with the given key for a persistent client.
com.google.common.base.Optional<String>	BlockingSessionAttributeStore.getAsString(String clientId, String key) Retrieves the value of the session attribute with the given key for a persistent client.
com.google.common.base.Optional<String>	BlockingSessionAttributeStore.getAsString(String clientId, String key) Retrieves the value of the session attribute with the given key for a persistent client.
com.google.common.util.concurrent.ListenableFuture<com.google.common.base.Optional<String>>	AsyncSessionAttributeStore.getAsString(String clientId, String key, Charset charset) Retrieves the value of the session attribute with the given key for a persistent client.
com.google.common.util.concurrent.ListenableFuture<com.google.common.base.Optional<String>>	AsyncSessionAttributeStore.getAsString(String clientId, String key, Charset charset) Retrieves the value of the session attribute with the given key for a persistent client.
com.google.common.util.concurrent.ListenableFuture<com.google.common.base.Optional<String>>	AsyncSessionAttributeStore.getAsString(String clientId, String key, Charset charset) Retrieves the value of the session attribute with the given key for a persistent client.
com.google.common.base.Optional<String>	BlockingSessionAttributeStore.getAsString(String clientId, String key, Charset charset) Retrieves the value of the session attribute with the given key for a persistent client.
com.google.common.base.Optional<String>	BlockingSessionAttributeStore.getAsString(String clientId, String key, Charset charset) Retrieves the value of the session attribute with the given key for a persistent client.
com.google.common.base.Optional<String>	BlockingSessionAttributeStore.getAsString(String clientId, String key, Charset charset) Retrieves the value of the session attribute with the given key for a persistent client.
com.google.common.collect.ImmutableSet<String>	BlockingClientGroupService.getClientsForGroup(String group) Retrieves the clients for a group.
com.google.common.util.concurrent.ListenableFuture<com.google.common.collect.ImmutableSet<String>>	AsyncClientGroupService.getClientsForGroup(String group) Retrieves the clients for a group.
Set<String>	SubscriptionStore.getLocalSubscribers(String topic) Deprecated. Use BlockingSubscriptionStore or AsyncSubscriptionStore instead.
Set<String>	BlockingSubscriptionStore.getLocalSubscribers(String topic) Returns all MQTT client subscriber identifiers for a given topic, for this HiveMQ instance.
com.google.common.util.concurrent.ListenableFuture<Set<String>>	AsyncSubscriptionStore.getLocalSubscribers(String topic) Returns all MQTT client subscriber identifiers for a given topic, for this HiveMQ instance.
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<Set<String>>	SubscriptionStore.getSubscribers(String topic) Deprecated. Use BlockingSubscriptionStore or AsyncSubscriptionStore instead.
Set<String>	BlockingSubscriptionStore.getSubscribers(String topic) Returns all MQTT client subscriber identifiers for a given topic, this HiveMQ instance and all other nodes in a HiveMQ cluster.
com.google.common.util.concurrent.ListenableFuture<Set<String>>	AsyncSubscriptionStore.getSubscribers(String topic) Returns all MQTT client subscriber identifiers for a given topic, this HiveMQ instance and all other nodes in a HiveMQ cluster.
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.
com.google.common.util.concurrent.ListenableFuture<Integer>	AsyncClientService.getTTL(String clientId) Returns the time to live for a client session in seconds.
int	BlockingClientService.getTTL(String clientId) Returns the time to live for a client session in seconds.
com.google.common.util.concurrent.ListenableFuture<Boolean>	AsyncClientService.invalidateSession(String clientId) Invalidates the client session for a client with the given client identifier.
void	BlockingClientService.invalidateSession(String clientId) Invalidates the client session for the client with the given client identifier.
void	PublishService.publish(PUBLISH publish) Publishes a new MQTT PUBLISH message.
void	PublishService.publishtoClient(PUBLISH publish, String clientId) Publishes a new MQTT PUBLISH message.
void	PublishService.publishtoClient(PUBLISH publish, String clientId) Publishes a new MQTT PUBLISH message.
void	ConnectionAttributeStore.put(String key, byte[] value) Sets the given connection attribute for the connected client.
void	ConnectionAttributeStore.put(String key, byte[] value) Sets the given connection attribute for the connected client.
com.google.common.util.concurrent.ListenableFuture<Void>	AsyncSessionAttributeStore.put(String clientId, String key, byte[] value) Sets the given session attribute for a persistent client.
com.google.common.util.concurrent.ListenableFuture<Void>	AsyncSessionAttributeStore.put(String clientId, String key, byte[] value) Sets the given session attribute for a persistent client.
com.google.common.util.concurrent.ListenableFuture<Void>	AsyncSessionAttributeStore.put(String clientId, String key, byte[] value) Sets the given session attribute for a persistent client.
void	BlockingSessionAttributeStore.put(String clientId, String key, byte[] value) Sets the given session attribute for a persistent client.
void	BlockingSessionAttributeStore.put(String clientId, String key, byte[] value) Sets the given session attribute for a persistent client.
void	BlockingSessionAttributeStore.put(String clientId, String key, byte[] value) Sets the given session attribute for a persistent client.
void	ConnectionAttributeStore.putAsString(String key, String value) Sets the given connection attribute as UTF-8 String representation for the connected client.
void	ConnectionAttributeStore.putAsString(String key, String value) Sets the given connection attribute as UTF-8 String representation for the connected client.
void	ConnectionAttributeStore.putAsString(String key, String value, Charset charset) Sets the given connection attribute as String representation for the connected client with a given charset.
void	ConnectionAttributeStore.putAsString(String key, String value, Charset charset) Sets the given connection attribute as String representation for the connected client with a given charset.
void	ConnectionAttributeStore.putAsString(String key, String value, Charset charset) Sets the given connection attribute as String representation for the connected client with a given charset.
com.google.common.util.concurrent.ListenableFuture<Void>	AsyncSessionAttributeStore.putAsString(String clientId, String key, String value) Sets the given session attribute for a persistent client.
com.google.common.util.concurrent.ListenableFuture<Void>	AsyncSessionAttributeStore.putAsString(String clientId, String key, String value) Sets the given session attribute for a persistent client.
com.google.common.util.concurrent.ListenableFuture<Void>	AsyncSessionAttributeStore.putAsString(String clientId, String key, String value) Sets the given session attribute for a persistent client.
void	BlockingSessionAttributeStore.putAsString(String clientId, String key, String value) Sets the given session attribute for a persistent client.
void	BlockingSessionAttributeStore.putAsString(String clientId, String key, String value) Sets the given session attribute for a persistent client.
void	BlockingSessionAttributeStore.putAsString(String clientId, String key, String value) Sets the given session attribute for a persistent client.
com.google.common.util.concurrent.ListenableFuture<Void>	AsyncSessionAttributeStore.putAsString(String clientId, String key, String value, Charset charset) Sets the given session attribute for a persistent client.
com.google.common.util.concurrent.ListenableFuture<Void>	AsyncSessionAttributeStore.putAsString(String clientId, String key, String value, Charset charset) Sets the given session attribute for a persistent client.
com.google.common.util.concurrent.ListenableFuture<Void>	AsyncSessionAttributeStore.putAsString(String clientId, String key, String value, Charset charset) Sets the given session attribute for a persistent client.
com.google.common.util.concurrent.ListenableFuture<Void>	AsyncSessionAttributeStore.putAsString(String clientId, String key, String value, Charset charset) Sets the given session attribute for a persistent client.
void	BlockingSessionAttributeStore.putAsString(String clientId, String key, String value, Charset charset) Sets the given session attribute for a persistent client.
void	BlockingSessionAttributeStore.putAsString(String clientId, String key, String value, Charset charset) Sets the given session attribute for a persistent client.
void	BlockingSessionAttributeStore.putAsString(String clientId, String key, String value, Charset charset) Sets the given session attribute for a persistent client.
void	BlockingSessionAttributeStore.putAsString(String clientId, String key, String value, Charset charset) Sets the given session attribute for a persistent client.
com.google.common.util.concurrent.ListenableFuture<OptionalAttribute>	AsyncSessionAttributeStore.putIfNewer(String clientId, String key, byte[] value, long timestamp) Sets the given session attribute for a persistent client if the timestamp of the attribute is newer than the timestamp of the already stored attribute.
com.google.common.util.concurrent.ListenableFuture<OptionalAttribute>	AsyncSessionAttributeStore.putIfNewer(String clientId, String key, byte[] value, long timestamp) Sets the given session attribute for a persistent client if the timestamp of the attribute is newer than the timestamp of the already stored attribute.
com.google.common.util.concurrent.ListenableFuture<OptionalAttribute>	AsyncSessionAttributeStore.putIfNewer(String clientId, String key, byte[] value, long timestamp) Sets the given session attribute for a persistent client if the timestamp of the attribute is newer than the timestamp of the already stored attribute.
OptionalAttribute	BlockingSessionAttributeStore.putIfNewer(String clientId, String key, byte[] value, long timestamp) Sets the given session attribute for a persistent client if the timestamp of the attribute is newer than the timestamp of the already stored attribute.
OptionalAttribute	BlockingSessionAttributeStore.putIfNewer(String clientId, String key, byte[] value, long timestamp) Sets the given session attribute for a persistent client if the timestamp of the attribute is newer than the timestamp of the already stored attribute.
OptionalAttribute	BlockingSessionAttributeStore.putIfNewer(String clientId, String key, byte[] value, long timestamp) Sets the given session attribute for a persistent client if the timestamp of the attribute is newer than the timestamp of the already stored attribute.
com.google.common.util.concurrent.ListenableFuture<OptionalAttribute>	AsyncSessionAttributeStore.putIfNewerOrEquals(String clientId, String key, byte[] value, long timestamp) Sets the given session attribute for a persistent client if the timestamp of the attribute is newer than or equal to the timestamp of the already stored attribute.
com.google.common.util.concurrent.ListenableFuture<OptionalAttribute>	AsyncSessionAttributeStore.putIfNewerOrEquals(String clientId, String key, byte[] value, long timestamp) Sets the given session attribute for a persistent client if the timestamp of the attribute is newer than or equal to the timestamp of the already stored attribute.
com.google.common.util.concurrent.ListenableFuture<OptionalAttribute>	AsyncSessionAttributeStore.putIfNewerOrEquals(String clientId, String key, byte[] value, long timestamp) Sets the given session attribute for a persistent client if the timestamp of the attribute is newer than or equal to the timestamp of the already stored attribute.
OptionalAttribute	BlockingSessionAttributeStore.putIfNewerOrEquals(String clientId, String key, byte[] value, long timestamp) Sets the given session attribute for a persistent client if the timestamp of the attribute is newer than or equal to the timestamp of the already stored attribute.
OptionalAttribute	BlockingSessionAttributeStore.putIfNewerOrEquals(String clientId, String key, byte[] value, long timestamp) Sets the given session attribute for a persistent client if the timestamp of the attribute is newer than or equal to the timestamp of the already stored attribute.
OptionalAttribute	BlockingSessionAttributeStore.putIfNewerOrEquals(String clientId, String key, byte[] value, long timestamp) Sets the given session attribute for a persistent client if the timestamp of the attribute is newer than or equal to the timestamp of the already stored attribute.
com.google.common.base.Optional<byte[]>	ConnectionAttributeStore.remove(String key) Removes the connection attribute with the given key for the connected client.
com.google.common.util.concurrent.ListenableFuture<com.google.common.base.Optional<byte[]>>	AsyncSessionAttributeStore.remove(String clientId, String key) Removes the session attribute with the given key for a persistent client.
com.google.common.util.concurrent.ListenableFuture<com.google.common.base.Optional<byte[]>>	AsyncSessionAttributeStore.remove(String clientId, String key) Removes the session attribute with the given key for a persistent client.
com.google.common.base.Optional<byte[]>	BlockingSessionAttributeStore.remove(String clientId, String key) Removes the session attribute with the given key for a persistent client.
com.google.common.base.Optional<byte[]>	BlockingSessionAttributeStore.remove(String clientId, String key) Removes the session attribute with the given key for a persistent client.
void	BlockingClientGroupService.removeClientFromGroup(String group, String clientIdentifier) Removes a client from a group.
void	BlockingClientGroupService.removeClientFromGroup(String group, String clientIdentifier) Removes a client from a group.
com.google.common.util.concurrent.ListenableFuture<Void>	AsyncClientGroupService.removeClientFromGroup(String group, String clientIdentifier) Removes a client from a group.
com.google.common.util.concurrent.ListenableFuture<Void>	AsyncClientGroupService.removeClientFromGroup(String group, String clientIdentifier) Removes a client from a group.
void	SharedSubscriptionService.removeSharedSubscription(String sharedSubscription) Deprecated. Since 3.1 Shared subscriptions are created by using a specific marker in the topic. Use BlockingSubscriptionStore or AsyncSubscriptionStore to create such subscriptions. See the HiveMQ documentation about shared subscriptions for more detailed information.
com.google.common.util.concurrent.ListenableFuture<Void>	SubscriptionStore.removeSubscription(String clientID, String topic) Deprecated. Use BlockingSubscriptionStore or AsyncSubscriptionStore instead.
com.google.common.util.concurrent.ListenableFuture<Void>	SubscriptionStore.removeSubscription(String clientID, String topic) Deprecated. Use BlockingSubscriptionStore or AsyncSubscriptionStore instead.
void	BlockingSubscriptionStore.removeSubscription(String clientID, String topic) This method removes a subscription for a certain client and a certain topic.
void	BlockingSubscriptionStore.removeSubscription(String clientID, String topic) This method removes a subscription for a certain client and a certain topic.
com.google.common.util.concurrent.ListenableFuture<Void>	AsyncSubscriptionStore.removeSubscription(String clientID, String topic) This method removes a subscription for a certain client and a certain topic.
com.google.common.util.concurrent.ListenableFuture<Void>	AsyncSubscriptionStore.removeSubscription(String clientID, String topic) This method removes a subscription for a certain client and a certain topic.
void	BlockingSubscriptionStore.removeSubscriptions(String clientID, Set<String> topics) This method removes subscriptions for a certain client and certain topics.
void	BlockingSubscriptionStore.removeSubscriptions(String clientID, Set<String> topics) This method removes subscriptions for a certain client and certain topics.
com.google.common.util.concurrent.ListenableFuture<Void>	AsyncSubscriptionStore.removeSubscriptions(String clientID, Set<String> topics) This method removes subscriptions for a certain client and certain topics.
com.google.common.util.concurrent.ListenableFuture<Void>	AsyncSubscriptionStore.removeSubscriptions(String clientID, Set<String> topics) This method removes subscriptions for a certain client and certain topics.
void	LogService.setLogLevel(LogService.LogLevel logLevel) Changes the log level of the internal HiveMQ logger This does not support null parameters.
com.google.common.util.concurrent.ListenableFuture<Void>	AsyncClientService.setTTL(String clientId, int ttl) Sets the time to live for a client session in seconds.
void	BlockingClientService.setTTL(String clientId, int ttl) Sets the time to live for the client session.

Uses of NotNull in com.hivemq.spi.services.configuration.entity

Methods in com.hivemq.spi.services.configuration.entity with annotations of type NotNull

Modifier and Type	Method and Description
com.google.common.base.Optional<Integer>	SocketOptionsProperties.getReceiveBufferSize() Get the receive buffer size.
com.google.common.base.Optional<Integer>	SocketOptionsProperties.getSendBufferSize() Get the send buffer size.

Constructor parameters in com.hivemq.spi.services.configuration.entity with annotations of type NotNull

Constructor and Description
TcpListener(int port, String bindAddress) Creates a new TCP listener which listens to a specific port and bind address
TcpListener(int port, String bindAddress, boolean proxyProtocolSupported) Creates a new TCP listener which listens to a specific port, bind address and proxy setting
TcpListener(int port, String bindAddress, boolean proxyProtocolSupported, SocketOptionsProperties socketOptionsProperties, ConnectOverloadProtectionProperties connectOverloadProtectionProperties, ClientWriteBufferProperties clientWriteBufferProperties) Creates a new TCP listener which listens to a specific port, bind address, proxy setting, socket options, overload protection and write buffer properties
Tls(String keystorePath, String keystorePassword, String keystoreType, String privateKeyPassword, String truststorePath, String truststorePassword, String truststoreType, int handshakeTimeout, Tls.ClientAuthMode clientAuthMode, List<String> protocols, List<String> cipherSuites) Creates a new TLS configuration
Tls(String keystorePath, String keystorePassword, String keystoreType, String privateKeyPassword, String truststorePath, String truststorePassword, String truststoreType, int handshakeTimeout, Tls.ClientAuthMode clientAuthMode, List<String> protocols, List<String> cipherSuites) Creates a new TLS configuration
Tls(String keystorePath, String keystorePassword, String keystoreType, String privateKeyPassword, String truststorePath, String truststorePassword, String truststoreType, int handshakeTimeout, Tls.ClientAuthMode clientAuthMode, List<String> protocols, List<String> cipherSuites) Creates a new TLS configuration
Tls(String keystorePath, String keystorePassword, String keystoreType, String privateKeyPassword, String truststorePath, String truststorePassword, String truststoreType, int handshakeTimeout, Tls.ClientAuthMode clientAuthMode, List<String> protocols, List<String> cipherSuites) Creates a new TLS configuration
Tls(String keystorePath, String keystorePassword, String keystoreType, String privateKeyPassword, String truststorePath, String truststorePassword, String truststoreType, int handshakeTimeout, Tls.ClientAuthMode clientAuthMode, List<String> protocols, List<String> cipherSuites) Creates a new TLS configuration
Tls(String keystorePath, String keystorePassword, String keystoreType, String privateKeyPassword, String truststorePath, String truststorePassword, String truststoreType, int handshakeTimeout, Tls.ClientAuthMode clientAuthMode, List<String> protocols, List<String> cipherSuites, Long concurrentHandshakeLimit, boolean nativeSSl, boolean ocspStaplingEnabled, String ocspOverrideUrl, int ocspCacheInterval) Creates a new TLS configuration
Tls(String keystorePath, String keystorePassword, String keystoreType, String privateKeyPassword, String truststorePath, String truststorePassword, String truststoreType, int handshakeTimeout, Tls.ClientAuthMode clientAuthMode, List<String> protocols, List<String> cipherSuites, Long concurrentHandshakeLimit, boolean nativeSSl, boolean ocspStaplingEnabled, String ocspOverrideUrl, int ocspCacheInterval) Creates a new TLS configuration
Tls(String keystorePath, String keystorePassword, String keystoreType, String privateKeyPassword, String truststorePath, String truststorePassword, String truststoreType, int handshakeTimeout, Tls.ClientAuthMode clientAuthMode, List<String> protocols, List<String> cipherSuites, Long concurrentHandshakeLimit, boolean nativeSSl, boolean ocspStaplingEnabled, String ocspOverrideUrl, int ocspCacheInterval) Creates a new TLS configuration
Tls(String keystorePath, String keystorePassword, String keystoreType, String privateKeyPassword, String truststorePath, String truststorePassword, String truststoreType, int handshakeTimeout, Tls.ClientAuthMode clientAuthMode, List<String> protocols, List<String> cipherSuites, Long concurrentHandshakeLimit, boolean nativeSSl, boolean ocspStaplingEnabled, String ocspOverrideUrl, int ocspCacheInterval) Creates a new TLS configuration
Tls(String keystorePath, String keystorePassword, String keystoreType, String privateKeyPassword, String truststorePath, String truststorePassword, String truststoreType, int handshakeTimeout, Tls.ClientAuthMode clientAuthMode, List<String> protocols, List<String> cipherSuites, Long concurrentHandshakeLimit, boolean nativeSSl, boolean ocspStaplingEnabled, String ocspOverrideUrl, int ocspCacheInterval) Creates a new TLS configuration
Tls(String keystorePath, String keystorePassword, String keystoreType, String privateKeyPassword, String truststorePath, String truststorePassword, String truststoreType, int handshakeTimeout, Tls.ClientAuthMode clientAuthMode, List<String> protocols, List<String> cipherSuites, Long concurrentHandshakeLimit, boolean nativeSSl, boolean ocspStaplingEnabled, String ocspOverrideUrl, int ocspCacheInterval) Creates a new TLS configuration
Tls(String keystorePath, String keystorePassword, String keystoreType, String privateKeyPassword, String truststorePath, String truststorePassword, String truststoreType, int handshakeTimeout, Tls.ClientAuthMode clientAuthMode, List<String> protocols, List<String> cipherSuites, Long concurrentHandshakeLimit, boolean nativeSSl, boolean ocspStaplingEnabled, String ocspOverrideUrl, int ocspCacheInterval) Creates a new TLS configuration

Uses of NotNull in com.hivemq.spi.services.rest

Method parameters in com.hivemq.spi.services.rest with annotations of type NotNull

Modifier and Type	Method and Description
void	RESTService.addContextResolver(Class<? extends javax.ws.rs.ext.ContextResolver> contextResolver) Adds an ContextResolver to all available listeners.
void	RESTService.addContextResolver(Class<? extends javax.ws.rs.ext.ContextResolver> contextResolver, Collection<String> listenerIdentifier) Adds an ContextResolver to all specified listeners.
void	RESTService.addContextResolver(Class<? extends javax.ws.rs.ext.ContextResolver> contextResolver, Collection<String> listenerIdentifier) Adds an ContextResolver to all specified listeners.
void	RESTService.addExceptionMapper(Class<? extends javax.ws.rs.ext.ExceptionMapper<? extends Throwable>> exceptionMapper) Adds an ExceptionMapper to all available listeners.
void	RESTService.addExceptionMapper(Class<? extends javax.ws.rs.ext.ExceptionMapper<? extends Throwable>> exceptionMapper, Collection<String> listenerIdentifier) Adds an ExceptionMapper to all specified listeners.
void	RESTService.addExceptionMapper(Class<? extends javax.ws.rs.ext.ExceptionMapper<? extends Throwable>> exceptionMapper, Collection<String> listenerIdentifier) Adds an ExceptionMapper to all specified listeners.
void	RESTService.addExceptionMapper(javax.ws.rs.ext.ExceptionMapper<? extends Throwable> exceptionMapper) Adds an ExceptionMapper to all available listeners.
void	RESTService.addExceptionMapper(javax.ws.rs.ext.ExceptionMapper<? extends Throwable> exceptionMapper, Collection<String> listenerIdentifier) Adds an ExceptionMapper to all specified listeners.
void	RESTService.addExceptionMapper(javax.ws.rs.ext.ExceptionMapper<? extends Throwable> exceptionMapper, Collection<String> listenerIdentifier) Adds an ExceptionMapper to all specified listeners.
<T extends javax.servlet.Filter> T	RESTService.addFilter(ServletFilter<T> filter, String path) Adds a specific ServletFilter with a given path to the RESTService on all available listeners.
<T extends javax.servlet.Filter> T	RESTService.addFilter(ServletFilter<T> filter, String path) Adds a specific ServletFilter with a given path to the RESTService on all available listeners.
<T extends javax.servlet.Filter> T	RESTService.addFilter(ServletFilter<T> filter, String path, Collection<String> listeners) Adds a specific ServletFilter with a given path to the RESTService on specific listeners.
<T extends javax.servlet.Filter> T	RESTService.addFilter(ServletFilter<T> filter, String path, Collection<String> listeners) Adds a specific ServletFilter with a given path to the RESTService on specific listeners.
<T extends javax.servlet.Filter> T	RESTService.addFilter(ServletFilter<T> filter, String path, Collection<String> listeners) Adds a specific ServletFilter with a given path to the RESTService on specific listeners.
void	RESTService.addJaxRsApplication(javax.ws.rs.core.Application application) Adds a Application to the RESTService.
void	RESTService.addJaxRsApplication(javax.ws.rs.core.Application application, Collection<String> listenerIdentifiers) Adds a Application to the RESTService.
void	RESTService.addJaxRsApplication(javax.ws.rs.core.Application application, Collection<String> listenerIdentifiers) Adds a Application to the RESTService.
void	RESTService.addJaxRsResources(Class<?>... resources) Adds an arbitrary number of JAX-RS resources to all available listeners.
void	RESTService.addJaxRsResources(Collection<Class<?>> resources, Collection<String> listenerIdentifiers) Adds an arbitrary number of JAX-RS resources to all specified listeners.
void	RESTService.addJaxRsResources(Collection<Class<?>> resources, Collection<String> listenerIdentifiers) Adds an arbitrary number of JAX-RS resources to all specified listeners.
void	RESTService.addJaxRsSingletons(Collection<Object> singletons, Collection<String> listenerIdentifiers) Adds all given JAX-RS resources as singleton to all specified listeners.
void	RESTService.addJaxRsSingletons(Collection<Object> singletons, Collection<String> listenerIdentifiers) Adds all given JAX-RS resources as singleton to all specified listeners.
void	RESTService.addJaxRsSingletons(Object... singletons) Adds all given JAX-RS resources as singleton to all available listeners.
void	RESTService.addListener(Listener listener) Adds a new listener to the REST Service programmatically.
void	RESTService.addMessageBodyReader(Class<? extends javax.ws.rs.ext.MessageBodyReader> messageBodyReader) Adds a MessageBodyReader to all listeners.
void	RESTService.addMessageBodyReader(Class<? extends javax.ws.rs.ext.MessageBodyReader> messageBodyReader, Collection<String> listenerIdentifier) Adds a MessageBodyReader to all specified listeners.
void	RESTService.addMessageBodyReader(Class<? extends javax.ws.rs.ext.MessageBodyReader> messageBodyReader, Collection<String> listenerIdentifier) Adds a MessageBodyReader to all specified listeners.
void	RESTService.addMessageBodyWriter(Class<? extends javax.ws.rs.ext.MessageBodyWriter> messageBodyWriter) Adds a MessageBodyWriter to all listeners.
void	RESTService.addMessageBodyWriter(Class<? extends javax.ws.rs.ext.MessageBodyWriter> messageBodyWriter, Collection<String> listenerIdentifier) Adds a MessageBodyWriter to all specified listeners.
void	RESTService.addMessageBodyWriter(Class<? extends javax.ws.rs.ext.MessageBodyWriter> messageBodyWriter, Collection<String> listenerIdentifier) Adds a MessageBodyWriter to all specified listeners.
<T extends javax.servlet.http.HttpServlet> T	RESTService.addServlet(Class<T> servlet, String path) Adds a servlet to a specific path and adds the servlet to all available listeners.
<T extends javax.servlet.http.HttpServlet> T	RESTService.addServlet(Class<T> servlet, String path) Adds a servlet to a specific path and adds the servlet to all available listeners.
<T extends javax.servlet.http.HttpServlet> T	RESTService.addServlet(Class<T> servlet, String path, Collection<String> listenerIdentifiers) Adds a servlet to a specific path and adds the servlet to all specified listeners.
<T extends javax.servlet.http.HttpServlet> T	RESTService.addServlet(Class<T> servlet, String path, Collection<String> listenerIdentifiers) Adds a servlet to a specific path and adds the servlet to all specified listeners.
<T extends javax.servlet.http.HttpServlet> T	RESTService.addServlet(Class<T> servlet, String path, Collection<String> listenerIdentifiers) Adds a servlet to a specific path and adds the servlet to all specified listeners.
void	RESTService.addServlet(javax.servlet.http.HttpServlet servlet, String path) Adds a servlet instance to a specific path and adds the servlet to all available listeners.
void	RESTService.addServlet(javax.servlet.http.HttpServlet servlet, String path) Adds a servlet instance to a specific path and adds the servlet to all available listeners.
void	RESTService.addServlet(javax.servlet.http.HttpServlet servlet, String path, Collection<String> listenerIdentifiers) Adds a servlet instance to a specific path and adds the servlet to all specified listeners.
void	RESTService.addServlet(javax.servlet.http.HttpServlet servlet, String path, Collection<String> listenerIdentifiers) Adds a servlet instance to a specific path and adds the servlet to all specified listeners.
void	RESTService.addServlet(javax.servlet.http.HttpServlet servlet, String path, Collection<String> listenerIdentifiers) Adds a servlet instance to a specific path and adds the servlet to all specified listeners.
<T extends javax.servlet.http.HttpServlet> T	RESTService.addServletWithFilters(Class<T> servlet, String path, Collection<String> listenerIdentifiers, ServletFilter<? extends javax.servlet.Filter>... filters) Adds a servlet to a specific path and adds the servlet to all specified listeners.
<T extends javax.servlet.http.HttpServlet> T	RESTService.addServletWithFilters(Class<T> servlet, String path, Collection<String> listenerIdentifiers, ServletFilter<? extends javax.servlet.Filter>... filters) Adds a servlet to a specific path and adds the servlet to all specified listeners.
<T extends javax.servlet.http.HttpServlet> T	RESTService.addServletWithFilters(Class<T> servlet, String path, Collection<String> listenerIdentifiers, ServletFilter<? extends javax.servlet.Filter>... filters) Adds a servlet to a specific path and adds the servlet to all specified listeners.
<T extends javax.servlet.http.HttpServlet> T	RESTService.addServletWithFilters(Class<T> servlet, String path, Collection<String> listenerIdentifiers, ServletFilter<? extends javax.servlet.Filter>... filters) Adds a servlet to a specific path and adds the servlet to all specified listeners.
<T extends javax.servlet.http.HttpServlet> T	RESTService.addServletWithFilters(Class<T> servlet, String path, ServletFilter<? extends javax.servlet.Filter>... filters) Adds a servlet to a specific path and adds the servlet to all available listeners.
<T extends javax.servlet.http.HttpServlet> T	RESTService.addServletWithFilters(Class<T> servlet, String path, ServletFilter<? extends javax.servlet.Filter>... filters) Adds a servlet to a specific path and adds the servlet to all available listeners.
<T extends javax.servlet.http.HttpServlet> T	RESTService.addServletWithFilters(Class<T> servlet, String path, ServletFilter<? extends javax.servlet.Filter>... filters) Adds a servlet to a specific path and adds the servlet to all available listeners.
void	RESTService.addServletWithFilters(javax.servlet.http.HttpServlet servlet, String path, Collection<String> listenerIdentifiers, ServletFilter<? extends javax.servlet.Filter>... filters) Adds a servlet instance to a specific path and adds the servlet to all specific listeners.
void	RESTService.addServletWithFilters(javax.servlet.http.HttpServlet servlet, String path, Collection<String> listenerIdentifiers, ServletFilter<? extends javax.servlet.Filter>... filters) Adds a servlet instance to a specific path and adds the servlet to all specific listeners.
void	RESTService.addServletWithFilters(javax.servlet.http.HttpServlet servlet, String path, Collection<String> listenerIdentifiers, ServletFilter<? extends javax.servlet.Filter>... filters) Adds a servlet instance to a specific path and adds the servlet to all specific listeners.
void	RESTService.addServletWithFilters(javax.servlet.http.HttpServlet servlet, String path, Collection<String> listenerIdentifiers, ServletFilter<? extends javax.servlet.Filter>... filters) Adds a servlet instance to a specific path and adds the servlet to all specific listeners.
void	RESTService.addServletWithFilters(javax.servlet.http.HttpServlet servlet, String path, ServletFilter<? extends javax.servlet.Filter>... filters) Adds a servlet instance to a specific path and adds the servlet to all available listeners.
void	RESTService.addServletWithFilters(javax.servlet.http.HttpServlet servlet, String path, ServletFilter<? extends javax.servlet.Filter>... filters) Adds a servlet instance to a specific path and adds the servlet to all available listeners.
void	RESTService.addServletWithFilters(javax.servlet.http.HttpServlet servlet, String path, ServletFilter<? extends javax.servlet.Filter>... filters) Adds a servlet instance to a specific path and adds the servlet to all available listeners.

Uses of NotNull in com.hivemq.spi.services.rest.listener

Constructor parameters in com.hivemq.spi.services.rest.listener with annotations of type NotNull

Constructor and Description
HttpListener(String name, String bindAddress, int port) Creates a new HTTP listener.
HttpListener(String name, String bindAddress, int port) Creates a new HTTP listener.

Uses of NotNull in com.hivemq.spi.services.rest.servlet

Constructor parameters in com.hivemq.spi.services.rest.servlet with annotations of type NotNull

Constructor and Description
ServletFilter(Class<T> filterClass, javax.servlet.DispatcherType... dispatcherTypes) Creates a new wrapper for a Servlet Filter class and its corresponding dispatcher types.
ServletFilter(Class<T> filterClass, javax.servlet.DispatcherType... dispatcherTypes) Creates a new wrapper for a Servlet Filter class and its corresponding dispatcher types.
ServletFilter(T filter, javax.servlet.DispatcherType... dispatcherTypes) Creates a new wrapper for a concrete Servlet Filter object and its corresponding dispatcher types.
ServletFilter(T filter, javax.servlet.DispatcherType... dispatcherTypes) Creates a new wrapper for a concrete Servlet Filter object and its corresponding dispatcher types.