B C D F G H I J N O P R S T

B

bind(ArgumentConversionContext<Object>, Message) - Method in class io.micronaut.nats.bind.NatsBodyBinder

bind(ArgumentConversionContext<Object>, Message) - Method in class io.micronaut.nats.bind.NatsDefaultBinder

C

close() - Method in class io.micronaut.nats.intercept.NatsConsumerAdvice

ClusterNatsConnectionFactoryConfig - Class in io.micronaut.nats.connect

Allows configuration of multiple nats connections.

ClusterNatsConnectionFactoryConfig(String) - Constructor for class io.micronaut.nats.connect.ClusterNatsConnectionFactoryConfig

Default constructor.

ClusterNatsConnectionFactoryConfig.DefaultTlsConfiguration - Class in io.micronaut.nats.connect

ConsumerExecutorServiceConfig - Class in io.micronaut.nats.executor

Configures a ScheduledExecutorService for running NatsListener instances.

ConsumerExecutorServiceConfig() - Constructor for class io.micronaut.nats.executor.ConsumerExecutorServiceConfig

D

DEFAULT_CONNECTION - Static variable in annotation type io.micronaut.nats.annotation.NatsConnection

DEFAULT_NAME - Static variable in class io.micronaut.nats.connect.SingleNatsConnectionFactoryConfig

DefaultNatsListenerExceptionHandler - Class in io.micronaut.nats.exception

The default ExceptionHandler used when a NatsListener fails to process Nats message.

DefaultNatsListenerExceptionHandler() - Constructor for class io.micronaut.nats.exception.DefaultNatsListenerExceptionHandler

DefaultNatsMessageSerDesRegistry - Class in io.micronaut.nats.serdes

Default implementation of NatsMessageSerDesRegistry.

DefaultNatsMessageSerDesRegistry(NatsMessageSerDes<?>...) - Constructor for class io.micronaut.nats.serdes.DefaultNatsMessageSerDesRegistry

Default constructor.

DefaultTlsConfiguration() - Constructor for class io.micronaut.nats.connect.ClusterNatsConnectionFactoryConfig.DefaultTlsConfiguration

DefaultTlsConfiguration() - Constructor for class io.micronaut.nats.connect.SingleNatsConnectionFactoryConfig.DefaultTlsConfiguration

deserialize(Message, Argument<Object>) - Method in class io.micronaut.nats.serdes.JavaLangNatsMessageSerDes

deserialize(Message, Argument<Object>) - Method in class io.micronaut.nats.serdes.JsonNatsMessageSerDes

deserialize(Message, Argument<T>) - Method in interface io.micronaut.nats.serdes.NatsMessageSerDes

Deserializes the message into the requested type.

F

findArgumentBinder(Argument<T>, Message) - Method in class io.micronaut.nats.bind.NatsBinderRegistry

findSerdes(Argument<T>) - Method in class io.micronaut.nats.serdes.DefaultNatsMessageSerDesRegistry

findSerDes(Argument<?>) - Method in class io.micronaut.nats.serdes.JavaLangNatsMessageSerDes

Finds the correct serDes based on the type.

findSerdes(Argument<T>) - Method in interface io.micronaut.nats.serdes.NatsMessageSerDesRegistry

Returns the serdes that supports the given type.

G

getAddresses() - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig

getAnnotationType() - Method in class io.micronaut.nats.bind.NatsBodyBinder

getBody() - Method in class io.micronaut.nats.reactive.PublishState

getBooleanSerDes() - Method in class io.micronaut.nats.serdes.JavaLangNatsMessageSerDes

getByteArraySerDes() - Method in class io.micronaut.nats.serdes.JavaLangNatsMessageSerDes

getByteBufferSerDes() - Method in class io.micronaut.nats.serdes.JavaLangNatsMessageSerDes

getCertificatePath() - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig.TLS

getConnectionTimeout() - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig

getCredentials() - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig

getDoubleSerDes() - Method in class io.micronaut.nats.serdes.JavaLangNatsMessageSerDes

getFloatSerDes() - Method in class io.micronaut.nats.serdes.JavaLangNatsMessageSerDes

