Index
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form
A
- AbstractMqttIntroductionAdvice<L,
M> - Class in io.micronaut.mqtt.intercept -
Intercepts calls to MQTT clients to publish messages.
- AbstractMqttIntroductionAdvice(MqttBinderRegistry) - Constructor for class io.micronaut.mqtt.intercept.AbstractMqttIntroductionAdvice
- AbstractMqttSubscriberAdvice<M> - Class in io.micronaut.mqtt.intercept
-
An
ExecutableMethodProcessor
that will process all beans annotated withMqttSubscriber
and create and subscribe the relevant methods as consumers to MQTT topics. - AbstractMqttSubscriberAdvice(BeanContext, MqttBinderRegistry, MqttSubscriberExceptionHandler) - Constructor for class io.micronaut.mqtt.intercept.AbstractMqttSubscriberAdvice
- AcknowledgeMqttBinder - Class in io.micronaut.mqtt.bind.impl
-
A typed binder for
Acknowledgement
that allows subscribers to manually acknowledge messages. - AcknowledgeMqttBinder() - Constructor for class io.micronaut.mqtt.bind.impl.AcknowledgeMqttBinder
- acknowlege() - Method in interface io.micronaut.mqtt.bind.MqttBindingContext
-
Acknowledges a message.
- acknowlege() - Method in class io.micronaut.mqtt.hivemq.v3.bind.MqttV3BindingContext
- acknowlege() - Method in class io.micronaut.mqtt.hivemq.v5.bind.MqttV5BindingContext
- acknowlege() - Method in class io.micronaut.mqtt.v3.bind.MqttV3BindingContext
- acknowlege() - Method in class io.micronaut.mqtt.v5.bind.MqttV5BindingContext
- AnnotatedMqttBinder<M,
T extends Annotation> - Interface in io.micronaut.mqtt.bind -
An
MqttBinder
that binds based on the presence of an annotation on the argument.
B
- bindFrom(MqttBindingContext<?>, ArgumentConversionContext<Acknowledgement>) - Method in class io.micronaut.mqtt.bind.impl.AcknowledgeMqttBinder
- bindFrom(MqttBindingContext<?>, ArgumentConversionContext<Object>) - Method in class io.micronaut.mqtt.bind.impl.DefaultMqttBinder
- bindFrom(MqttBindingContext<?>, ArgumentConversionContext<Object>) - Method in class io.micronaut.mqtt.bind.impl.IdMqttBinder
- bindFrom(MqttBindingContext<?>, ArgumentConversionContext<Object>) - Method in class io.micronaut.mqtt.bind.impl.PayloadMqttBinder
- bindFrom(MqttBindingContext<?>, ArgumentConversionContext<Object>) - Method in class io.micronaut.mqtt.bind.impl.QosMqttBinder
- bindFrom(MqttBindingContext<?>, ArgumentConversionContext<Object>) - Method in class io.micronaut.mqtt.bind.impl.RetainedMqttBinder
- bindFrom(MqttBindingContext<?>, ArgumentConversionContext<Object>) - Method in class io.micronaut.mqtt.bind.impl.TopicMqttBinder
- bindFrom(MqttV5BindingContext, ArgumentConversionContext<Object>) - Method in class io.micronaut.mqtt.hivemq.v5.bind.MqttPropertyBinder
- bindFrom(MqttV5BindingContext, ArgumentConversionContext<Object>) - Method in class io.micronaut.mqtt.v5.bind.MqttPropertyBinder
- bindFrom(M, ArgumentConversionContext<T>) - Method in interface io.micronaut.mqtt.bind.MqttBinder
-
Binds the given context and returns an optional value.
- bindTo(MqttBindingContext<?>, Acknowledgement, Argument<Acknowledgement>) - Method in class io.micronaut.mqtt.bind.impl.AcknowledgeMqttBinder
- bindTo(MqttBindingContext<?>, Object, Argument<Object>) - Method in class io.micronaut.mqtt.bind.impl.DefaultMqttBinder
- bindTo(MqttBindingContext<?>, Object, Argument<Object>) - Method in class io.micronaut.mqtt.bind.impl.IdMqttBinder
- bindTo(MqttBindingContext<?>, Object, Argument<Object>) - Method in class io.micronaut.mqtt.bind.impl.PayloadMqttBinder
- bindTo(MqttBindingContext<?>, Object, Argument<Object>) - Method in class io.micronaut.mqtt.bind.impl.QosMqttBinder
- bindTo(MqttBindingContext<?>, Object, Argument<Object>) - Method in class io.micronaut.mqtt.bind.impl.RetainedMqttBinder
- bindTo(MqttBindingContext<?>, Object, Argument<Object>) - Method in class io.micronaut.mqtt.bind.impl.TopicMqttBinder
- bindTo(MqttV5BindingContext, Object, Argument<Object>) - Method in class io.micronaut.mqtt.hivemq.v5.bind.MqttPropertyBinder
- bindTo(MqttV5BindingContext, Object, Argument<Object>) - Method in class io.micronaut.mqtt.v5.bind.MqttPropertyBinder
- bindTo(M, T, Argument<T>) - Method in interface io.micronaut.mqtt.bind.MqttBinder
-
Binds the given value to the given context.
C
- CertificateReader - Class in io.micronaut.mqtt.hivemq.ssl
-
Reader for X.509 certificates.
- close() - Method in class io.micronaut.mqtt.intercept.AbstractMqttSubscriberAdvice
- createBindingContext(MethodInvocationContext<Object, Object>) - Method in class io.micronaut.mqtt.hivemq.v3.intercept.Mqtt3IntroductionAdvice
- createBindingContext(MethodInvocationContext<Object, Object>) - Method in class io.micronaut.mqtt.hivemq.v5.intercept.Mqtt5IntroductionAdvice
- createBindingContext(MethodInvocationContext<Object, Object>) - Method in class io.micronaut.mqtt.intercept.AbstractMqttIntroductionAdvice
- createBindingContext(MethodInvocationContext<Object, Object>) - Method in class io.micronaut.mqtt.v3.intercept.MqttIntroductionAdvice
- createBindingContext(MethodInvocationContext<Object, Object>) - Method in class io.micronaut.mqtt.v5.intercept.MqttIntroductionAdvice
- createListener(Runnable, Consumer<Throwable>) - Method in class io.micronaut.mqtt.hivemq.v3.intercept.Mqtt3IntroductionAdvice
- createListener(Runnable, Consumer<Throwable>) - Method in class io.micronaut.mqtt.hivemq.v5.intercept.Mqtt5IntroductionAdvice
- createListener(Runnable, Consumer<Throwable>) - Method in class io.micronaut.mqtt.intercept.AbstractMqttIntroductionAdvice
-
Create a listener.
- createListener(Runnable, Consumer<Throwable>) - Method in class io.micronaut.mqtt.v3.intercept.MqttIntroductionAdvice
- createListener(Runnable, Consumer<Throwable>) - Method in class io.micronaut.mqtt.v5.intercept.MqttIntroductionAdvice
D
- DEFAULT_VALUE - Static variable in annotation interface io.micronaut.mqtt.annotation.Qos
- DefaultMqttBinder - Class in io.micronaut.mqtt.bind.impl
-
The
FallbackMqttBinder
to bind arguments that don't match any annotated or typed based binder. - DefaultMqttBinder(PayloadMqttBinder) - Constructor for class io.micronaut.mqtt.bind.impl.DefaultMqttBinder
- DefaultMqttBinderRegistry - Class in io.micronaut.mqtt.bind
-
A default implementation of
MqttBinderRegistry
that searches for binders based on argument annotations, then based on the argument type. - DefaultMqttBinderRegistry(FallbackMqttBinder<?>, MqttBinder<?, ?>...) - Constructor for class io.micronaut.mqtt.bind.DefaultMqttBinderRegistry
-
Default constructor.
- DefaultMqttPayloadSerDesRegistry - Class in io.micronaut.mqtt.serdes
-
Default implementation of
MqttPayloadSerDesRegistry
. - DefaultMqttPayloadSerDesRegistry(MqttPayloadSerDes<?>...) - Constructor for class io.micronaut.mqtt.serdes.DefaultMqttPayloadSerDesRegistry
-
Default constructor.
- DefaultMqttSubscriberExceptionHandler - Class in io.micronaut.mqtt.exception
-
The exception handler for subscriber exceptions that is used if the subscriber does not implement
MqttSubscriberExceptionHandler
. - DefaultMqttSubscriberExceptionHandler() - Constructor for class io.micronaut.mqtt.exception.DefaultMqttSubscriberExceptionHandler
- deserialize(byte[], Argument<Object>) - Method in class io.micronaut.mqtt.serdes.JavaLangMqttPayloadSerDes
- deserialize(byte[], Argument<Object>) - Method in class io.micronaut.mqtt.serdes.JsonMqttPayloadSerDes
- deserialize(byte[], Argument<T>) - Method in interface io.micronaut.mqtt.serdes.MqttPayloadSerDes
-
Deserializes the message into the requested type.
F
- FallbackMqttBinder<M> - Interface in io.micronaut.mqtt.bind
-
A binder to use when no other binders match the argument.
- findArgumentBinder(Argument<T>) - Method in class io.micronaut.mqtt.bind.DefaultMqttBinderRegistry
- findArgumentBinder(Argument<T>) - Method in interface io.micronaut.mqtt.bind.MqttBinderRegistry
-
Finds a binder for the given argument.
- findSerdes(Argument<T>) - Method in class io.micronaut.mqtt.serdes.DefaultMqttPayloadSerDesRegistry
- findSerdes(Argument<T>) - Method in interface io.micronaut.mqtt.serdes.MqttPayloadSerDesRegistry
-
Returns the serdes that supports the given type.
- findSerDes(Argument<?>) - Method in class io.micronaut.mqtt.serdes.JavaLangMqttPayloadSerDes
-
Finds the correct serDes based on the type.
G
- getAnnotationType() - Method in interface io.micronaut.mqtt.bind.AnnotatedMqttBinder
- getAnnotationType() - Method in class io.micronaut.mqtt.bind.impl.IdMqttBinder
- getAnnotationType() - Method in class io.micronaut.mqtt.bind.impl.PayloadMqttBinder
- getAnnotationType() - Method in class io.micronaut.mqtt.bind.impl.QosMqttBinder
- getAnnotationType() - Method in class io.micronaut.mqtt.bind.impl.RetainedMqttBinder
- getAnnotationType() - Method in class io.micronaut.mqtt.bind.impl.TopicMqttBinder
- getAnnotationType() - Method in class io.micronaut.mqtt.hivemq.v5.bind.MqttPropertyBinder
- getAnnotationType() - Method in class io.micronaut.mqtt.v5.bind.MqttPropertyBinder
- getArgumentType() - Method in class io.micronaut.mqtt.bind.impl.AcknowledgeMqttBinder
- getArgumentType() - Method in interface io.micronaut.mqtt.bind.TypedMqttBinder
- getBooleanSerDes() - Method in class io.micronaut.mqtt.serdes.JavaLangMqttPayloadSerDes
- getByteArraySerDes() - Method in class io.micronaut.mqtt.serdes.JavaLangMqttPayloadSerDes
- getByteBufferSerDes() - Method in class io.micronaut.mqtt.serdes.JavaLangMqttPayloadSerDes
- getCertificate() - Method in class io.micronaut.mqtt.ssl.MqttCertificateConfiguration
- getCertificateAuthority() - Method in class io.micronaut.mqtt.ssl.MqttCertificateConfiguration
- getCertificateConfiguration() - Method in interface io.micronaut.mqtt.hivemq.config.MqttClientConfiguration
- getClientId() - Method in interface io.micronaut.mqtt.hivemq.config.MqttClientConfiguration
- getClientId() - Method in class io.micronaut.mqtt.v3.config.MqttClientConfigurationProperties
- getClientId() - Method in class io.micronaut.mqtt.v5.config.MqttClientConfigurationProperties
- getClientIdentifier() - Method in interface io.micronaut.mqtt.hivemq.client.MqttClientAdapter
- getClientIdentifier() - Method in class io.micronaut.mqtt.hivemq.v3.client.Mqtt3ClientAdapter
- getClientIdentifier() - Method in class io.micronaut.mqtt.hivemq.v5.client.Mqtt5ClientAdapter
- getConnectionTimeout() - Method in interface io.micronaut.mqtt.hivemq.config.MqttClientConfiguration
- getConnectionTimeout() - Method in class io.micronaut.mqtt.v3.config.MqttClientConfigurationProperties
- getConnectionTimeout() - Method in class io.micronaut.mqtt.v5.config.MqttClientConfigurationProperties
- getConnectOptions() - Method in class io.micronaut.mqtt.v3.config.MqttClientConfigurationProperties
- getConnectOptions() - Method in class io.micronaut.mqtt.v5.config.MqttClientConfigurationProperties
- getContentType() - Method in class io.micronaut.mqtt.hivemq.bind.MqttMessage
-
Returns a string describing the content type.
- getCorrelationData() - Method in class io.micronaut.mqtt.hivemq.bind.MqttMessage
-
Returns the correlation data for the message.
- getCustomWebSocketHeaders() - Method in interface io.micronaut.mqtt.hivemq.config.MqttClientConfiguration
- getDoubleSerDes() - Method in class io.micronaut.mqtt.serdes.JavaLangMqttPayloadSerDes
- getFloatSerDes() - Method in class io.micronaut.mqtt.serdes.JavaLangMqttPayloadSerDes
- getId() - Method in interface io.micronaut.mqtt.bind.MqttBindingContext
- getId() - Method in class io.micronaut.mqtt.hivemq.bind.MqttMessage
-
Returns the message id.
- getId() - Method in class io.micronaut.mqtt.hivemq.v3.bind.MqttV3BindingContext
- getId() - Method in class io.micronaut.mqtt.hivemq.v5.bind.MqttV5BindingContext
- getId() - Method in class io.micronaut.mqtt.v3.bind.MqttV3BindingContext
- getId() - Method in class io.micronaut.mqtt.v5.bind.MqttV5BindingContext
- getIntegerSerDes() - Method in class io.micronaut.mqtt.serdes.JavaLangMqttPayloadSerDes
- getKeepAliveInterval() - Method in interface io.micronaut.mqtt.hivemq.config.MqttClientConfiguration
- getKey() - Method in class io.micronaut.mqtt.hivemq.bind.UserProperty
-
The key of the property.
- getKeyManagerFactory(MqttCertificateConfiguration) - Method in interface io.micronaut.mqtt.hivemq.client.MqttClientFactory
- getLongSerDes() - Method in class io.micronaut.mqtt.serdes.JavaLangMqttPayloadSerDes
- getManualAcks() - Method in interface io.micronaut.mqtt.hivemq.config.MqttClientConfiguration
- getManualAcks() - Method in class io.micronaut.mqtt.v3.config.MqttClientConfigurationProperties
- getMaximumPacketSize() - Method in interface io.micronaut.mqtt.hivemq.v5.config.Mqtt5ClientConfiguration
- getMaxReconnectDelay() - Method in interface io.micronaut.mqtt.hivemq.config.MqttClientConfiguration
- getMessageExpiryInterval() - Method in class io.micronaut.mqtt.hivemq.bind.MqttMessage
-
Returns the message expiry interval in seconds.
- getMqttVersion() - Method in interface io.micronaut.mqtt.hivemq.config.MqttClientConfiguration
- getNativeMessage() - Method in interface io.micronaut.mqtt.bind.MqttBindingContext
- getNativeMessage() - Method in class io.micronaut.mqtt.hivemq.v3.bind.MqttV3BindingContext
- getNativeMessage() - Method in class io.micronaut.mqtt.hivemq.v5.bind.MqttV5BindingContext
- getNativeMessage() - Method in class io.micronaut.mqtt.v3.bind.MqttV3BindingContext
- getNativeMessage() - Method in class io.micronaut.mqtt.v5.bind.MqttV5BindingContext
- getOrder() - Method in class io.micronaut.mqtt.serdes.JavaLangMqttPayloadSerDes
- getOrder() - Method in class io.micronaut.mqtt.serdes.JsonMqttPayloadSerDes
- getPassword() - Method in interface io.micronaut.mqtt.hivemq.config.MqttClientConfiguration
- getPassword() - Method in class io.micronaut.mqtt.ssl.MqttCertificateConfiguration
- getPayload() - Method in interface io.micronaut.mqtt.bind.MqttBindingContext
- getPayload() - Method in class io.micronaut.mqtt.hivemq.bind.MqttMessage
-
Returns the payload as byte array.
- getPayload() - Method in class io.micronaut.mqtt.hivemq.v3.bind.MqttV3BindingContext
- getPayload() - Method in class io.micronaut.mqtt.hivemq.v5.bind.MqttV5BindingContext
- getPayload() - Method in class io.micronaut.mqtt.v3.bind.MqttV3BindingContext
- getPayload() - Method in class io.micronaut.mqtt.v5.bind.MqttV5BindingContext
- getPayloadFormatIndicator() - Method in class io.micronaut.mqtt.hivemq.bind.MqttMessage
-
Returns the payload format indicator.
- getPrivateKey() - Method in class io.micronaut.mqtt.ssl.MqttCertificateConfiguration
- getPrivateKey(Readable, char[]) - Static method in class io.micronaut.mqtt.hivemq.ssl.PrivateKeyReader
- getProperties() - Method in class io.micronaut.mqtt.v5.bind.MqttV5BindingContext
- getQos() - Method in interface io.micronaut.mqtt.bind.MqttBindingContext
- getQos() - Method in class io.micronaut.mqtt.hivemq.bind.MqttMessage
-
Returns the quality of service level for the message.
- getQos() - Method in class io.micronaut.mqtt.hivemq.v3.bind.MqttV3BindingContext
- getQos() - Method in class io.micronaut.mqtt.hivemq.v5.bind.MqttV5BindingContext
- getQos() - Method in class io.micronaut.mqtt.v3.bind.MqttV3BindingContext
- getQos() - Method in class io.micronaut.mqtt.v5.bind.MqttV5BindingContext
- getReceiveMaximum() - Method in interface io.micronaut.mqtt.hivemq.v5.config.Mqtt5ClientConfiguration
- getRequiredAnnotation() - Method in class io.micronaut.mqtt.hivemq.v3.intercept.Mqtt3IntroductionAdvice
- getRequiredAnnotation() - Method in class io.micronaut.mqtt.hivemq.v5.intercept.Mqtt5IntroductionAdvice
- getRequiredAnnotation() - Method in class io.micronaut.mqtt.intercept.AbstractMqttIntroductionAdvice
- getRequiredAnnotation() - Method in class io.micronaut.mqtt.v3.intercept.MqttIntroductionAdvice
- getRequiredAnnotation() - Method in class io.micronaut.mqtt.v5.intercept.MqttIntroductionAdvice
- getResponseTopic() - Method in class io.micronaut.mqtt.hivemq.bind.MqttMessage
-
Returns the response topic for using MQTT v5 request response pattern.
- getResult() - Method in class io.micronaut.mqtt.hivemq.client.health.MqttHealthIndicator
- getResult() - Method in class io.micronaut.mqtt.v3.client.health.MqttHealthIndicator
- getResult() - Method in class io.micronaut.mqtt.v5.client.health.MqttHealthIndicator
- getServerHost() - Method in interface io.micronaut.mqtt.hivemq.config.MqttClientConfiguration
- getServerPort() - Method in interface io.micronaut.mqtt.hivemq.config.MqttClientConfiguration
- getServerUri() - Method in interface io.micronaut.mqtt.hivemq.config.MqttClientConfiguration
- getServerUri() - Method in class io.micronaut.mqtt.v3.config.MqttClientConfigurationProperties
- getServerUri() - Method in class io.micronaut.mqtt.v5.config.MqttClientConfigurationProperties
- getSessionExpiryInterval() - Method in interface io.micronaut.mqtt.hivemq.v5.config.Mqtt5ClientConfiguration
- getShortSerDes() - Method in class io.micronaut.mqtt.serdes.JavaLangMqttPayloadSerDes
- getSocketFactory() - Method in interface io.micronaut.mqtt.config.MqttSSLConfiguration
- getSocketFactory() - Method in class io.micronaut.mqtt.v3.config.MqttClientConfigurationProperties
- getSocketFactory() - Method in class io.micronaut.mqtt.v5.config.MqttClientConfigurationProperties
- getSSLHostnameVerifier() - Method in interface io.micronaut.mqtt.config.MqttSSLConfiguration
- getSSLHostnameVerifier() - Method in interface io.micronaut.mqtt.hivemq.config.MqttClientConfiguration
- getSSLHostnameVerifier() - Method in class io.micronaut.mqtt.v3.config.MqttClientConfigurationProperties
- getSSLHostnameVerifier() - Method in class io.micronaut.mqtt.v5.config.MqttClientConfigurationProperties
- getSSLProperties() - Method in interface io.micronaut.mqtt.config.MqttSSLConfiguration
- getSSLProperties() - Method in class io.micronaut.mqtt.v3.config.MqttClientConfigurationProperties
- getSSLProperties() - Method in class io.micronaut.mqtt.v5.config.MqttClientConfigurationProperties
- getStringSerDes() - Method in class io.micronaut.mqtt.serdes.JavaLangMqttPayloadSerDes
- getTopic() - Method in interface io.micronaut.mqtt.bind.MqttBindingContext
- getTopic() - Method in class io.micronaut.mqtt.hivemq.v3.bind.MqttV3BindingContext
- getTopic() - Method in class io.micronaut.mqtt.hivemq.v5.bind.MqttV5BindingContext
- getTopic() - Method in class io.micronaut.mqtt.v3.bind.MqttV3BindingContext
- getTopic() - Method in class io.micronaut.mqtt.v5.bind.MqttV5BindingContext
- getTopicAliasMaximum() - Method in interface io.micronaut.mqtt.hivemq.v5.config.Mqtt5ClientConfiguration
- getTopicMap(String[], int[]) - Method in interface io.micronaut.mqtt.hivemq.client.MqttClientAdapter
- getTrustManagerFactory(MqttCertificateConfiguration) - Method in interface io.micronaut.mqtt.hivemq.client.MqttClientFactory
- getUserName() - Method in interface io.micronaut.mqtt.hivemq.config.MqttClientConfiguration
- getUserProperties() - Method in class io.micronaut.mqtt.hivemq.bind.MqttMessage
-
Returns the MQTT user properties.
- getUserProperties() - Method in interface io.micronaut.mqtt.hivemq.v5.config.Mqtt5ClientConfiguration
- getUUIDSerDes() - Method in class io.micronaut.mqtt.serdes.JavaLangMqttPayloadSerDes
- getValue() - Method in class io.micronaut.mqtt.hivemq.bind.UserProperty
-
The value of the property.
- getWillMessage() - Method in interface io.micronaut.mqtt.hivemq.config.MqttClientConfiguration
H
- handle(MqttSubscriberException) - Method in class io.micronaut.mqtt.exception.DefaultMqttSubscriberExceptionHandler
I
- Id - Annotation Interface in io.micronaut.mqtt.annotation
-
Used to bind the message ID to a parameter.
- IdMqttBinder - Class in io.micronaut.mqtt.bind.impl
-
An annotated argument binder for
Id
. - IdMqttBinder(ConversionService) - Constructor for class io.micronaut.mqtt.bind.impl.IdMqttBinder
- intercept(MethodInvocationContext<Object, Object>) - Method in class io.micronaut.mqtt.intercept.AbstractMqttIntroductionAdvice
- io.micronaut.mqtt.annotation - package io.micronaut.mqtt.annotation
-
Annotations for creating MQTT consumers and producers.
- io.micronaut.mqtt.annotation.v3 - package io.micronaut.mqtt.annotation.v3
- io.micronaut.mqtt.annotation.v5 - package io.micronaut.mqtt.annotation.v5
- io.micronaut.mqtt.bind - package io.micronaut.mqtt.bind
- io.micronaut.mqtt.bind.impl - package io.micronaut.mqtt.bind.impl
- io.micronaut.mqtt.config - package io.micronaut.mqtt.config
- io.micronaut.mqtt.exception - package io.micronaut.mqtt.exception
- io.micronaut.mqtt.executor - package io.micronaut.mqtt.executor
- io.micronaut.mqtt.hivemq.bind - package io.micronaut.mqtt.hivemq.bind
- io.micronaut.mqtt.hivemq.client - package io.micronaut.mqtt.hivemq.client
- io.micronaut.mqtt.hivemq.client.health - package io.micronaut.mqtt.hivemq.client.health
- io.micronaut.mqtt.hivemq.config - package io.micronaut.mqtt.hivemq.config
- io.micronaut.mqtt.hivemq.intercept - package io.micronaut.mqtt.hivemq.intercept
- io.micronaut.mqtt.hivemq.ssl - package io.micronaut.mqtt.hivemq.ssl
- io.micronaut.mqtt.hivemq.v3.bind - package io.micronaut.mqtt.hivemq.v3.bind
- io.micronaut.mqtt.hivemq.v3.client - package io.micronaut.mqtt.hivemq.v3.client
- io.micronaut.mqtt.hivemq.v3.config - package io.micronaut.mqtt.hivemq.v3.config
- io.micronaut.mqtt.hivemq.v3.intercept - package io.micronaut.mqtt.hivemq.v3.intercept
- io.micronaut.mqtt.hivemq.v5.bind - package io.micronaut.mqtt.hivemq.v5.bind
- io.micronaut.mqtt.hivemq.v5.client - package io.micronaut.mqtt.hivemq.v5.client
- io.micronaut.mqtt.hivemq.v5.config - package io.micronaut.mqtt.hivemq.v5.config
- io.micronaut.mqtt.hivemq.v5.intercept - package io.micronaut.mqtt.hivemq.v5.intercept
- io.micronaut.mqtt.intercept - package io.micronaut.mqtt.intercept
- io.micronaut.mqtt.serdes - package io.micronaut.mqtt.serdes
-
Classes for serializing and deserializing MQTT message payloads.
- io.micronaut.mqtt.ssl - package io.micronaut.mqtt.ssl
-
MQTT SSL connection management.
- io.micronaut.mqtt.v3.bind - package io.micronaut.mqtt.v3.bind
- io.micronaut.mqtt.v3.client - package io.micronaut.mqtt.v3.client
- io.micronaut.mqtt.v3.client.health - package io.micronaut.mqtt.v3.client.health
- io.micronaut.mqtt.v3.config - package io.micronaut.mqtt.v3.config
- io.micronaut.mqtt.v3.intercept - package io.micronaut.mqtt.v3.intercept
- io.micronaut.mqtt.v5.bind - package io.micronaut.mqtt.v5.bind
- io.micronaut.mqtt.v5.client - package io.micronaut.mqtt.v5.client
- io.micronaut.mqtt.v5.client.health - package io.micronaut.mqtt.v5.client.health
- io.micronaut.mqtt.v5.config - package io.micronaut.mqtt.v5.config
- io.micronaut.mqtt.v5.intercept - package io.micronaut.mqtt.v5.intercept
- isAutomaticReconnect() - Method in interface io.micronaut.mqtt.hivemq.config.MqttClientConfiguration
- isCleanSession() - Method in interface io.micronaut.mqtt.hivemq.v3.config.Mqtt3ClientConfiguration
- isCleanStart() - Method in interface io.micronaut.mqtt.hivemq.v5.config.Mqtt5ClientConfiguration
- isConnected() - Method in interface io.micronaut.mqtt.hivemq.client.MqttClientAdapter
- isConnected() - Method in class io.micronaut.mqtt.hivemq.v3.client.Mqtt3ClientAdapter
- isConnected() - Method in class io.micronaut.mqtt.hivemq.v5.client.Mqtt5ClientAdapter
- isEnabled() - Method in class io.micronaut.mqtt.config.MqttConfigurationProperties
- isHttpsHostnameVerificationEnabled() - Method in interface io.micronaut.mqtt.config.MqttSSLConfiguration
- isHttpsHostnameVerificationEnabled() - Method in interface io.micronaut.mqtt.hivemq.config.MqttClientConfiguration
- isHttpsHostnameVerificationEnabled() - Method in class io.micronaut.mqtt.v3.config.MqttClientConfigurationProperties
- isHttpsHostnameVerificationEnabled() - Method in class io.micronaut.mqtt.v5.config.MqttClientConfigurationProperties
- isRequestProblemInfo() - Method in interface io.micronaut.mqtt.hivemq.v5.config.Mqtt5ClientConfiguration
- isRequestResponseInfo() - Method in interface io.micronaut.mqtt.hivemq.v5.config.Mqtt5ClientConfiguration
- isRetained() - Method in interface io.micronaut.mqtt.bind.MqttBindingContext
- isRetained() - Method in class io.micronaut.mqtt.hivemq.bind.MqttMessage
-
Returns whether the message is a retained message.
- isRetained() - Method in class io.micronaut.mqtt.hivemq.v3.bind.MqttV3BindingContext
- isRetained() - Method in class io.micronaut.mqtt.hivemq.v5.bind.MqttV5BindingContext
- isRetained() - Method in class io.micronaut.mqtt.v3.bind.MqttV3BindingContext
- isRetained() - Method in class io.micronaut.mqtt.v5.bind.MqttV5BindingContext
- isSSL() - Method in interface io.micronaut.mqtt.hivemq.config.MqttClientConfiguration
J
- JavaLangMqttPayloadSerDes - Class in io.micronaut.mqtt.serdes
-
Serializes and deserializes standard Java types.
- JavaLangMqttPayloadSerDes() - Constructor for class io.micronaut.mqtt.serdes.JavaLangMqttPayloadSerDes
-
Default constructor.
- javaSerDes - Variable in class io.micronaut.mqtt.serdes.JavaLangMqttPayloadSerDes
- JsonMqttPayloadSerDes - Class in io.micronaut.mqtt.serdes
-
Serializes and deserializes objects as JSON using Jackson.
- JsonMqttPayloadSerDes(JsonMapper) - Constructor for class io.micronaut.mqtt.serdes.JsonMqttPayloadSerDes
-
Default constructor.
K
- KeyManagerFactoryCreationException - Exception in io.micronaut.mqtt.hivemq.ssl
-
Thrown when an a
KeyManagerFactory
can not be created. - KeyManagerFactoryCreationException(String, Throwable) - Constructor for exception io.micronaut.mqtt.hivemq.ssl.KeyManagerFactoryCreationException
M
- Mqtt3ClientAdapter - Class in io.micronaut.mqtt.hivemq.v3.client
-
Adapter class for MQTT 3 HiveMQ async client.
- Mqtt3ClientAdapter(Mqtt3AsyncClient, Mqtt3ClientConfiguration) - Constructor for class io.micronaut.mqtt.hivemq.v3.client.Mqtt3ClientAdapter
- Mqtt3ClientConfiguration - Interface in io.micronaut.mqtt.hivemq.v3.config
-
MQTT v3 Client Configuration.
- Mqtt3ClientFactory - Class in io.micronaut.mqtt.hivemq.v3.client
-
A factory to create an MQTT v3 client.
- Mqtt3ClientFactory() - Constructor for class io.micronaut.mqtt.hivemq.v3.client.Mqtt3ClientFactory
- Mqtt3IntroductionAdvice - Class in io.micronaut.mqtt.hivemq.v3.intercept
-
The MQTT v3 implementation of
AbstractMqttIntroductionAdvice
. - Mqtt3IntroductionAdvice(Mqtt3AsyncClient, MqttBinderRegistry) - Constructor for class io.micronaut.mqtt.hivemq.v3.intercept.Mqtt3IntroductionAdvice
- Mqtt5ClientAdapter - Class in io.micronaut.mqtt.hivemq.v5.client
-
Adapter class for MQTT 3 HiveMQ async client.
- Mqtt5ClientAdapter(Mqtt5AsyncClient, Mqtt5ClientConfiguration) - Constructor for class io.micronaut.mqtt.hivemq.v5.client.Mqtt5ClientAdapter
- Mqtt5ClientConfiguration - Interface in io.micronaut.mqtt.hivemq.v5.config
-
MQTT v5 Client Configuration.
- Mqtt5ClientFactory - Class in io.micronaut.mqtt.hivemq.v5.client
-
A factory to create an MQTT v5 client.
- Mqtt5ClientFactory() - Constructor for class io.micronaut.mqtt.hivemq.v5.client.Mqtt5ClientFactory
- Mqtt5IntroductionAdvice - Class in io.micronaut.mqtt.hivemq.v5.intercept
-
The MQTT v5 implementation of
AbstractMqttIntroductionAdvice
. - Mqtt5IntroductionAdvice(Mqtt5AsyncClient, MqttBinderRegistry) - Constructor for class io.micronaut.mqtt.hivemq.v5.intercept.Mqtt5IntroductionAdvice
- MqttBinder<M,
T> - Interface in io.micronaut.mqtt.bind -
Argument binder to bind publisher and subscriber method arguments to and from the message context.
- MqttBinderRegistry - Interface in io.micronaut.mqtt.bind
-
A registry of binders for binding to and from MQTT messages.
- MqttBindingContext<T> - Interface in io.micronaut.mqtt.bind
-
A generic context for binding to MQTT messages.
- MqttCertificateConfiguration - Class in io.micronaut.mqtt.ssl
-
MQTT client SSL configuration.
- MqttCertificateConfiguration() - Constructor for class io.micronaut.mqtt.ssl.MqttCertificateConfiguration
- MqttClientAdapter - Interface in io.micronaut.mqtt.hivemq.client
-
Common interface for HiveMQ MQTT clients.
- MqttClientConfiguration - Interface in io.micronaut.mqtt.hivemq.config
-
MQTT Client Configuration.
- MqttClientConfigurationProperties - Class in io.micronaut.mqtt.v3.config
-
Configuration for the MQTT client.
- MqttClientConfigurationProperties - Class in io.micronaut.mqtt.v5.config
-
Configuration for the MQTT client.
- MqttClientConfigurationProperties(MqttClientConfigurationProperties.WillMessage) - Constructor for class io.micronaut.mqtt.v3.config.MqttClientConfigurationProperties
- MqttClientConfigurationProperties(MqttClientConfigurationProperties.WillMessage) - Constructor for class io.micronaut.mqtt.v5.config.MqttClientConfigurationProperties
- MqttClientException - Exception in io.micronaut.mqtt.exception
-
An exception thrown while publishing to MQTT topics.
- MqttClientException(String) - Constructor for exception io.micronaut.mqtt.exception.MqttClientException
- MqttClientException(String, Throwable) - Constructor for exception io.micronaut.mqtt.exception.MqttClientException
- MqttClientFactory - Class in io.micronaut.mqtt.v3.client
-
A factory to create an MQTT client.
- MqttClientFactory - Class in io.micronaut.mqtt.v5.client
-
A factory to create an MQTT client.
- MqttClientFactory - Interface in io.micronaut.mqtt.hivemq.client
-
Common interface for MQTT client factories.
- MqttClientFactory() - Constructor for class io.micronaut.mqtt.v3.client.MqttClientFactory
- MqttClientFactory() - Constructor for class io.micronaut.mqtt.v5.client.MqttClientFactory
- MqttConfiguration - Interface in io.micronaut.mqtt.config
-
MQTT related configuration.
- MqttConfigurationProperties - Class in io.micronaut.mqtt.config
-
ConfigurationProperties
implementation forMqttConfiguration
. - MqttConfigurationProperties() - Constructor for class io.micronaut.mqtt.config.MqttConfigurationProperties
- MqttExecutorFactory - Class in io.micronaut.mqtt.executor
-
Configures a
ScheduledExecutorService
for running instances. - MqttExecutorFactory() - Constructor for class io.micronaut.mqtt.executor.MqttExecutorFactory
- MqttHealthIndicator - Class in io.micronaut.mqtt.hivemq.client.health
-
A
HealthIndicator
for HiveMQ MQTT Client. - MqttHealthIndicator - Class in io.micronaut.mqtt.v3.client.health
-
A
HealthIndicator
for Mqtt Client. - MqttHealthIndicator - Class in io.micronaut.mqtt.v5.client.health
-
A
HealthIndicator
for Mqtt Client. - MqttHealthIndicator(MqttClientAdapter) - Constructor for class io.micronaut.mqtt.hivemq.client.health.MqttHealthIndicator
- MqttHealthIndicator(MqttAsyncClient) - Constructor for class io.micronaut.mqtt.v3.client.health.MqttHealthIndicator
-
Constructor.
- MqttHealthIndicator(MqttAsyncClient) - Constructor for class io.micronaut.mqtt.v5.client.health.MqttHealthIndicator
-
Constructor.
- MqttIntroductionAdvice - Class in io.micronaut.mqtt.v3.intercept
-
The MQTT v3 implementation of
AbstractMqttIntroductionAdvice
. - MqttIntroductionAdvice - Class in io.micronaut.mqtt.v5.intercept
-
The MQTT v5 implementation of
AbstractMqttIntroductionAdvice
. - MqttIntroductionAdvice(MqttAsyncClient, MqttBinderRegistry) - Constructor for class io.micronaut.mqtt.v3.intercept.MqttIntroductionAdvice
- MqttIntroductionAdvice(MqttAsyncClient, MqttBinderRegistry) - Constructor for class io.micronaut.mqtt.v5.intercept.MqttIntroductionAdvice
- MqttMessage - Class in io.micronaut.mqtt.hivemq.bind
-
A MQTT message holds the payload and options for message delivery.
- MqttMessage() - Constructor for class io.micronaut.mqtt.hivemq.bind.MqttMessage
- MqttMessage(byte[]) - Constructor for class io.micronaut.mqtt.hivemq.bind.MqttMessage
- MqttPayloadSerDes<T> - Interface in io.micronaut.mqtt.serdes
-
Responsible for serializing and deserializing MQTT message payloads.
- MqttPayloadSerDesRegistry - Interface in io.micronaut.mqtt.serdes
-
A registry of
MqttPayloadSerDes
instances. - MqttProperties - Annotation Interface in io.micronaut.mqtt.annotation.v5
-
Used for binding arguments to mqtt properties.
- MqttProperty - Annotation Interface in io.micronaut.mqtt.annotation.v5
-
Used for binding arguments to mqtt properties.
- MqttPropertyBinder - Class in io.micronaut.mqtt.hivemq.v5.bind
-
Binds arguments to and from
MqttMessage
. - MqttPropertyBinder - Class in io.micronaut.mqtt.v5.bind
-
Binds arguments to and from
MqttProperties
. - MqttPropertyBinder(ConversionService) - Constructor for class io.micronaut.mqtt.hivemq.v5.bind.MqttPropertyBinder
- MqttPropertyBinder(ConversionService) - Constructor for class io.micronaut.mqtt.v5.bind.MqttPropertyBinder
- MqttPublisher - Annotation Interface in io.micronaut.mqtt.annotation.v3
-
An introduction advice that automatically implements interfaces and abstract classes and publishes Mqtt messages.
- MqttPublisher - Annotation Interface in io.micronaut.mqtt.annotation.v5
-
An introduction advice that automatically implements interfaces and abstract classes and publishes Mqtt messages.
- MqttSSLConfiguration - Interface in io.micronaut.mqtt.config
-
Generic interface for manipulating SSL based properties in MQTT configuration.
- MqttSubscriber - Annotation Interface in io.micronaut.mqtt.annotation
-
Class level annotation to indicate that a bean will be consumers of messages from Mqtt.
- MqttSubscriberAdvice - Class in io.micronaut.mqtt.hivemq.intercept
-
The HiveMQ implementation of
AbstractMqttSubscriberAdvice
. - MqttSubscriberAdvice - Class in io.micronaut.mqtt.v3.intercept
-
The MQTT v3 implementation of
AbstractMqttSubscriberAdvice
. - MqttSubscriberAdvice - Class in io.micronaut.mqtt.v5.intercept
-
The MQTT v5 implementation of
AbstractMqttSubscriberAdvice
. - MqttSubscriberAdvice(BeanContext, MqttBinderRegistry, MqttSubscriberExceptionHandler, MqttClientAdapter) - Constructor for class io.micronaut.mqtt.hivemq.intercept.MqttSubscriberAdvice
- MqttSubscriberAdvice(BeanContext, MqttBinderRegistry, MqttSubscriberExceptionHandler, MqttAsyncClient) - Constructor for class io.micronaut.mqtt.v3.intercept.MqttSubscriberAdvice
- MqttSubscriberAdvice(BeanContext, MqttBinderRegistry, MqttSubscriberExceptionHandler, MqttAsyncClient) - Constructor for class io.micronaut.mqtt.v5.intercept.MqttSubscriberAdvice
- MqttSubscriberException - Exception in io.micronaut.mqtt.exception
-
An exception thrown while subscribing to MQTT topics.
- MqttSubscriberException(String) - Constructor for exception io.micronaut.mqtt.exception.MqttSubscriberException
- MqttSubscriberException(String, Throwable) - Constructor for exception io.micronaut.mqtt.exception.MqttSubscriberException
- MqttSubscriberExceptionHandler - Interface in io.micronaut.mqtt.exception
-
Responsible for handling exceptions thrown during the subscription process.
- MqttV3BindingContext - Class in io.micronaut.mqtt.hivemq.v3.bind
-
A binding context for MQTT v3 messages.
- MqttV3BindingContext - Class in io.micronaut.mqtt.v3.bind
-
A binding context for MQTT v3 messages.
- MqttV3BindingContext(Mqtt3AsyncClient, MqttMessage) - Constructor for class io.micronaut.mqtt.hivemq.v3.bind.MqttV3BindingContext
- MqttV3BindingContext(MqttAsyncClient, MqttMessage) - Constructor for class io.micronaut.mqtt.v3.bind.MqttV3BindingContext
- MqttV5BindingContext - Class in io.micronaut.mqtt.hivemq.v5.bind
-
A binding context for MQTT v5 messages.
- MqttV5BindingContext - Class in io.micronaut.mqtt.v5.bind
-
A binding context for MQTT v5 messages.
- MqttV5BindingContext(Mqtt5AsyncClient, MqttMessage) - Constructor for class io.micronaut.mqtt.hivemq.v5.bind.MqttV5BindingContext
- MqttV5BindingContext(MqttAsyncClient, MqttMessage) - Constructor for class io.micronaut.mqtt.v5.bind.MqttV5BindingContext
N
- name() - Element in annotation interface io.micronaut.mqtt.annotation.v5.MqttProperty
-
Never used if applied to a parameter.
- NAME - Static variable in class io.micronaut.mqtt.hivemq.client.health.MqttHealthIndicator
- NAME - Static variable in class io.micronaut.mqtt.v3.client.health.MqttHealthIndicator
- NAME - Static variable in class io.micronaut.mqtt.v5.client.health.MqttHealthIndicator
O
- ORDER - Static variable in class io.micronaut.mqtt.serdes.JavaLangMqttPayloadSerDes
-
The order of this serDes.
- ORDER - Static variable in class io.micronaut.mqtt.serdes.JsonMqttPayloadSerDes
-
The order of this serDes.
P
- PayloadMqttBinder - Class in io.micronaut.mqtt.bind.impl
-
A binder responsible for binding to the payload of the message.
- PayloadMqttBinder(MqttPayloadSerDesRegistry) - Constructor for class io.micronaut.mqtt.bind.impl.PayloadMqttBinder
- PREFIX - Static variable in class io.micronaut.mqtt.config.MqttConfigurationProperties
- PrivateKeyReader - Class in io.micronaut.mqtt.hivemq.ssl
-
Reader for reading PKCS #1 and PKCS #8 private keys from PEM files.
- process(BeanDefinition<?>, ExecutableMethod<?, ?>) - Method in class io.micronaut.mqtt.intercept.AbstractMqttSubscriberAdvice
- publish(String, MqttMessage, BiConsumer<Mqtt3Publish, Throwable>) - Method in class io.micronaut.mqtt.hivemq.v3.intercept.Mqtt3IntroductionAdvice
- publish(String, MqttMessage, BiConsumer<Mqtt5PublishResult, Throwable>) - Method in class io.micronaut.mqtt.hivemq.v5.intercept.Mqtt5IntroductionAdvice
- publish(String, M, L) - Method in class io.micronaut.mqtt.intercept.AbstractMqttIntroductionAdvice
-
Publishes the message.
- publish(String, MqttMessage, IMqttActionListener) - Method in class io.micronaut.mqtt.v3.intercept.MqttIntroductionAdvice
- publish(String, MqttMessage, MqttActionListener) - Method in class io.micronaut.mqtt.v5.intercept.MqttIntroductionAdvice
Q
- qos() - Element in annotation interface io.micronaut.mqtt.annotation.Topic
- Qos - Annotation Interface in io.micronaut.mqtt.annotation
-
Used for binding the message Qos.
- QosMqttBinder - Class in io.micronaut.mqtt.bind.impl
-
An annotated argument binder for
Qos
. - QosMqttBinder(ConversionService) - Constructor for class io.micronaut.mqtt.bind.impl.QosMqttBinder
R
- readCertificate(Readable) - Static method in class io.micronaut.mqtt.hivemq.ssl.CertificateReader
- Retained - Annotation Interface in io.micronaut.mqtt.annotation
-
Used for binding the message retained parameter.
- RetainedMqttBinder - Class in io.micronaut.mqtt.bind.impl
-
An annotated argument binder for
Retained
. - RetainedMqttBinder(ConversionService) - Constructor for class io.micronaut.mqtt.bind.impl.RetainedMqttBinder
S
- serialize(Object) - Method in class io.micronaut.mqtt.serdes.JavaLangMqttPayloadSerDes
- serialize(Object) - Method in class io.micronaut.mqtt.serdes.JsonMqttPayloadSerDes
- serialize(T) - Method in interface io.micronaut.mqtt.serdes.MqttPayloadSerDes
-
Serializes the data into a byte[] to be published to MQTT.
- setCertificate(Readable) - Method in class io.micronaut.mqtt.ssl.MqttCertificateConfiguration
- setCertificateAuthority(Readable) - Method in class io.micronaut.mqtt.ssl.MqttCertificateConfiguration
- setClientId(String) - Method in class io.micronaut.mqtt.v3.config.MqttClientConfigurationProperties
- setClientId(String) - Method in class io.micronaut.mqtt.v5.config.MqttClientConfigurationProperties
- setConnectionTimeout(Duration) - Method in class io.micronaut.mqtt.v3.config.MqttClientConfigurationProperties
- setConnectionTimeout(Duration) - Method in class io.micronaut.mqtt.v5.config.MqttClientConfigurationProperties
- setContentType(String) - Method in class io.micronaut.mqtt.hivemq.bind.MqttMessage
-
Sets the content type description for the message.
- setCorrelationData(byte[]) - Method in class io.micronaut.mqtt.hivemq.bind.MqttMessage
-
Sets the correlation data for the message.
- setEnabled(boolean) - Method in class io.micronaut.mqtt.config.MqttConfigurationProperties
-
Enables Micronaut MQTT integration.
- setHttpsHostnameVerificationEnabled(boolean) - Method in interface io.micronaut.mqtt.config.MqttSSLConfiguration
- setHttpsHostnameVerificationEnabled(boolean) - Method in class io.micronaut.mqtt.v3.config.MqttClientConfigurationProperties
- setHttpsHostnameVerificationEnabled(boolean) - Method in class io.micronaut.mqtt.v5.config.MqttClientConfigurationProperties
- setId(int) - Method in class io.micronaut.mqtt.hivemq.bind.MqttMessage
-
Sets the message id.
- setManualAcks(boolean) - Method in class io.micronaut.mqtt.hivemq.v3.bind.MqttV3BindingContext
- setManualAcks(boolean) - Method in class io.micronaut.mqtt.hivemq.v5.bind.MqttV5BindingContext
- setManualAcks(Boolean) - Method in class io.micronaut.mqtt.v3.config.MqttClientConfigurationProperties
- setMessageExpiryInterval(long) - Method in class io.micronaut.mqtt.hivemq.bind.MqttMessage
-
Sets the message expiry interval in seconds.
- setMqtt3Publish(Mqtt3Publish) - Method in class io.micronaut.mqtt.hivemq.v3.bind.MqttV3BindingContext
- setMqtt5Publish(Mqtt5Publish) - Method in class io.micronaut.mqtt.hivemq.v5.bind.MqttV5BindingContext
- setPassword(char[]) - Method in class io.micronaut.mqtt.ssl.MqttCertificateConfiguration
- setPayload(byte[]) - Method in interface io.micronaut.mqtt.bind.MqttBindingContext
-
Sets the message payload.
- setPayload(byte[]) - Method in class io.micronaut.mqtt.hivemq.bind.MqttMessage
-
Sets the payload of the message.
- setPayload(byte[]) - Method in class io.micronaut.mqtt.hivemq.v3.bind.MqttV3BindingContext
- setPayload(byte[]) - Method in class io.micronaut.mqtt.hivemq.v5.bind.MqttV5BindingContext
- setPayload(byte[]) - Method in class io.micronaut.mqtt.v3.bind.MqttV3BindingContext
- setPayload(byte[]) - Method in class io.micronaut.mqtt.v5.bind.MqttV5BindingContext
- setPayloadFormatIndicator(int) - Method in class io.micronaut.mqtt.hivemq.bind.MqttMessage
-
Sets the payload format indicator.
- setPrivateKey(Readable) - Method in class io.micronaut.mqtt.ssl.MqttCertificateConfiguration
- setProperties(MqttProperties) - Method in class io.micronaut.mqtt.v5.bind.MqttV5BindingContext
- setQos(int) - Method in interface io.micronaut.mqtt.bind.MqttBindingContext
-
Sets the message qos.
- setQos(int) - Method in class io.micronaut.mqtt.hivemq.bind.MqttMessage
-
Sets the quality of service level for the message.
- setQos(int) - Method in class io.micronaut.mqtt.hivemq.v3.bind.MqttV3BindingContext
- setQos(int) - Method in class io.micronaut.mqtt.hivemq.v5.bind.MqttV5BindingContext
- setQos(int) - Method in class io.micronaut.mqtt.v3.bind.MqttV3BindingContext
- setQos(int) - Method in class io.micronaut.mqtt.v5.bind.MqttV5BindingContext
- setResponseTopic(String) - Method in class io.micronaut.mqtt.hivemq.bind.MqttMessage
-
Sets the response topic for using MQTT v5 request response pattern.
- setRetained(boolean) - Method in interface io.micronaut.mqtt.bind.MqttBindingContext
-
Sets the message to be retained.
- setRetained(boolean) - Method in class io.micronaut.mqtt.hivemq.bind.MqttMessage
-
Sets whether the message is retained.
- setRetained(boolean) - Method in class io.micronaut.mqtt.hivemq.v3.bind.MqttV3BindingContext
- setRetained(boolean) - Method in class io.micronaut.mqtt.hivemq.v5.bind.MqttV5BindingContext
- setRetained(boolean) - Method in class io.micronaut.mqtt.v3.bind.MqttV3BindingContext
- setRetained(boolean) - Method in class io.micronaut.mqtt.v5.bind.MqttV5BindingContext
- setServerUri(String) - Method in class io.micronaut.mqtt.v3.config.MqttClientConfigurationProperties
- setServerUri(String) - Method in class io.micronaut.mqtt.v5.config.MqttClientConfigurationProperties
- setSocketFactory(SocketFactory) - Method in interface io.micronaut.mqtt.config.MqttSSLConfiguration
- setSocketFactory(SocketFactory) - Method in class io.micronaut.mqtt.v3.config.MqttClientConfigurationProperties
- setSocketFactory(SocketFactory) - Method in class io.micronaut.mqtt.v5.config.MqttClientConfigurationProperties
- setSSLHostnameVerifier(HostnameVerifier) - Method in interface io.micronaut.mqtt.config.MqttSSLConfiguration
- setSSLHostnameVerifier(HostnameVerifier) - Method in class io.micronaut.mqtt.v3.config.MqttClientConfigurationProperties
- setSSLHostnameVerifier(HostnameVerifier) - Method in class io.micronaut.mqtt.v5.config.MqttClientConfigurationProperties
- setSSLProperties(Properties) - Method in interface io.micronaut.mqtt.config.MqttSSLConfiguration
- setSSLProperties(Properties) - Method in class io.micronaut.mqtt.v3.config.MqttClientConfigurationProperties
- setSSLProperties(Properties) - Method in class io.micronaut.mqtt.v5.config.MqttClientConfigurationProperties
- setTopic(String) - Method in interface io.micronaut.mqtt.bind.MqttBindingContext
-
Sets the message topic.
- setTopic(String) - Method in class io.micronaut.mqtt.hivemq.v3.bind.MqttV3BindingContext
- setTopic(String) - Method in class io.micronaut.mqtt.hivemq.v5.bind.MqttV5BindingContext
- setTopic(String) - Method in class io.micronaut.mqtt.v3.bind.MqttV3BindingContext
- setTopic(String) - Method in class io.micronaut.mqtt.v5.bind.MqttV5BindingContext
- setUserProperties(List<UserProperty>) - Method in class io.micronaut.mqtt.hivemq.bind.MqttMessage
-
Sets the MQTT user properties.
- subscribe(String[], int[], Consumer<MqttBindingContext<MqttMessage>>) - Method in interface io.micronaut.mqtt.hivemq.client.MqttClientAdapter
- subscribe(String[], int[], Consumer<MqttBindingContext<MqttMessage>>) - Method in class io.micronaut.mqtt.hivemq.intercept.MqttSubscriberAdvice
- subscribe(String[], int[], Consumer<MqttBindingContext<MqttMessage>>) - Method in class io.micronaut.mqtt.hivemq.v3.client.Mqtt3ClientAdapter
- subscribe(String[], int[], Consumer<MqttBindingContext<MqttMessage>>) - Method in class io.micronaut.mqtt.hivemq.v5.client.Mqtt5ClientAdapter
- subscribe(String[], int[], Consumer<MqttBindingContext<M>>) - Method in class io.micronaut.mqtt.intercept.AbstractMqttSubscriberAdvice
- subscribe(String[], int[], Consumer<MqttBindingContext<MqttMessage>>) - Method in class io.micronaut.mqtt.v3.intercept.MqttSubscriberAdvice
- subscribe(String[], int[], Consumer<MqttBindingContext<MqttMessage>>) - Method in class io.micronaut.mqtt.v5.intercept.MqttSubscriberAdvice
- supports(Argument<Object>) - Method in class io.micronaut.mqtt.serdes.JavaLangMqttPayloadSerDes
- supports(Argument<Object>) - Method in class io.micronaut.mqtt.serdes.JsonMqttPayloadSerDes
- supports(Argument<T>) - Method in interface io.micronaut.mqtt.serdes.MqttPayloadSerDes
-
Determines if this serdes supports the given type.
T
- Topic - Annotation Interface in io.micronaut.mqtt.annotation
-
Used for binding the message topic and other parameters.
- TopicMqttBinder - Class in io.micronaut.mqtt.bind.impl
-
An annotated argument binder for
Topic
. - TopicMqttBinder(ConversionService) - Constructor for class io.micronaut.mqtt.bind.impl.TopicMqttBinder
- Topics - Annotation Interface in io.micronaut.mqtt.annotation
-
Used to supply multiple topics on subscriber methods.
- TrustManagerFactoryCreationException - Exception in io.micronaut.mqtt.hivemq.ssl
-
Thrown when a
TrustManagerFactory
can not be created. - TrustManagerFactoryCreationException(String, Exception) - Constructor for exception io.micronaut.mqtt.hivemq.ssl.TrustManagerFactoryCreationException
- TypedMqttBinder<M,
T> - Interface in io.micronaut.mqtt.bind -
Argument binder based on the type of the argument.
U
- unsubscribe(Set<String>) - Method in interface io.micronaut.mqtt.hivemq.client.MqttClientAdapter
- unsubscribe(Set<String>) - Method in class io.micronaut.mqtt.hivemq.intercept.MqttSubscriberAdvice
- unsubscribe(Set<String>) - Method in class io.micronaut.mqtt.hivemq.v3.client.Mqtt3ClientAdapter
- unsubscribe(Set<String>) - Method in class io.micronaut.mqtt.hivemq.v5.client.Mqtt5ClientAdapter
- unsubscribe(Set<String>) - Method in class io.micronaut.mqtt.intercept.AbstractMqttSubscriberAdvice
- unsubscribe(Set<String>) - Method in class io.micronaut.mqtt.v3.intercept.MqttSubscriberAdvice
- unsubscribe(Set<String>) - Method in class io.micronaut.mqtt.v5.intercept.MqttSubscriberAdvice
- UserProperty - Class in io.micronaut.mqtt.hivemq.bind
-
Represents a MQTT v5 property.
- UserProperty(String, String) - Constructor for class io.micronaut.mqtt.hivemq.bind.UserProperty
V
- value() - Element in annotation interface io.micronaut.mqtt.annotation.Qos
- value() - Element in annotation interface io.micronaut.mqtt.annotation.Retained
- value() - Element in annotation interface io.micronaut.mqtt.annotation.Topic
- value() - Element in annotation interface io.micronaut.mqtt.annotation.Topics
- value() - Element in annotation interface io.micronaut.mqtt.annotation.v3.MqttPublisher
- value() - Element in annotation interface io.micronaut.mqtt.annotation.v5.MqttProperties
- value() - Element in annotation interface io.micronaut.mqtt.annotation.v5.MqttProperty
-
If used as a bound parameter, this is the property name.
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form