- initialize(Channel) - Method in class io.micronaut.rabbitmq.connect.ChannelInitializer
-
- initialize(Channel, String) - Method in class io.micronaut.rabbitmq.connect.ChannelInitializer
-
Do any work with a channel.
- initializePublish(Channel) - Method in class io.micronaut.rabbitmq.reactive.ReactorReactivePublisher
-
Initializes the channel to allow publisher acknowledgements.
- intercept(MethodInvocationContext<Object, Object>) - Method in class io.micronaut.rabbitmq.intercept.RabbitMQIntroductionAdvice
-
- io.micronaut.rabbitmq.annotation - package io.micronaut.rabbitmq.annotation
-
Annotations for creating RabbitMQ consumers and producers.
- io.micronaut.rabbitmq.bind - package io.micronaut.rabbitmq.bind
-
Classes for binding RabbitMQ messages to consumer methods.
- io.micronaut.rabbitmq.connect - package io.micronaut.rabbitmq.connect
-
Classes handling the connection RabbitMQ.
- io.micronaut.rabbitmq.exception - package io.micronaut.rabbitmq.exception
-
RabbitMQ specific exceptions.
- io.micronaut.rabbitmq.executor - package io.micronaut.rabbitmq.executor
-
Classes related to configuring the thread pool to run RabbitMQ consumers.
- io.micronaut.rabbitmq.health - package io.micronaut.rabbitmq.health
-
Classes related to performing health checks for RabbitMQ.
- io.micronaut.rabbitmq.intercept - package io.micronaut.rabbitmq.intercept
-
Contains the implementations of the Around advices for
RabbitMQ consumer and producer methods.
- io.micronaut.rabbitmq.metrics - package io.micronaut.rabbitmq.metrics
-
Contains classes specific to capturing RabbitMQ metrics.
- io.micronaut.rabbitmq.reactive - package io.micronaut.rabbitmq.reactive
-
Contains classes specific to converting the RabbitMQ java client API to
a reactive API.
- io.micronaut.rabbitmq.serdes - package io.micronaut.rabbitmq.serdes
-
Classes for serializing and deserializing RabbitMQ message bodies.
- isTopologyRecoveryEnabled() - Method in interface io.micronaut.rabbitmq.connect.ChannelPool
-
Returns whether topology recovery
is enabled for the connection of this pool.
- isTopologyRecoveryEnabled() - Method in class io.micronaut.rabbitmq.connect.DefaultChannelPool
-
- RabbitAcknowledgement - Interface in io.micronaut.rabbitmq.bind
-
A contract for acknowledging or rejecting RabbitMQ messages.
- RabbitAcknowledgementBinder - Class in io.micronaut.rabbitmq.bind
-
- RabbitAcknowledgementBinder() - Constructor for class io.micronaut.rabbitmq.bind.RabbitAcknowledgementBinder
-
- RabbitAnnotatedArgumentBinder<A extends java.lang.annotation.Annotation> - Interface in io.micronaut.rabbitmq.bind
-
An interface for RabbitMQ argument binding based on an annotation.
- RabbitArgumentBinder<T> - Interface in io.micronaut.rabbitmq.bind
-
An interface for RabbitMQ argument binding.
- RabbitBasicPropertiesBinder - Class in io.micronaut.rabbitmq.bind
-
- RabbitBasicPropertiesBinder() - Constructor for class io.micronaut.rabbitmq.bind.RabbitBasicPropertiesBinder
-
- RabbitBinderRegistry - Class in io.micronaut.rabbitmq.bind
-
- RabbitBinderRegistry(RabbitDefaultBinder, RabbitArgumentBinder...) - Constructor for class io.micronaut.rabbitmq.bind.RabbitBinderRegistry
-
Default constructor.
- RabbitBodyBinder - Class in io.micronaut.rabbitmq.bind
-
- RabbitBodyBinder(RabbitMessageSerDesRegistry) - Constructor for class io.micronaut.rabbitmq.bind.RabbitBodyBinder
-
Default constructor.
- RabbitChannelBinder - Class in io.micronaut.rabbitmq.bind
-
- RabbitChannelBinder() - Constructor for class io.micronaut.rabbitmq.bind.RabbitChannelBinder
-
- RabbitClient - Annotation Type in io.micronaut.rabbitmq.annotation
-
An introduction advice that automatically implements interfaces and abstract classes and publishes RabbitMQ messages.
- RabbitClientException - Exception in io.micronaut.rabbitmq.exception
-
Exception thrown when an error occurs publishing a RabbitMQ message.
- RabbitClientException(String) - Constructor for exception io.micronaut.rabbitmq.exception.RabbitClientException
-
Creates a new exception.
- RabbitClientException(String, List<RabbitPublishState>) - Constructor for exception io.micronaut.rabbitmq.exception.RabbitClientException
-
Creates a new exception.
- RabbitClientException(String, Throwable) - Constructor for exception io.micronaut.rabbitmq.exception.RabbitClientException
-
Creates a new exception.
- RabbitClientException(String, Throwable, List<RabbitPublishState>) - Constructor for exception io.micronaut.rabbitmq.exception.RabbitClientException
-
Creates a new exception.
- RabbitConnection - Annotation Type in io.micronaut.rabbitmq.annotation
-
Stores options surrounding a RabbitMQ connection.
- RabbitConnectionFactory - Class in io.micronaut.rabbitmq.connect
-
A factory for creating a connection to RabbitMQ.
- RabbitConnectionFactory() - Constructor for class io.micronaut.rabbitmq.connect.RabbitConnectionFactory
-
- RabbitConnectionFactoryConfig - Class in io.micronaut.rabbitmq.connect
-
Base class for RabbitMQ to be configured.
- RabbitConnectionFactoryConfig(String) - Constructor for class io.micronaut.rabbitmq.connect.RabbitConnectionFactoryConfig
-
Default constructor.
- RabbitConnectionFactoryConfig.ChannelPoolConfiguration - Class in io.micronaut.rabbitmq.connect
-
Configuration for the channel pool.
- RabbitConnectionFactoryConfig.RpcConfiguration - Class in io.micronaut.rabbitmq.connect
-
Configuration for RPC.
- RabbitConsumerExecutorFactory - Class in io.micronaut.rabbitmq.executor
-
Configures a
ScheduledExecutorService for running
RabbitListener instances.
- RabbitConsumerExecutorFactory() - Constructor for class io.micronaut.rabbitmq.executor.RabbitConsumerExecutorFactory
-
- RabbitConsumerState - Class in io.micronaut.rabbitmq.bind
-
Stores the state of a RabbitMQ message to be consumed.
- RabbitConsumerState(Envelope, AMQP.BasicProperties, byte[], Channel) - Constructor for class io.micronaut.rabbitmq.bind.RabbitConsumerState
-
Default constructor.
- RabbitDefaultBinder - Class in io.micronaut.rabbitmq.bind
-
The default binder for binding an argument from the
RabbitConsumerState
that is used if no other binder supports the argument.
- RabbitDefaultBinder(RabbitPropertyBinder, RabbitBodyBinder) - Constructor for class io.micronaut.rabbitmq.bind.RabbitDefaultBinder
-
Default constructor.
- RabbitEnvelopeBinder - Class in io.micronaut.rabbitmq.bind
-
- RabbitEnvelopeBinder() - Constructor for class io.micronaut.rabbitmq.bind.RabbitEnvelopeBinder
-
- RabbitHeaderBinder - Class in io.micronaut.rabbitmq.bind
-
- RabbitHeaderBinder(ConversionService) - Constructor for class io.micronaut.rabbitmq.bind.RabbitHeaderBinder
-
Default constructor.
- RabbitHeaderConvertibleValues - Class in io.micronaut.rabbitmq.bind
-
Converts RabbitMQ header values to the requested type.
- RabbitHeaderConvertibleValues(Map<String, Object>, ConversionService<?>) - Constructor for class io.micronaut.rabbitmq.bind.RabbitHeaderConvertibleValues
-
Default constructor.
- RabbitHeaders - Annotation Type in io.micronaut.rabbitmq.annotation
-
Denotes a Map argument that should be used as a source
of message headers.
- RabbitHeadersBinder - Class in io.micronaut.rabbitmq.bind
-
- RabbitHeadersBinder(ConversionService<?>) - Constructor for class io.micronaut.rabbitmq.bind.RabbitHeadersBinder
-
Default constructor.
- RabbitListener - Annotation Type in io.micronaut.rabbitmq.annotation
-
Class level annotation to indicate that a bean will be consumers of messages
from RabbitMQ.
- RabbitListenerException - Exception in io.micronaut.rabbitmq.exception
-
Exception thrown when an error occurs processing a RabbitMQ message via a
RabbitListener.
- RabbitListenerException(String, Object, RabbitConsumerState) - Constructor for exception io.micronaut.rabbitmq.exception.RabbitListenerException
-
Creates a new exception.
- RabbitListenerException(String, Throwable, Object, RabbitConsumerState) - Constructor for exception io.micronaut.rabbitmq.exception.RabbitListenerException
-
Creates a new exception.
- RabbitListenerException(Throwable, Object, RabbitConsumerState) - Constructor for exception io.micronaut.rabbitmq.exception.RabbitListenerException
-
Creates a new exception.
- RabbitListenerExceptionHandler - Interface in io.micronaut.rabbitmq.exception
-
Interface that
RabbitListener beans can implement to handle exceptions.
- RabbitMessageCloseable - Class in io.micronaut.rabbitmq.bind
-
Responsible for acknowledging or rejecting a message.
- RabbitMessageCloseable(RabbitConsumerState, boolean, boolean) - Constructor for class io.micronaut.rabbitmq.bind.RabbitMessageCloseable
-
Default constructor.
- RabbitMessageSerDes<T> - Interface in io.micronaut.rabbitmq.serdes
-
Responsible for serializing and deserializing RabbitMQ message bodies.
- RabbitMessageSerDesRegistry - Interface in io.micronaut.rabbitmq.serdes
-
- RabbitMetricsInterceptor - Class in io.micronaut.rabbitmq.metrics
-
Interceptor of the connection factory to set the metrics collector.
- RabbitMetricsInterceptor(BeanProvider<MeterRegistry>, String, Map<String, String>) - Constructor for class io.micronaut.rabbitmq.metrics.RabbitMetricsInterceptor
-
Default constructor.
- RabbitMQConsumerAdvice - Class in io.micronaut.rabbitmq.intercept
-
An
ExecutableMethodProcessor that will process all beans annotated
with
RabbitListener and create and subscribe the relevant methods
as consumers to RabbitMQ queues.
- RabbitMQConsumerAdvice(BeanContext, RabbitBinderRegistry, RabbitListenerExceptionHandler, RabbitMessageSerDesRegistry, ConversionService<?>, List<ChannelPool>) - Constructor for class io.micronaut.rabbitmq.intercept.RabbitMQConsumerAdvice
-
Default constructor.
- RabbitMQHealthIndicator - Class in io.micronaut.rabbitmq.health
-
A HealthIndicator for RabbitMQ.
- RabbitMQHealthIndicator(Connection) - Constructor for class io.micronaut.rabbitmq.health.RabbitMQHealthIndicator
-
Default constructor.
- RabbitMQHealthIndicator(List<Connection>) - Constructor for class io.micronaut.rabbitmq.health.RabbitMQHealthIndicator
-
Default constructor.
- RabbitMQIntroductionAdvice - Class in io.micronaut.rabbitmq.intercept
-
- RabbitMQIntroductionAdvice(BeanContext, ConversionService<?>, RabbitMessageSerDesRegistry, ExecutorService) - Constructor for class io.micronaut.rabbitmq.intercept.RabbitMQIntroductionAdvice
-
Default constructor.
- RabbitProperties - Annotation Type in io.micronaut.rabbitmq.annotation
-
Annotation to collect a set of properties.
- RabbitProperty - Annotation Type in io.micronaut.rabbitmq.annotation
-
Used to set properties while publishing or bind to properties while consuming.
- RabbitPropertyBinder - Class in io.micronaut.rabbitmq.bind
-
- RabbitPropertyBinder(ConversionService) - Constructor for class io.micronaut.rabbitmq.bind.RabbitPropertyBinder
-
Default constructor.
- RabbitPublishState - Class in io.micronaut.rabbitmq.reactive
-
Stores the state of a RabbitMQ message to be published.
- RabbitPublishState(String, String, AMQP.BasicProperties, byte[]) - Constructor for class io.micronaut.rabbitmq.reactive.RabbitPublishState
-
Default constructor.
- RabbitTypeArgumentBinder<T> - Interface in io.micronaut.rabbitmq.bind
-
An interface for RabbitMQ argument binding based on argument type.
- ReactivePublisher - Interface in io.micronaut.rabbitmq.reactive
-
A generic contract for publishing RabbitMQ messages reactively.
- ReactorReactivePublisher - Class in io.micronaut.rabbitmq.reactive
-
A reactive publisher implementation that uses a single channel per publish
operation and returns a Reactor Mono.
- ReactorReactivePublisher(ChannelPool, RabbitConnectionFactoryConfig) - Constructor for class io.micronaut.rabbitmq.reactive.ReactorReactivePublisher
-
Default constructor.
- returnChannel(Channel) - Method in interface io.micronaut.rabbitmq.connect.ChannelPool
-
Returns a channel to the pool.
- returnChannel(Channel) - Method in class io.micronaut.rabbitmq.connect.DefaultChannelPool
-
- returnChannel(Channel) - Method in class io.micronaut.rabbitmq.reactive.ReactorReactivePublisher
-
Removes confirm listeners from the channel and returns the
channel to the pool.
- RpcConfiguration() - Constructor for class io.micronaut.rabbitmq.connect.RabbitConnectionFactoryConfig.RpcConfiguration
-