getHealthInformation() - Method in class io.micronaut.nats.health.NatsHealthIndicator

getInboxPrefix() - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig

getIntegerSerDes() - Method in class io.micronaut.nats.serdes.JavaLangNatsMessageSerDes

getListener() - Method in exception io.micronaut.nats.exception.NatsListenerException

getLongSerDes() - Method in class io.micronaut.nats.serdes.JavaLangNatsMessageSerDes

getMaxReconnect() - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig

getMessageState() - Method in exception io.micronaut.nats.exception.NatsListenerException

getName() - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig

getName() - Method in class io.micronaut.nats.health.NatsHealthIndicator

getOrder() - Method in class io.micronaut.nats.serdes.JavaLangNatsMessageSerDes

getOrder() - Method in class io.micronaut.nats.serdes.JsonNatsMessageSerDes

getPassword() - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig

getPingInterval() - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig

getReconnectBufferSize() - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig

getReconnectWait() - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig

getShortSerDes() - Method in class io.micronaut.nats.serdes.JavaLangNatsMessageSerDes

getStringSerDes() - Method in class io.micronaut.nats.serdes.JavaLangNatsMessageSerDes

getSubject() - Method in class io.micronaut.nats.reactive.PublishState

getToken() - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig

getTrustStorePassword() - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig.TLS

getTrustStorePath() - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig.TLS

getTrustStoreType() - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig.TLS

getUsername() - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig

getUUIDSerDes() - Method in class io.micronaut.nats.serdes.JavaLangNatsMessageSerDes

H

handle(NatsListenerException) - Method in class io.micronaut.nats.exception.DefaultNatsListenerExceptionHandler

I

intercept(MethodInvocationContext<Object, Object>) - Method in class io.micronaut.nats.intercept.NatsIntroductionAdvice

io.micronaut.nats.annotation - package io.micronaut.nats.annotation

Annotations for creating Nats consumers and producers.

io.micronaut.nats.bind - package io.micronaut.nats.bind

Classes for binding Nats messages to consumer methods.

io.micronaut.nats.connect - package io.micronaut.nats.connect

Classes handling the connection to nats.

io.micronaut.nats.exception - package io.micronaut.nats.exception

Nats specific exceptions.

io.micronaut.nats.executor - package io.micronaut.nats.executor

Classes related to configuring the thread pool to run nats consumers and producers.

io.micronaut.nats.health - package io.micronaut.nats.health

Classes related to performing health checks for nats.

io.micronaut.nats.intercept - package io.micronaut.nats.intercept

Contains the implementation of the Around advices for Nats consumer and producer methods.

io.micronaut.nats.reactive - package io.micronaut.nats.reactive

io.micronaut.nats.serdes - package io.micronaut.nats.serdes

Classes for serializing and deserializing Nats message bodies.

isNoEcho() - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig

isUtf8Support() - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig

J

JavaLangNatsMessageSerDes - Class in io.micronaut.nats.serdes

Serializes and deserializes standard Java types.

JavaLangNatsMessageSerDes() - Constructor for class io.micronaut.nats.serdes.JavaLangNatsMessageSerDes

Default constructor.

javaSerDes - Variable in class io.micronaut.nats.serdes.JavaLangNatsMessageSerDes

JsonNatsMessageSerDes - Class in io.micronaut.nats.serdes

Serializes and deserializes objects as JSON using Jackson.

JsonNatsMessageSerDes(ObjectMapper) - Constructor for class io.micronaut.nats.serdes.JsonNatsMessageSerDes

Default constructor.

N

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

Used to determine which NatsArgumentBinder to use for any given argument.

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 Body 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<PublishState>) - 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<PublishState>) - 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.

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) - 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.

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

Interface that NatsListenerException beans can implement to handle exceptions.

NatsMessageSerDes<T> - Interface in io.micronaut.nats.serdes

Responsible for serializing and deserializing Nats message bodies.

NatsMessageSerDesRegistry - Interface in io.micronaut.nats.serdes

A registry of NatsMessageSerDes instances.

O

ORDER - Static variable in class io.micronaut.nats.serdes.JavaLangNatsMessageSerDes

