Index

A B C D F G H I J K M N O P Q R S T V 
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

A

AbstractIntroductionAdvice - Class in io.micronaut.nats.intercept
Abstract Implementation for nats introduction advices.
AbstractIntroductionAdvice(BeanContext, ExecutorService, ConversionService, NatsMessageSerDesRegistry) - Constructor for class io.micronaut.nats.intercept.AbstractIntroductionAdvice
Default constructor.
AcknowledgementBinder<T extends io.micronaut.messaging.Acknowledgement> - Class in io.micronaut.nats.jetstream.bind
Binds an argument of type Acknowledgement from the Message.
AcknowledgementBinder() - Constructor for class io.micronaut.nats.jetstream.bind.AcknowledgementBinder
 
ackPolicy() - Element in annotation interface io.micronaut.nats.jetstream.annotation.PushConsumer
 
ackWait() - Element in annotation interface io.micronaut.nats.jetstream.annotation.PushConsumer
 
argumentType() - Method in class io.micronaut.nats.bind.NatsConnectionBinder
 
argumentType() - Method in class io.micronaut.nats.bind.NatsHeadersBinder
 
argumentType() - Method in class io.micronaut.nats.bind.NatsMessageBinder
 
argumentType() - Method in class io.micronaut.nats.bind.NatsSubscriptionBinder
 
argumentType() - Method in class io.micronaut.nats.jetstream.bind.AcknowledgementBinder
 
argumentType() - Method in class io.micronaut.nats.jetstream.bind.NatsAcknowledgementBinder
 

B

backoff() - Element in annotation interface io.micronaut.nats.jetstream.annotation.PushConsumer
 
beanContext - Variable in class io.micronaut.nats.intercept.AbstractIntroductionAdvice
 
bind(ArgumentConversionContext<Connection>, Message) - Method in class io.micronaut.nats.bind.NatsConnectionBinder
 
bind(ArgumentConversionContext<Headers>, Message) - Method in class io.micronaut.nats.bind.NatsHeadersBinder
 
bind(ArgumentConversionContext<Message>, Message) - Method in class io.micronaut.nats.bind.NatsMessageBinder
 
bind(ArgumentConversionContext<Subscription>, Message) - Method in class io.micronaut.nats.bind.NatsSubscriptionBinder
 
bind(ArgumentConversionContext<Object>, Message) - Method in class io.micronaut.nats.bind.NatsBodyBinder
 
bind(ArgumentConversionContext<Object>, Message) - Method in class io.micronaut.nats.bind.NatsDefaultBinder
 
bind(ArgumentConversionContext<Object>, Message) - Method in class io.micronaut.nats.bind.NatsHeaderBinder
 
bind(ArgumentConversionContext<T>, Message) - Method in class io.micronaut.nats.jetstream.bind.AcknowledgementBinder
 
bucket() - Element in annotation interface io.micronaut.nats.jetstream.annotation.KeyValueStore
This is an alias for value.
bucket() - Element in annotation interface io.micronaut.nats.jetstream.annotation.ObjectStore
This is an alias for value.
buildNatsMessage(MethodInvocationContext<Object, Object>, Headers, Argument<?>, NatsMessageSerDes<Object>, Optional<String>) - Method in class io.micronaut.nats.intercept.AbstractIntroductionAdvice
build the nats message to send.
buildPublisherState(ExecutableMethod<?, ?>) - Method in class io.micronaut.nats.intercept.AbstractIntroductionAdvice
builds the cacheable publisher state.

C

clientId() - Element in annotation interface io.micronaut.nats.annotation.NatsListener
Sets the client id of the Nats consumer.
clientId() - Element in annotation interface io.micronaut.nats.jetstream.annotation.JetStreamListener
Sets the client id of the Nats consumer.
close() - Method in class io.micronaut.nats.intercept.NatsConsumerAdvice
 
close() - Method in class io.micronaut.nats.intercept.StaticConsumerState
 
close() - Method in class io.micronaut.nats.jetstream.intercept.JetStreamPushConsumerAdvice
 
