- names() - Method in class io.micronaut.nats.bind.NatsHeaderConvertibleValues
-
- NatsAnnotatedArgumentBinder<A extends java.lang.annotation.Annotation> - Interface in io.micronaut.nats.bind
-
An interface for nats argument binding based on an annotation.
- NatsArgumentBinder<T> - Interface in io.micronaut.nats.bind
-
An interface for Nats argument binding.
- NatsBinderRegistry - Class in io.micronaut.nats.bind
-
- NatsBinderRegistry(NatsDefaultBinder, NatsArgumentBinder...) - Constructor for class io.micronaut.nats.bind.NatsBinderRegistry
-
Default constructor.
- NatsBodyBinder - Class in io.micronaut.nats.bind
-
Binds an argument of with the MessageBody
annotation from the Message
.
- NatsBodyBinder(NatsMessageSerDesRegistry) - Constructor for class io.micronaut.nats.bind.NatsBodyBinder
-
Default constructor.
- NatsClient - Annotation Type in io.micronaut.nats.annotation
-
An introduction advice that automatically implemnts interfaces and abstract classes and publishes nats messages.
- NatsClientException - Exception in io.micronaut.nats.exception
-
Exception thrown when an error occurs publishing a Nats message.
- NatsClientException(String) - Constructor for exception io.micronaut.nats.exception.NatsClientException
-
Creates a new exception.
- NatsClientException(String, List<Message>) - Constructor for exception io.micronaut.nats.exception.NatsClientException
-
Creates a new exception.
- NatsClientException(String, Throwable) - Constructor for exception io.micronaut.nats.exception.NatsClientException
-
Creates a new exception.
- NatsClientException(String, Throwable, List<Message>) - Constructor for exception io.micronaut.nats.exception.NatsClientException
-
Creates a new exception.
- NatsConnection - Annotation Type in io.micronaut.nats.annotation
-
Stores the options surrounding a Nats connection.
- NatsConnectionBinder - Class in io.micronaut.nats.bind
-
Binds an argument type Message
.
- NatsConnectionBinder() - Constructor for class io.micronaut.nats.bind.NatsConnectionBinder
-
- NatsConnectionFactory - Class in io.micronaut.nats.connect
-
A factory for creating a connection to nats.
- NatsConnectionFactory() - Constructor for class io.micronaut.nats.connect.NatsConnectionFactory
-
- NatsConnectionFactoryConfig - Class in io.micronaut.nats.connect
-
Base class for nats to be configured.
- NatsConnectionFactoryConfig(String) - Constructor for class io.micronaut.nats.connect.NatsConnectionFactoryConfig
-
Default constructor.
- NatsConnectionFactoryConfig.TLS - Class in io.micronaut.nats.connect
-
TLS Configuration.
- NatsConsumerAdvice - Class in io.micronaut.nats.intercept
-
An
ExecutableMethodProcessor
that will process all beans annotated with
NatsListener
.
- NatsConsumerAdvice(BeanContext, NatsBinderRegistry, NatsMessageSerDesRegistry, NatsListenerExceptionHandler, ApplicationConfiguration) - Constructor for class io.micronaut.nats.intercept.NatsConsumerAdvice
-
Default constructor.
- NatsDefaultBinder - Class in io.micronaut.nats.bind
-
The default binder for binding an argument from the Message
that is used if no other binder supports the argument.
- NatsDefaultBinder(NatsBodyBinder) - Constructor for class io.micronaut.nats.bind.NatsDefaultBinder
-
Default constructor.
- NatsHeaderBinder - Class in io.micronaut.nats.bind
-
Binds an argument of with the MessageHeader
annotation from the Message
.
- NatsHeaderBinder(ConversionService<?>) - Constructor for class io.micronaut.nats.bind.NatsHeaderBinder
-
Default constructor.
- NatsHeaderConvertibleValues - Class in io.micronaut.nats.bind
-
Converts Nats header values to the requested type.
- NatsHeaderConvertibleValues(Headers, ConversionService<?>) - Constructor for class io.micronaut.nats.bind.NatsHeaderConvertibleValues
-
Default constructor.
- NatsHeadersBinder - Class in io.micronaut.nats.bind
-
Binds an argument of type Headers
from the Message
.
- NatsHeadersBinder() - Constructor for class io.micronaut.nats.bind.NatsHeadersBinder
-
- NatsHealthIndicator - Class in io.micronaut.nats.health
-
A HealthIndicator
for Nats.
- NatsHealthIndicator(Connection) - Constructor for class io.micronaut.nats.health.NatsHealthIndicator
-
Default constructor.
- NatsIntroductionAdvice - Class in io.micronaut.nats.intercept
-
Implementation of the
NatsClient
advice annotation.
- NatsIntroductionAdvice(BeanContext, ConversionService<?>, NatsMessageSerDesRegistry, ExecutorService) - Constructor for class io.micronaut.nats.intercept.NatsIntroductionAdvice
-
Default constructor.
- NatsListener - Annotation Type in io.micronaut.nats.annotation
-
Class level annotation to indicate that a bean will be consumer of messages.
- NatsListenerException - Exception in io.micronaut.nats.exception
-
Exception thrown when an error occurs processing a Nats message via a
NatsListener
.
- NatsListenerException(String, Object, Message) - Constructor for exception io.micronaut.nats.exception.NatsListenerException
-
Creates a new exception.
- NatsListenerException(String, Throwable, Object, Message) - Constructor for exception io.micronaut.nats.exception.NatsListenerException
-
Creates a new exception.
- NatsListenerExceptionHandler - Interface in io.micronaut.nats.exception
-
- NatsMessageBinder - Class in io.micronaut.nats.bind
-
Binds an argument type Message
.
- NatsMessageBinder() - Constructor for class io.micronaut.nats.bind.NatsMessageBinder
-
- NatsMessageSerDes<T> - Interface in io.micronaut.nats.serdes
-
Responsible for serializing and deserializing Nats message bodies.
- NatsMessageSerDesRegistry - Interface in io.micronaut.nats.serdes
-
- NatsSubscriptionBinder - Class in io.micronaut.nats.bind
-
Binds an argument of type Subscription
from the Message
.
- NatsSubscriptionBinder() - Constructor for class io.micronaut.nats.bind.NatsSubscriptionBinder
-
- NatsTypeArgumentBinder<T> - Interface in io.micronaut.nats.bind
-
An interface for Nats argument binding based on argument type.
- newSubscription(String, String) - Method in interface io.micronaut.nats.ConsumerRegistry
-
Create a new subscription with the default connection.
- newSubscription(String, String, String) - Method in interface io.micronaut.nats.ConsumerRegistry
-
Create a new subscription from the given connection name.
- newSubscription(String, String) - Method in class io.micronaut.nats.intercept.NatsConsumerAdvice
-
- newSubscription(String, String, String) - Method in class io.micronaut.nats.intercept.NatsConsumerAdvice
-