All Classes and Interfaces
Class
Description
Intercepts calls to MQTT clients to publish messages.
An
ExecutableMethodProcessor
that will process all beans annotated
with MqttSubscriber
and create and subscribe the relevant methods
as consumers to MQTT topics.A typed binder for
Acknowledgement
that allows subscribers to manually
acknowledge messages.An
MqttBinder
that binds based on the presence of an annotation on the argument.Reader for X.509 certificates.
The
FallbackMqttBinder
to bind arguments that don't match any
annotated or typed based binder.A default implementation of
MqttBinderRegistry
that searches
for binders based on argument annotations, then based on the argument
type.Default implementation of
MqttPayloadSerDesRegistry
.The exception handler for subscriber exceptions that is used if the subscriber
does not implement
MqttSubscriberExceptionHandler
.A binder to use when no other binders match the argument.
Used to bind the message ID to a parameter.
An annotated argument binder for
Id
.Serializes and deserializes standard Java types.
Serializes and deserializes objects as JSON using Jackson.
Thrown when an a
KeyManagerFactory
can not be created.Adapter class for MQTT 3 HiveMQ async client.
MQTT v3 Client Configuration.
A factory to create an MQTT v3 client.
The MQTT v3 implementation of
AbstractMqttIntroductionAdvice
.Adapter class for MQTT 3 HiveMQ async client.
MQTT v5 Client Configuration.
A factory to create an MQTT v5 client.
The MQTT v5 implementation of
AbstractMqttIntroductionAdvice
.Argument binder to bind publisher and subscriber method arguments
to and from the message context.
A registry of binders for binding to and from MQTT messages.
A generic context for binding to MQTT messages.
MQTT client SSL configuration.
Common interface for HiveMQ MQTT clients.
MQTT Client Configuration.
Configuration for the MQTT client.
Configuration for the MQTT client.
An exception thrown while publishing to MQTT topics.
Common interface for MQTT client factories.
A factory to create an MQTT client.
A factory to create an MQTT client.
MQTT related configuration.
ConfigurationProperties
implementation for MqttConfiguration
.Configures a
ScheduledExecutorService
for running instances.A
HealthIndicator
for HiveMQ MQTT Client.A
HealthIndicator
for Mqtt Client.A
HealthIndicator
for Mqtt Client.The MQTT v3 implementation of
AbstractMqttIntroductionAdvice
.The MQTT v5 implementation of
AbstractMqttIntroductionAdvice
.A MQTT message holds the payload and options
for message delivery.
Responsible for serializing and deserializing MQTT message payloads.
A registry of
MqttPayloadSerDes
instances.Used for binding arguments to mqtt properties.
Used for binding arguments to mqtt properties.
Binds arguments to and from
MqttMessage
.Binds arguments to and from
MqttProperties
.An introduction advice that automatically implements interfaces and abstract classes and publishes Mqtt messages.
An introduction advice that automatically implements interfaces and abstract classes and publishes Mqtt messages.
Generic interface for manipulating SSL based properties
in MQTT configuration.
Class level annotation to indicate that a bean will be consumers of messages
from Mqtt.
The HiveMQ implementation of
AbstractMqttSubscriberAdvice
.The MQTT v3 implementation of
AbstractMqttSubscriberAdvice
.The MQTT v5 implementation of
AbstractMqttSubscriberAdvice
.An exception thrown while subscribing to MQTT topics.
Responsible for handling exceptions thrown during the subscription process.
A binding context for MQTT v3 messages.
A binding context for MQTT v3 messages.
A binding context for MQTT v5 messages.
A binding context for MQTT v5 messages.
A binder responsible for binding to the payload of the message.
Reader for reading PKCS #1 and PKCS #8 private keys from PEM files.
Used for binding the message Qos.
An annotated argument binder for
Qos
.Used for binding the message retained parameter.
An annotated argument binder for
Retained
.Used for binding the message topic and other parameters.
An annotated argument binder for
Topic
.Used to supply multiple topics on subscriber methods.
Thrown when a
TrustManagerFactory
can not be created.Argument binder based on the type of the argument.
Represents a MQTT v5 property.