connection() - Element in annotation interface io.micronaut.nats.annotation.NatsClient
 
connection() - Element in annotation interface io.micronaut.nats.annotation.NatsConnection
 
connection() - Element in annotation interface io.micronaut.nats.annotation.NatsListener
 
connection() - Element in annotation interface io.micronaut.nats.annotation.Subject
 
connection() - Element in annotation interface io.micronaut.nats.jetstream.annotation.JetStreamClient
 
connection() - Element in annotation interface io.micronaut.nats.jetstream.annotation.JetStreamListener
 
connection() - Element in annotation interface io.micronaut.nats.jetstream.annotation.KeyValueStore
The nats connection to use.
connection() - Element in annotation interface io.micronaut.nats.jetstream.annotation.ObjectStore
The nats connection to use.
connection() - Element in annotation interface io.micronaut.nats.jetstream.annotation.PushConsumer
 
ConsumerExecutorServiceConfig - Class in io.micronaut.nats.executor
Configures a ScheduledExecutorService for running NatsListener instances.
ConsumerExecutorServiceConfig() - Constructor for class io.micronaut.nats.executor.ConsumerExecutorServiceConfig
 
ConsumerRegistry - Interface in io.micronaut.nats
A registry for created Nats consumers.
conversionService - Variable in class io.micronaut.nats.intercept.AbstractIntroductionAdvice
 

D

DEFAULT_CONNECTION - Static variable in annotation interface io.micronaut.nats.annotation.NatsConnection
 
DefaultJetStreamListenerExceptionHandler - Class in io.micronaut.nats.jetstream.exception
The default ExceptionHandler used when a JetStreamListener fails to process Nats message.
DefaultJetStreamListenerExceptionHandler() - Constructor for class io.micronaut.nats.jetstream.exception.DefaultJetStreamListenerExceptionHandler
 
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.
deliverGroup() - Element in annotation interface io.micronaut.nats.jetstream.annotation.PushConsumer
 
deliverPolicy() - Element in annotation interface io.micronaut.nats.jetstream.annotation.PushConsumer
 
deliverSubject() - Element in annotation interface io.micronaut.nats.jetstream.annotation.PushConsumer
 
description() - Element in annotation interface io.micronaut.nats.jetstream.annotation.PushConsumer
 
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.
durable() - Element in annotation interface io.micronaut.nats.jetstream.annotation.PushConsumer
 

F

filterSubject() - Element in annotation interface io.micronaut.nats.jetstream.annotation.PushConsumer
 
findArgumentBinder(Argument<T>) - Method in class io.micronaut.nats.bind.NatsBinderRegistry
 
findSerdes(Argument<T>) - Method in class io.micronaut.nats.serdes.DefaultNatsMessageSerDesRegistry
 
findSerdes(Argument<T>) - Method in interface io.micronaut.nats.serdes.NatsMessageSerDesRegistry
Returns the serdes that supports the given type.
findSerDes(Argument<?>) - Method in class io.micronaut.nats.serdes.JavaLangNatsMessageSerDes
Finds the correct serDes based on the type.
flowControl() - Element in annotation interface io.micronaut.nats.jetstream.annotation.PushConsumer
 

G

get(CharSequence, ArgumentConversionContext<T>) - Method in class io.micronaut.nats.bind.NatsHeaderConvertibleValues
 
getAddresses() - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig
 
getAnnotationType() - Method in class io.micronaut.nats.bind.NatsBodyBinder
 
getAnnotationType() - Method in class io.micronaut.nats.bind.NatsHeaderBinder
 
getBodyArgument() - Method in class io.micronaut.nats.intercept.StaticPublisherState
 
getBooleanSerDes() - Method in class io.micronaut.nats.serdes.JavaLangNatsMessageSerDes
 
