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