The order of this serDes.

ORDER - Static variable in class io.micronaut.nats.serdes.JsonNatsMessageSerDes

The order of this serDes.

P

PREFIX - Static variable in class io.micronaut.nats.connect.ClusterNatsConnectionFactoryConfig

process(BeanDefinition<?>, ExecutableMethod<?, ?>) - Method in class io.micronaut.nats.intercept.NatsConsumerAdvice

publish(PublishState) - Method in interface io.micronaut.nats.reactive.ReactivePublisher

Publish the message with the provided arguments and return a reactive type that completes successfully when the message is published.

publish(PublishState) - Method in class io.micronaut.nats.reactive.RxJavaReactivePublisher

publishAndReply(PublishState) - Method in interface io.micronaut.nats.reactive.ReactivePublisher

Publish the message with the provided arguments and return a reactive type that completes successfully when the reply is received from the reply to queue.

publishAndReply(PublishState) - Method in class io.micronaut.nats.reactive.RxJavaReactivePublisher

PublishState - Class in io.micronaut.nats.reactive

Stores the state of a Nats message to be published.

PublishState(String, byte[]) - Constructor for class io.micronaut.nats.reactive.PublishState

Default constructor.

R

ReactivePublisher - Interface in io.micronaut.nats.reactive

A generic contract publishing message reactively.

RxJavaReactivePublisher - Class in io.micronaut.nats.reactive

RxJavaReactivePublisher(Connection) - Constructor for class io.micronaut.nats.reactive.RxJavaReactivePublisher

Constructor.

S

serialize(Object) - Method in class io.micronaut.nats.serdes.JavaLangNatsMessageSerDes

serialize(Object) - Method in class io.micronaut.nats.serdes.JsonNatsMessageSerDes

serialize(T) - Method in interface io.micronaut.nats.serdes.NatsMessageSerDes

Serializes the data into a byte[] to be published to nats.

setAddresses(List<String>) - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig

setCertificatePath(String) - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig.TLS

setConnectionTimeout(Duration) - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig

setCredentials(String) - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig

setInboxPrefix(String) - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig

setMaxReconnect(int) - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig

setNoEcho(boolean) - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig

setPassword(String) - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig

setPingInterval(Duration) - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig

setReconnectBufferSize(long) - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig

setReconnectWait(Duration) - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig

setTls(ClusterNatsConnectionFactoryConfig.DefaultTlsConfiguration) - Method in class io.micronaut.nats.connect.ClusterNatsConnectionFactoryConfig

Sets the tls configuration.

setTls(NatsConnectionFactoryConfig.TLS) - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig

setTls(SingleNatsConnectionFactoryConfig.DefaultTlsConfiguration) - Method in class io.micronaut.nats.connect.SingleNatsConnectionFactoryConfig

Sets the tls configuration.

setToken(String) - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig

setTrustStorePassword(String) - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig.TLS

setTrustStorePath(String) - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig.TLS

setTrustStoreType(String) - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig.TLS

setUsername(String) - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig

setUtf8Support(boolean) - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig

SingleNatsConnectionFactoryConfig - Class in io.micronaut.nats.connect

The default Nats configuration class.

SingleNatsConnectionFactoryConfig() - Constructor for class io.micronaut.nats.connect.SingleNatsConnectionFactoryConfig

Default constructor.

SingleNatsConnectionFactoryConfig.DefaultTlsConfiguration - Class in io.micronaut.nats.connect

Subject - Annotation Type in io.micronaut.nats.annotation

Used to specify which subject should be used for messages.

supports(Argument<Object>) - Method in class io.micronaut.nats.serdes.JavaLangNatsMessageSerDes

supports(Argument<Object>) - Method in class io.micronaut.nats.serdes.JsonNatsMessageSerDes

supports(Argument<T>) - Method in interface io.micronaut.nats.serdes.NatsMessageSerDes

Determines if this serdes supports the given type.

T

TLS() - Constructor for class io.micronaut.nats.connect.NatsConnectionFactoryConfig.TLS

toOptionsBuilder() - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig

B C D F G H I J N O P R S T