getBuilder() - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig.JetStreamConfiguration
get the jetstream options builder.
getBuilder() - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig.JetStreamConfiguration.KeyValueConfiguration
get the key value configuration builder.
getBuilder() - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig.JetStreamConfiguration.ObjectStoreConfiguration
get the object store configuration builder.
getBuilder() - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig.JetStreamConfiguration.StreamConfiguration
get the stream configuration builder.
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
 
getClientId() - Method in class io.micronaut.nats.intercept.StaticConsumerState
 
getConnection() - Method in class io.micronaut.nats.intercept.StaticConsumerState
 
getConnection() - Method in class io.micronaut.nats.intercept.StaticPublisherState
 
getConnectionTimeout() - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig
 
getConsumer(String) - Method in interface io.micronaut.nats.ConsumerRegistry
Returns the subscription by given id.
getConsumer(String) - Method in class io.micronaut.nats.intercept.NatsConsumerAdvice
 
getConsumerIds() - Method in interface io.micronaut.nats.ConsumerRegistry
The IDs of the available consumers.
getConsumerIds() - Method in class io.micronaut.nats.intercept.NatsConsumerAdvice
 
getConsumerSubscription(String) - Method in interface io.micronaut.nats.ConsumerRegistry
Returns a managed Consumer's subscriptions.
getConsumerSubscription(String) - Method in class io.micronaut.nats.intercept.NatsConsumerAdvice
 
getConversionErrors() - Method in class io.micronaut.nats.bind.NatsHeaderConvertibleValues
 
getCredentials() - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig
 
getDataType() - Method in class io.micronaut.nats.intercept.StaticPublisherState
 
getDispatcher() - Method in class io.micronaut.nats.intercept.StaticConsumerState
 
getDoubleSerDes() - Method in class io.micronaut.nats.serdes.JavaLangNatsMessageSerDes
 
getFloatSerDes() - Method in class io.micronaut.nats.serdes.JavaLangNatsMessageSerDes
 
getHeaders() - Method in class io.micronaut.nats.intercept.StaticPublisherState
 
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
 
getJetstream() - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig
get the optional jetstream configuration.
getKeyvalue() - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig.JetStreamConfiguration
get the key value configurations.
getListener() - Method in exception io.micronaut.nats.exception.NatsListenerException
 
getListener() - Method in exception io.micronaut.nats.jetstream.exception.JetStreamListenerException
 
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
 
getMessageState() - Method in exception io.micronaut.nats.jetstream.exception.JetStreamListenerException
 
getName() - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig
 
getName() - Method in class io.micronaut.nats.health.NatsHealthIndicator
 
getObjectstore() - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig.JetStreamConfiguration
get the object store configurations.
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
 
getReactivePublisher() - Method in class io.micronaut.nats.intercept.StaticPublisherState
 
getReconnectBufferSize() - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig
 
getReconnectWait() - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig
 
getSerDes() - Method in class io.micronaut.nats.intercept.StaticPublisherState
 
getShortSerDes() - Method in class io.micronaut.nats.serdes.JavaLangNatsMessageSerDes
 
getStreams() - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig.JetStreamConfiguration
get the stream configurations.
getStringSerDes() - Method in class io.micronaut.nats.serdes.JavaLangNatsMessageSerDes
 
getSubject() - Method in class io.micronaut.nats.intercept.StaticPublisherState
 
getSubjects() - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig.JetStreamConfiguration.StreamConfiguration
get the subjects of the stream.
getSubscriptions() - Method in class io.micronaut.nats.intercept.StaticConsumerState
 
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
 
handle(JetStreamListenerException) - Method in class io.micronaut.nats.jetstream.exception.DefaultJetStreamListenerExceptionHandler
 
handleResult(InterceptedMethod, Mono<?>) - Static method in class io.micronaut.nats.intercept.AbstractIntroductionAdvice
 
headersOnly() - Element in annotation interface io.micronaut.nats.jetstream.annotation.PushConsumer
 

I

idleHeartbeat() - Element in annotation interface io.micronaut.nats.jetstream.annotation.PushConsumer
 
