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.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.
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.
Configuration for the MQTT client.
Configuration for the MQTT client.
An exception thrown while publishing to MQTT topics.
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 Mqtt Client.A
HealthIndicator
for Mqtt Client.The MQTT v3 implementation of
AbstractMqttIntroductionAdvice
.The MQTT v5 implementation of
AbstractMqttIntroductionAdvice
.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
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 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 v5 messages.
A binder responsible for binding to the payload of the message.
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.
Argument binder based on the type of the argument.