intercept(MethodInvocationContext<Object, Object>) - Method in class io.micronaut.nats.intercept.NatsIntroductionAdvice
 
intercept(MethodInvocationContext<Object, Object>) - Method in class io.micronaut.nats.jetstream.intercept.JetStreamIntroductionAdvice
 
io.micronaut.nats - package io.micronaut.nats
Configuration for Nats.
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.jetstream - package io.micronaut.nats.jetstream
Configuration for Nats jetstream.
io.micronaut.nats.jetstream.annotation - package io.micronaut.nats.jetstream.annotation
Annotations for creating Jetstream consumers and producers.
io.micronaut.nats.jetstream.bind - package io.micronaut.nats.jetstream.bind
Classes for binding Nats messages to jetstream consumer methods.
io.micronaut.nats.jetstream.exception - package io.micronaut.nats.jetstream.exception
 
io.micronaut.nats.jetstream.intercept - package io.micronaut.nats.jetstream.intercept
Contains the implementation of the Around advices for JetStream consumer and producer methods.
io.micronaut.nats.jetstream.reactive - package io.micronaut.nats.jetstream.reactive
 
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.
isCreate() - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig.JetStreamConfiguration.ObjectStoreConfiguration
create object store during startup.
isCreateOrUpdate() - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig.JetStreamConfiguration.KeyValueConfiguration
create or update key/value store during startup.
isCreateOrUpdate() - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig.JetStreamConfiguration.StreamConfiguration
create or update stream during startup.
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
 
JetStreamClient - Annotation Interface in io.micronaut.nats.jetstream.annotation
An introduction advice that automatically implemnts interfaces and abstract classes and publishes jetstream messages.
JetStreamConfiguration() - Constructor for class io.micronaut.nats.connect.NatsConnectionFactoryConfig.JetStreamConfiguration
 
JetStreamFactory - Class in io.micronaut.nats.jetstream
JetStreamFactory.
JetStreamFactory(BeanContext) - Constructor for class io.micronaut.nats.jetstream.JetStreamFactory
 
JetStreamIntroductionAdvice - Class in io.micronaut.nats.jetstream.intercept
Implementation of the JetStreamClient advice annotation.
JetStreamIntroductionAdvice(BeanContext, ConversionService, NatsMessageSerDesRegistry, ExecutorService) - Constructor for class io.micronaut.nats.jetstream.intercept.JetStreamIntroductionAdvice
Default constructor.
JetStreamListener - Annotation Interface in io.micronaut.nats.jetstream.annotation
Class level annotation to indicate that a bean will be consumer of messages.
JetStreamListenerException - Exception in io.micronaut.nats.jetstream.exception
Exception thrown when an error occurs processing a Nats message via a JetStreamListener.
JetStreamListenerException(String, Object, Message) - Constructor for exception io.micronaut.nats.jetstream.exception.JetStreamListenerException
Creates a new exception.
JetStreamListenerException(String, Throwable, Object) - Constructor for exception io.micronaut.nats.jetstream.exception.JetStreamListenerException
Creates a new exception.
JetStreamListenerException(String, Throwable, Object, Message) - Constructor for exception io.micronaut.nats.jetstream.exception.JetStreamListenerException
Creates a new exception.
JetStreamListenerExceptionHandler - Interface in io.micronaut.nats.jetstream.exception
Interface that JetStreamListenerException beans can implement to handle exceptions.
JetStreamPushConsumerAdvice - Class in io.micronaut.nats.jetstream.intercept
An ExecutableMethodProcessor that will process all beans annotated with JetStreamListener.
JetStreamPushConsumerAdvice(BeanContext, NatsBinderRegistry, JetStreamListenerExceptionHandler, ApplicationConfiguration) - Constructor for class io.micronaut.nats.jetstream.intercept.JetStreamPushConsumerAdvice
Default constructor.
JsonNatsMessageSerDes - Class in io.micronaut.nats.serdes
Serializes and deserializes objects as JSON using Jackson.
JsonNatsMessageSerDes(JsonMapper) - Constructor for class io.micronaut.nats.serdes.JsonNatsMessageSerDes
Default constructor.

K

KeyValueConfiguration(String) - Constructor for class io.micronaut.nats.connect.NatsConnectionFactoryConfig.JetStreamConfiguration.KeyValueConfiguration
 
KeyValueFactory - Class in io.micronaut.nats.jetstream
KeyValueFactory.
KeyValueFactory(BeanContext) - Constructor for class io.micronaut.nats.jetstream.KeyValueFactory
 
KeyValueStore - Annotation Interface in io.micronaut.nats.jetstream.annotation
Used to specify which key value bucket should be used.

M

maxAckPending() - Element in annotation interface io.micronaut.nats.jetstream.annotation.PushConsumer
 
maxDeliver() - Element in annotation interface io.micronaut.nats.jetstream.annotation.PushConsumer
 

N

nackWithDelay(Duration) - Method in interface io.micronaut.nats.jetstream.bind.NatsAcknowledgement
nak acknowledges a JetStream message has been received but indicates that the message is not completely processed and should be sent again later, after at least the delay amount.
names() - Method in class io.micronaut.nats.bind.NatsHeaderConvertibleValues
 
NatsAcknowledgement - Interface in io.micronaut.nats.jetstream.bind
A contract for acknowleding or rejecting messages.
NatsAcknowledgementBinder - Class in io.micronaut.nats.jetstream.bind
Binds an argument type Message.
NatsAcknowledgementBinder() - Constructor for class io.micronaut.nats.jetstream.bind.NatsAcknowledgementBinder
 
NatsAnnotatedArgumentBinder<A extends 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 MessageBody annotation from the Message.
NatsBodyBinder(NatsMessageSerDesRegistry) - Constructor for class io.micronaut.nats.bind.NatsBodyBinder
Default constructor.
NatsClient - Annotation Interface 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, 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.
NatsClientException(String, List<Message>) - Constructor for exception io.micronaut.nats.exception.NatsClientException
Creates a new exception.
NatsConnection - Annotation Interface 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.JetStreamConfiguration - Class in io.micronaut.nats.connect
Manages the jetstream configuration.
NatsConnectionFactoryConfig.JetStreamConfiguration.KeyValueConfiguration - Class in io.micronaut.nats.connect
Manages a single key value configuration.
NatsConnectionFactoryConfig.JetStreamConfiguration.ObjectStoreConfiguration - Class in io.micronaut.nats.connect
Manages a single object store configuration.
NatsConnectionFactoryConfig.JetStreamConfiguration.StreamConfiguration - Class in io.micronaut.nats.connect
Manages a single stream configuration.
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 Interface 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.
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
A registry of NatsMessageSerDes instances.
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.
newPullConsumer(String, PullSubscribeOptions) - Method in class io.micronaut.nats.jetstream.PullConsumerRegistry
create a new pull consumer subscription for the default connection.
newPullConsumer(String, String, PullSubscribeOptions) - Method in class io.micronaut.nats.jetstream.PullConsumerRegistry
create a new pull consumer subscription for the default connection.
newSubscription(String, PushSubscribeOptions, String) - Method in interface io.micronaut.nats.jetstream.PushConsumerRegistry
Create a new push consumer with the default connection.
newSubscription(String, String, PushSubscribeOptions, String) - Method in interface io.micronaut.nats.jetstream.PushConsumerRegistry
Create a new push consumer from the given connection name.
newSubscription(String, String, String) - Method in interface io.micronaut.nats.ConsumerRegistry
Create a new subscription from the given connection name.
newSubscription(String, String, String) - Method in class io.micronaut.nats.intercept.NatsConsumerAdvice
 
newSubscription(String, String) - Method in interface io.micronaut.nats.ConsumerRegistry
Create a new subscription with the default connection.
newSubscription(String, String) - Method in class io.micronaut.nats.intercept.NatsConsumerAdvice
 
newSubscription(String, PushSubscribeOptions, String) - Method in class io.micronaut.nats.jetstream.intercept.JetStreamPushConsumerAdvice
 
newSubscription(String, String, PushSubscribeOptions, String) - Method in class io.micronaut.nats.jetstream.intercept.JetStreamPushConsumerAdvice
 

O

ObjectStore - Annotation Interface in io.micronaut.nats.jetstream.annotation
Used to specify which object store should be used.
ObjectStoreConfiguration(String) - Constructor for class io.micronaut.nats.connect.NatsConnectionFactoryConfig.JetStreamConfiguration.ObjectStoreConfiguration
 
ObjectStoreFactory - Class in io.micronaut.nats.jetstream
ObjectStoreFactory.
ObjectStoreFactory(BeanContext) - Constructor for class io.micronaut.nats.jetstream.ObjectStoreFactory
 
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.
ordered() - Element in annotation interface io.micronaut.nats.jetstream.annotation.PushConsumer
 

P

PREFIX - Static variable in class io.micronaut.nats.connect.NatsConnectionFactoryConfig
 
process(BeanDefinition<?>, ExecutableMethod<?, ?>) - Method in class io.micronaut.nats.intercept.NatsConsumerAdvice
 
process(BeanDefinition<?>, ExecutableMethod<?, ?>) - Method in class io.micronaut.nats.jetstream.intercept.JetStreamPushConsumerAdvice
 
publish(Message) - Method in interface io.micronaut.nats.jetstream.reactive.ReactivePublisher
Publish the message with the provided arguments and return a reactive type that completes successfully when the message is published.
publish(Message) - 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(Message) - Method in class io.micronaut.nats.reactive.ReactorReactivePublisher
 
publish(Message, PublishOptions) - Method in interface io.micronaut.nats.jetstream.reactive.ReactivePublisher
Publish the message with the provided arguments and return a reactive type that completes successfully when the message is published.
publishAndReply(Message) - 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(Message) - Method in class io.micronaut.nats.reactive.ReactorReactivePublisher
 
PullConsumerRegistry - Class in io.micronaut.nats.jetstream
handles new pull subscriptions.
PullConsumerRegistry(BeanContext) - Constructor for class io.micronaut.nats.jetstream.PullConsumerRegistry
 
PushConsumer - Annotation Interface in io.micronaut.nats.jetstream.annotation
Used to specify which stream should be used for messages.
PushConsumerRegistry - Interface in io.micronaut.nats.jetstream
A registry for jetstream push consumers.

Q

queue() - Element in annotation interface io.micronaut.nats.annotation.NatsListener
 
queue() - Element in annotation interface io.micronaut.nats.annotation.Subject
 
queue() - Element in annotation interface io.micronaut.nats.jetstream.annotation.JetStreamListener
 
queue() - Element in annotation interface io.micronaut.nats.jetstream.annotation.PushConsumer
 

R

rateLimit() - Element in annotation interface io.micronaut.nats.jetstream.annotation.PushConsumer
 
ReactivePublisher - Interface in io.micronaut.nats.jetstream.reactive
A generic contract publishing message reactively.
ReactivePublisher - Interface in io.micronaut.nats.reactive
A generic contract publishing message reactively.
ReactorReactivePublisher - Class in io.micronaut.nats.reactive
 
ReactorReactivePublisher(Connection) - Constructor for class io.micronaut.nats.reactive.ReactorReactivePublisher
Constructor.
replayPolicy() - Element in annotation interface io.micronaut.nats.jetstream.annotation.PushConsumer
 

S

sampleFrequency() - Element in annotation interface io.micronaut.nats.jetstream.annotation.PushConsumer
 
scheduler - Variable in class io.micronaut.nats.intercept.AbstractIntroductionAdvice
 
serDesRegistry - Variable in class io.micronaut.nats.intercept.AbstractIntroductionAdvice
 
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
 
setCreate(boolean) - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig.JetStreamConfiguration.ObjectStoreConfiguration
create store during startup.
setCreateOrUpdate(boolean) - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig.JetStreamConfiguration.KeyValueConfiguration
create or update key/value store during startup.
setCreateOrUpdate(boolean) - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig.JetStreamConfiguration.StreamConfiguration
create or update stream during startup.
setCredentials(String) - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig
 
setInboxPrefix(String) - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig
 
setJetstream(NatsConnectionFactoryConfig.JetStreamConfiguration) - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig
 
setKeyvalue(List<NatsConnectionFactoryConfig.JetStreamConfiguration.KeyValueConfiguration>) - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig.JetStreamConfiguration
set the keyvalue configurations.
setMaxReconnect(int) - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig
 
setNoEcho(boolean) - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig
 
setObjectstore(List<NatsConnectionFactoryConfig.JetStreamConfiguration.ObjectStoreConfiguration>) - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig.JetStreamConfiguration
set the object store configurations.
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
 
setStreams(List<NatsConnectionFactoryConfig.JetStreamConfiguration.StreamConfiguration>) - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig.JetStreamConfiguration
set the stream configurations for the jetstream.
setSubjects(List<String>) - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig.JetStreamConfiguration.StreamConfiguration
set the subjects.
setTls(NatsConnectionFactoryConfig.TLS) - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig
 
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
 
startSequence() - Element in annotation interface io.micronaut.nats.jetstream.annotation.PushConsumer
 
StaticConsumerState - Class in io.micronaut.nats.intercept
Manages the consumer state for nats and jetstream.
StaticConsumerState(String, Set<Subscription>, Dispatcher, Connection) - Constructor for class io.micronaut.nats.intercept.StaticConsumerState
default constructor.
StaticPublisherState - Class in io.micronaut.nats.intercept
Stores the static state for publishing messages with NatsClient.
StaticPublisherState(StaticPublisherState) - Constructor for class io.micronaut.nats.intercept.StaticPublisherState
 
StaticPublisherState(String, Argument<?>, Headers, ReturnType<?>, String, NatsMessageSerDes<?>, ReactivePublisher) - Constructor for class io.micronaut.nats.intercept.StaticPublisherState
Default constructor.
StreamConfiguration(String) - Constructor for class io.micronaut.nats.connect.NatsConnectionFactoryConfig.JetStreamConfiguration.StreamConfiguration
 
subject() - Element in annotation interface io.micronaut.nats.jetstream.annotation.PushConsumer
 
Subject - Annotation Interface in io.micronaut.nats.annotation
Used to specify which subject should be used for messages.
Subjects - Annotation Interface in io.micronaut.nats.annotation
Repeatable annotation for one or many Subject annotations.
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
 
toJetStreamOptions() - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig.JetStreamConfiguration
return the configuration as JetStreamOptions.
toKeyValueConfiguration() - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig.JetStreamConfiguration.KeyValueConfiguration
return the configuration as KeyValueConfiguration.
toObjectStoreConfiguration() - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig.JetStreamConfiguration.ObjectStoreConfiguration
return the configuration as ObjectStoreConfiguration.
toOptionsBuilder() - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig
 
toStreamConfiguration() - Method in class io.micronaut.nats.connect.NatsConnectionFactoryConfig.JetStreamConfiguration.StreamConfiguration
return the configuration as StreamConfiguration.

V

value() - Element in annotation interface io.micronaut.nats.annotation.Subject
 
value() - Element in annotation interface io.micronaut.nats.annotation.Subjects
 
value() - Element in annotation interface io.micronaut.nats.jetstream.annotation.KeyValueStore
The name of the key value store/bucket.
value() - Element in annotation interface io.micronaut.nats.jetstream.annotation.ObjectStore
The name of the object store/bucket.
value() - Element in annotation interface io.micronaut.nats.jetstream.annotation.PushConsumer
 
values() - Method in class io.micronaut.nats.bind.NatsHeaderConvertibleValues
 
A B C D F G H I J K M N O P Q R S T V 
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form