Index (rabbitmq-root 1.1.3 API)

A B C D F G H I J M N O P Q R S T V W

A

ack() - Method in interface io.micronaut.configuration.rabbitmq.bind.RabbitAcknowledgement
ack(boolean) - Method in interface io.micronaut.configuration.rabbitmq.bind.RabbitAcknowledgement: Acknowledges this message.
AcknowledgementBinder<T extends io.micronaut.messaging.Acknowledgement> - Class in io.micronaut.configuration.rabbitmq.bind: Binds an argument of type Acknowledgement from the RabbitConsumerState.
AcknowledgementBinder() - Constructor for class io.micronaut.configuration.rabbitmq.bind.AcknowledgementBinder
AddressTypeConverter - Class in io.micronaut.configuration.rabbitmq.connect: Converts a CharSequence to an Address.
AddressTypeConverter() - Constructor for class io.micronaut.configuration.rabbitmq.connect.AddressTypeConverter
argumentType() - Method in class io.micronaut.configuration.rabbitmq.bind.AcknowledgementBinder
argumentType() - Method in class io.micronaut.configuration.rabbitmq.bind.RabbitAcknowledgementBinder
argumentType() - Method in class io.micronaut.configuration.rabbitmq.bind.RabbitBasicPropertiesBinder
argumentType() - Method in class io.micronaut.configuration.rabbitmq.bind.RabbitChannelBinder
argumentType() - Method in class io.micronaut.configuration.rabbitmq.bind.RabbitEnvelopeBinder

B

bind(ArgumentConversionContext<T>, RabbitConsumerState) - Method in class io.micronaut.configuration.rabbitmq.bind.AcknowledgementBinder
bind(ArgumentConversionContext<BasicProperties>, RabbitConsumerState) - Method in class io.micronaut.configuration.rabbitmq.bind.RabbitBasicPropertiesBinder
bind(ArgumentConversionContext<Object>, RabbitConsumerState) - Method in class io.micronaut.configuration.rabbitmq.bind.RabbitBodyBinder
bind(ArgumentConversionContext<Channel>, RabbitConsumerState) - Method in class io.micronaut.configuration.rabbitmq.bind.RabbitChannelBinder
bind(ArgumentConversionContext<Object>, RabbitConsumerState) - Method in class io.micronaut.configuration.rabbitmq.bind.RabbitDefaultBinder: Checks if the argument name matches one of the BasicProperties.
bind(ArgumentConversionContext<Envelope>, RabbitConsumerState) - Method in class io.micronaut.configuration.rabbitmq.bind.RabbitEnvelopeBinder
bind(ArgumentConversionContext<Object>, RabbitConsumerState) - Method in class io.micronaut.configuration.rabbitmq.bind.RabbitHeaderBinder
bind(ArgumentConversionContext<Object>, RabbitConsumerState) - Method in class io.micronaut.configuration.rabbitmq.bind.RabbitPropertyBinder
Binding - Annotation Type in io.micronaut.configuration.rabbitmq.annotation: Used to specify which binding (routing key) messages should be sent to.
BrokerResponse - Enum in io.micronaut.configuration.rabbitmq.reactive: An enumeration to represent the three possible states of response from a broker.

C

ChannelInitializer - Class in io.micronaut.configuration.rabbitmq.connect: A base class to extend from to do initialization work with a channel before any consumers or producers are created.
ChannelInitializer() - Constructor for class io.micronaut.configuration.rabbitmq.connect.ChannelInitializer
ChannelPool - Interface in io.micronaut.configuration.rabbitmq.connect: A pool of Channels to allow for channels to be shared across threads but not at the same time.
ChannelPoolConfiguration() - Constructor for class io.micronaut.configuration.rabbitmq.connect.RabbitConnectionFactoryConfig.ChannelPoolConfiguration
close() - Method in class io.micronaut.configuration.rabbitmq.bind.RabbitMessageCloseable
close() - Method in class io.micronaut.configuration.rabbitmq.connect.DefaultChannelPool
close() - Method in class io.micronaut.configuration.rabbitmq.intercept.RabbitMQConsumerAdvice
ClusterRabbitConnectionFactoryConfig - Class in io.micronaut.configuration.rabbitmq.connect: Allows configuration of multiple RabbitMQ connections.
ClusterRabbitConnectionFactoryConfig(String) - Constructor for class io.micronaut.configuration.rabbitmq.connect.ClusterRabbitConnectionFactoryConfig: Default constructor.
ClusterRabbitConnectionFactoryConfig.DefaultChannelPoolConfiguration - Class in io.micronaut.configuration.rabbitmq.connect
ClusterRabbitConnectionFactoryConfig.DefaultRpcConfiguration - Class in io.micronaut.configuration.rabbitmq.connect
convert(CharSequence, Class<Address>, ConversionContext) - Method in class io.micronaut.configuration.rabbitmq.connect.AddressTypeConverter
createChannel() - Method in class io.micronaut.configuration.rabbitmq.connect.DefaultChannelPool: Creates a channel.
createConsumer(Channel, RabbitPublishState, String, SingleEmitter<RabbitConsumerState>) - Method in class io.micronaut.configuration.rabbitmq.reactive.RxJavaReactivePublisher: Listens for ack/nack from the broker.
createListener(Channel, CompletableEmitter, RabbitPublishState) - Method in class io.micronaut.configuration.rabbitmq.reactive.RxJavaReactivePublisher: Listens for ack/nack from the broker.

D

DEFAULT_CONNECTION - Static variable in annotation type io.micronaut.configuration.rabbitmq.annotation.RabbitConnection
DEFAULT_NAME - Static variable in class io.micronaut.configuration.rabbitmq.connect.SingleRabbitConnectionFactoryConfig
DEFAULT_TIMEOUT_SECONDS - Static variable in class io.micronaut.configuration.rabbitmq.connect.RabbitConnectionFactoryConfig.RpcConfiguration: The default timeout before cancelling an RPC call.
DefaultChannelPool - Class in io.micronaut.configuration.rabbitmq.connect: Default implementation of ChannelPool.
DefaultChannelPool(String, Connection, RabbitConnectionFactoryConfig) - Constructor for class io.micronaut.configuration.rabbitmq.connect.DefaultChannelPool: Default constructor.
DefaultChannelPoolConfiguration() - Constructor for class io.micronaut.configuration.rabbitmq.connect.ClusterRabbitConnectionFactoryConfig.DefaultChannelPoolConfiguration
DefaultChannelPoolConfiguration() - Constructor for class io.micronaut.configuration.rabbitmq.connect.SingleRabbitConnectionFactoryConfig.DefaultChannelPoolConfiguration
DefaultConsumer - Interface in io.micronaut.configuration.rabbitmq.intercept: A default Consumer that delegates cancelled or shutdown with a single method DefaultConsumer.handleTerminate(String).
DefaultRabbitListenerExceptionHandler - Class in io.micronaut.configuration.rabbitmq.exception: The default ExceptionHandler used when a RabbitListener fails to process a RabbitMQ message.
DefaultRabbitListenerExceptionHandler() - Constructor for class io.micronaut.configuration.rabbitmq.exception.DefaultRabbitListenerExceptionHandler
DefaultRabbitMessageSerDesRegistry - Class in io.micronaut.configuration.rabbitmq.serdes: Default implementation of RabbitMessageSerDesRegistry.
DefaultRabbitMessageSerDesRegistry(RabbitMessageSerDes<?>...) - Constructor for class io.micronaut.configuration.rabbitmq.serdes.DefaultRabbitMessageSerDesRegistry: Default constructor.
DefaultRpcConfiguration() - Constructor for class io.micronaut.configuration.rabbitmq.connect.ClusterRabbitConnectionFactoryConfig.DefaultRpcConfiguration
DefaultRpcConfiguration() - Constructor for class io.micronaut.configuration.rabbitmq.connect.SingleRabbitConnectionFactoryConfig.DefaultRpcConfiguration
deserialize(RabbitConsumerState, Argument<Object>) - Method in class io.micronaut.configuration.rabbitmq.serdes.JavaLangRabbitMessageSerDes
deserialize(RabbitConsumerState, Argument<Object>) - Method in class io.micronaut.configuration.rabbitmq.serdes.JsonRabbitMessageSerDes
deserialize(RabbitConsumerState, Argument<T>) - Method in interface io.micronaut.configuration.rabbitmq.serdes.RabbitMessageSerDes: Deserializes the message into the requested type.

F

findArgumentBinder(Argument<T>, RabbitConsumerState) - Method in class io.micronaut.configuration.rabbitmq.bind.RabbitBinderRegistry
findSerdes(Argument<T>) - Method in class io.micronaut.configuration.rabbitmq.serdes.DefaultRabbitMessageSerDesRegistry
findSerDes(Argument<?>) - Method in class io.micronaut.configuration.rabbitmq.serdes.JavaLangRabbitMessageSerDes: Finds the correct serDes based on the type.
findSerdes(Argument<T>) - Method in interface io.micronaut.configuration.rabbitmq.serdes.RabbitMessageSerDesRegistry: Returns the serdes that supports the given type.

G

get(CharSequence, ArgumentConversionContext<T>) - Method in class io.micronaut.configuration.rabbitmq.bind.RabbitHeaderConvertibleValues
getAddresses() - Method in class io.micronaut.configuration.rabbitmq.connect.RabbitConnectionFactoryConfig
getAnnotationType() - Method in class io.micronaut.configuration.rabbitmq.bind.RabbitBodyBinder
getAnnotationType() - Method in class io.micronaut.configuration.rabbitmq.bind.RabbitHeaderBinder
getAnnotationType() - Method in class io.micronaut.configuration.rabbitmq.bind.RabbitPropertyBinder
getAppId() - Method in class io.micronaut.configuration.rabbitmq.intercept.MutableBasicProperties
getBody() - Method in class io.micronaut.configuration.rabbitmq.bind.RabbitConsumerState
getBody() - Method in class io.micronaut.configuration.rabbitmq.reactive.RabbitPublishState
getBooleanSerDes() - Method in class io.micronaut.configuration.rabbitmq.serdes.JavaLangRabbitMessageSerDes
getByteArraySerDes() - Method in class io.micronaut.configuration.rabbitmq.serdes.JavaLangRabbitMessageSerDes
getByteBufferSerDes() - Method in class io.micronaut.configuration.rabbitmq.serdes.JavaLangRabbitMessageSerDes
getChannel() - Method in class io.micronaut.configuration.rabbitmq.bind.RabbitConsumerState: This channel is being used exclusively by the consumer that consumed this message.
getChannel() - Method in interface io.micronaut.configuration.rabbitmq.connect.ChannelPool: Retrieves a channel from the pool.
getChannel() - Method in class io.micronaut.configuration.rabbitmq.connect.DefaultChannelPool
getChannel(ChannelPool) - Method in class io.micronaut.configuration.rabbitmq.intercept.RabbitMQConsumerAdvice: Retrieves a channel to use for consuming messages.
getChannel() - Method in class io.micronaut.configuration.rabbitmq.reactive.RxJavaReactivePublisher: Creates a Single from a channel, emitting an error if the channel could not be retrieved.
getChannelPool() - Method in class io.micronaut.configuration.rabbitmq.connect.RabbitConnectionFactoryConfig
getClusterId() - Method in class io.micronaut.configuration.rabbitmq.intercept.MutableBasicProperties
getConsumerExecutor() - Method in class io.micronaut.configuration.rabbitmq.connect.RabbitConnectionFactoryConfig
getContentEncoding() - Method in class io.micronaut.configuration.rabbitmq.intercept.MutableBasicProperties
getContentType() - Method in class io.micronaut.configuration.rabbitmq.intercept.MutableBasicProperties
getConversionErrors() - Method in class io.micronaut.configuration.rabbitmq.bind.RabbitHeaderConvertibleValues
getCorrelationId() - Method in class io.micronaut.configuration.rabbitmq.intercept.MutableBasicProperties
getDeliveryMode() - Method in class io.micronaut.configuration.rabbitmq.intercept.MutableBasicProperties
getDoubleSerDes() - Method in class io.micronaut.configuration.rabbitmq.serdes.JavaLangRabbitMessageSerDes
getEnvelope() - Method in class io.micronaut.configuration.rabbitmq.bind.RabbitConsumerState
getExchange() - Method in class io.micronaut.configuration.rabbitmq.reactive.RabbitPublishState
getExpiration() - Method in class io.micronaut.configuration.rabbitmq.intercept.MutableBasicProperties
getFailures() - Method in exception io.micronaut.configuration.rabbitmq.exception.RabbitClientException
getFloatSerDes() - Method in class io.micronaut.configuration.rabbitmq.serdes.JavaLangRabbitMessageSerDes
getHeaders() - Method in class io.micronaut.configuration.rabbitmq.intercept.MutableBasicProperties
getHealthInformation() - Method in class io.micronaut.configuration.rabbitmq.health.RabbitMQHealthIndicator
getIntegerSerDes() - Method in class io.micronaut.configuration.rabbitmq.serdes.JavaLangRabbitMessageSerDes
getListener() - Method in exception io.micronaut.configuration.rabbitmq.exception.RabbitListenerException
getLongSerDes() - Method in class io.micronaut.configuration.rabbitmq.serdes.JavaLangRabbitMessageSerDes
getMaxIdleChannels() - Method in class io.micronaut.configuration.rabbitmq.connect.RabbitConnectionFactoryConfig.ChannelPoolConfiguration
getMessageId() - Method in class io.micronaut.configuration.rabbitmq.intercept.MutableBasicProperties
getMessageState() - Method in exception io.micronaut.configuration.rabbitmq.exception.RabbitListenerException
getName() - Method in class io.micronaut.configuration.rabbitmq.connect.DefaultChannelPool
getName() - Method in class io.micronaut.configuration.rabbitmq.connect.RabbitConnectionFactoryConfig
getName() - Method in class io.micronaut.configuration.rabbitmq.health.RabbitMQHealthIndicator
getOrder() - Method in class io.micronaut.configuration.rabbitmq.serdes.JavaLangRabbitMessageSerDes
getOrder() - Method in class io.micronaut.configuration.rabbitmq.serdes.JsonRabbitMessageSerDes
getPriority() - Method in class io.micronaut.configuration.rabbitmq.intercept.MutableBasicProperties
getProperties() - Method in class io.micronaut.configuration.rabbitmq.bind.RabbitConsumerState
getProperties() - Method in class io.micronaut.configuration.rabbitmq.reactive.RabbitPublishState
getReplyTo() - Method in class io.micronaut.configuration.rabbitmq.intercept.MutableBasicProperties
getRoutingKey() - Method in class io.micronaut.configuration.rabbitmq.reactive.RabbitPublishState
getRpc() - Method in class io.micronaut.configuration.rabbitmq.connect.RabbitConnectionFactoryConfig
getShortSerDes() - Method in class io.micronaut.configuration.rabbitmq.serdes.JavaLangRabbitMessageSerDes
getStringSerDes() - Method in class io.micronaut.configuration.rabbitmq.serdes.JavaLangRabbitMessageSerDes
getTimeout() - Method in class io.micronaut.configuration.rabbitmq.connect.RabbitConnectionFactoryConfig.RpcConfiguration
getTimestamp() - Method in class io.micronaut.configuration.rabbitmq.intercept.MutableBasicProperties
getType() - Method in class io.micronaut.configuration.rabbitmq.intercept.MutableBasicProperties
getUserId() - Method in class io.micronaut.configuration.rabbitmq.intercept.MutableBasicProperties
getUUIDSerDes() - Method in class io.micronaut.configuration.rabbitmq.serdes.JavaLangRabbitMessageSerDes

H

handle(RabbitListenerException) - Method in class io.micronaut.configuration.rabbitmq.exception.DefaultRabbitListenerExceptionHandler
handleCancel(String) - Method in interface io.micronaut.configuration.rabbitmq.intercept.DefaultConsumer
handleCancelOk(String) - Method in interface io.micronaut.configuration.rabbitmq.intercept.DefaultConsumer
handleConsumeOk(String) - Method in interface io.micronaut.configuration.rabbitmq.intercept.DefaultConsumer
handleRecoverOk(String) - Method in interface io.micronaut.configuration.rabbitmq.intercept.DefaultConsumer
handleShutdownSignal(String, ShutdownSignalException) - Method in interface io.micronaut.configuration.rabbitmq.intercept.DefaultConsumer
handleTerminate(String) - Method in interface io.micronaut.configuration.rabbitmq.intercept.DefaultConsumer: Called when a consumer is cancelled or shut down.

I

initialize(Channel) - Method in class io.micronaut.configuration.rabbitmq.connect.ChannelInitializer: Do any work with a channel.
initializePublish(Channel) - Method in class io.micronaut.configuration.rabbitmq.reactive.RxJavaReactivePublisher: Initializes the channel to allow publisher acknowledgements.
intercept(MethodInvocationContext<Object, Object>) - Method in class io.micronaut.configuration.rabbitmq.intercept.RabbitMQIntroductionAdvice
io.micronaut.configuration.rabbitmq.annotation - package io.micronaut.configuration.rabbitmq.annotation: Annotations for creating RabbitMQ consumers and producers.
io.micronaut.configuration.rabbitmq.bind - package io.micronaut.configuration.rabbitmq.bind: Classes for binding RabbitMQ messages to consumer methods.
io.micronaut.configuration.rabbitmq.connect - package io.micronaut.configuration.rabbitmq.connect: Classes handling the connection RabbitMQ.
io.micronaut.configuration.rabbitmq.exception - package io.micronaut.configuration.rabbitmq.exception: RabbitMQ specific exceptions.
io.micronaut.configuration.rabbitmq.executor - package io.micronaut.configuration.rabbitmq.executor: Classes related to configuring the thread pool to run RabbitMQ consumers.
io.micronaut.configuration.rabbitmq.health - package io.micronaut.configuration.rabbitmq.health: Classes related to performing health checks for RabbitMQ.
io.micronaut.configuration.rabbitmq.intercept - package io.micronaut.configuration.rabbitmq.intercept: Contains the implementations of the Around advices for RabbitMQ consumer and producer methods.
io.micronaut.configuration.rabbitmq.metrics - package io.micronaut.configuration.rabbitmq.metrics: Contains classes specific to capturing RabbitMQ metrics.
io.micronaut.configuration.rabbitmq.reactive - package io.micronaut.configuration.rabbitmq.reactive: Contains classes specific to converting the RabbitMQ java client API to a reactive API.
io.micronaut.configuration.rabbitmq.serdes - package io.micronaut.configuration.rabbitmq.serdes: Classes for serializing and deserializing RabbitMQ message bodies.

J

JavaLangRabbitMessageSerDes - Class in io.micronaut.configuration.rabbitmq.serdes: Serializes and deserializes standard Java types.
JavaLangRabbitMessageSerDes() - Constructor for class io.micronaut.configuration.rabbitmq.serdes.JavaLangRabbitMessageSerDes: Default constructor.
javaSerDes - Variable in class io.micronaut.configuration.rabbitmq.serdes.JavaLangRabbitMessageSerDes
JsonRabbitMessageSerDes - Class in io.micronaut.configuration.rabbitmq.serdes: Serializes and deserializes objects as JSON using Jackson.
JsonRabbitMessageSerDes(ObjectMapper) - Constructor for class io.micronaut.configuration.rabbitmq.serdes.JsonRabbitMessageSerDes: Default constructor.

M

MutableBasicProperties - Class in io.micronaut.configuration.rabbitmq.intercept: A class that stores the basic properties in a mutable state.
MutableBasicProperties() - Constructor for class io.micronaut.configuration.rabbitmq.intercept.MutableBasicProperties

N

nack() - Method in interface io.micronaut.configuration.rabbitmq.bind.RabbitAcknowledgement
nack(boolean, boolean) - Method in interface io.micronaut.configuration.rabbitmq.bind.RabbitAcknowledgement: Rejects this message.
names() - Method in class io.micronaut.configuration.rabbitmq.bind.RabbitHeaderConvertibleValues

O

onCreated(BeanCreatedEvent<ChannelPool>) - Method in class io.micronaut.configuration.rabbitmq.connect.ChannelInitializer
onCreated(BeanCreatedEvent<ConnectionFactory>) - Method in class io.micronaut.configuration.rabbitmq.metrics.RabbitMetricsInterceptor
ORDER - Static variable in class io.micronaut.configuration.rabbitmq.serdes.JavaLangRabbitMessageSerDes: The order of this serDes.
ORDER - Static variable in class io.micronaut.configuration.rabbitmq.serdes.JsonRabbitMessageSerDes: The order of this serDes.

P

PREFIX - Static variable in class io.micronaut.configuration.rabbitmq.connect.ClusterRabbitConnectionFactoryConfig
process(BeanDefinition<?>, ExecutableMethod<?, ?>) - Method in class io.micronaut.configuration.rabbitmq.intercept.RabbitMQConsumerAdvice
publish(RabbitPublishState) - Method in interface io.micronaut.configuration.rabbitmq.reactive.ReactivePublisher: Publish the message with the provided arguments and return a reactive type that completes successfully when the message is published.
publish(RabbitPublishState) - Method in class io.micronaut.configuration.rabbitmq.reactive.RxJavaReactivePublisher
publishAndConfirm(RabbitPublishState) - Method in interface io.micronaut.configuration.rabbitmq.reactive.ReactivePublisher: Publish the message with the provided arguments and return a reactive type that completes successfully when the broker acknowledged the message.
publishAndConfirm(RabbitPublishState) - Method in class io.micronaut.configuration.rabbitmq.reactive.RxJavaReactivePublisher
publishAndReply(RabbitPublishState) - Method in interface io.micronaut.configuration.rabbitmq.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(RabbitPublishState) - Method in class io.micronaut.configuration.rabbitmq.reactive.RxJavaReactivePublisher
publishInternal(Channel, RabbitPublishState) - Method in class io.micronaut.configuration.rabbitmq.reactive.RxJavaReactivePublisher: Publishes the message to the channel.
publishInternalNoConfirm(Channel, RabbitPublishState) - Method in class io.micronaut.configuration.rabbitmq.reactive.RxJavaReactivePublisher: Publishes the message to the channel.
publishRpcInternal(Channel, RabbitPublishState) - Method in class io.micronaut.configuration.rabbitmq.reactive.RxJavaReactivePublisher: Publishes the message to the channel.

Q

Queue - Annotation Type in io.micronaut.configuration.rabbitmq.annotation: Used to specify which queue messages should be consumed from.

R

RabbitAcknowledgement - Interface in io.micronaut.configuration.rabbitmq.bind: A contract for acknowledging or rejecting RabbitMQ messages.
RabbitAcknowledgementBinder - Class in io.micronaut.configuration.rabbitmq.bind: Binds an argument of type RabbitAcknowledgement from the RabbitConsumerState.
RabbitAcknowledgementBinder() - Constructor for class io.micronaut.configuration.rabbitmq.bind.RabbitAcknowledgementBinder
RabbitAnnotatedArgumentBinder<A extends Annotation> - Interface in io.micronaut.configuration.rabbitmq.bind: An interface for RabbitMQ argument binding based on an annotation.
RabbitArgumentBinder<T> - Interface in io.micronaut.configuration.rabbitmq.bind: An interface for RabbitMQ argument binding.
RabbitBasicPropertiesBinder - Class in io.micronaut.configuration.rabbitmq.bind: Binds an argument of type BasicProperties from the RabbitConsumerState.
RabbitBasicPropertiesBinder() - Constructor for class io.micronaut.configuration.rabbitmq.bind.RabbitBasicPropertiesBinder
RabbitBinderRegistry - Class in io.micronaut.configuration.rabbitmq.bind: Used to determine which RabbitArgumentBinder to use for any given argument.
RabbitBinderRegistry(RabbitDefaultBinder, RabbitArgumentBinder...) - Constructor for class io.micronaut.configuration.rabbitmq.bind.RabbitBinderRegistry: Default constructor.
RabbitBodyBinder - Class in io.micronaut.configuration.rabbitmq.bind: Binds an argument of with the Body annotation from the RabbitConsumerState.
RabbitBodyBinder(RabbitMessageSerDesRegistry) - Constructor for class io.micronaut.configuration.rabbitmq.bind.RabbitBodyBinder: Default constructor.
RabbitChannelBinder - Class in io.micronaut.configuration.rabbitmq.bind: Binds an argument of type Channel from the RabbitConsumerState.
RabbitChannelBinder() - Constructor for class io.micronaut.configuration.rabbitmq.bind.RabbitChannelBinder
RabbitClient - Annotation Type in io.micronaut.configuration.rabbitmq.annotation: An introduction advice that automatically implements interfaces and abstract classes and publishes RabbitMQ messages.
RabbitClientException - Exception in io.micronaut.configuration.rabbitmq.exception: Exception thrown when an error occurs publishing a RabbitMQ message.
RabbitClientException(String) - Constructor for exception io.micronaut.configuration.rabbitmq.exception.RabbitClientException: Creates a new exception.
RabbitClientException(String, List<RabbitPublishState>) - Constructor for exception io.micronaut.configuration.rabbitmq.exception.RabbitClientException: Creates a new exception.
RabbitClientException(String, Throwable) - Constructor for exception io.micronaut.configuration.rabbitmq.exception.RabbitClientException: Creates a new exception.
RabbitClientException(String, Throwable, List<RabbitPublishState>) - Constructor for exception io.micronaut.configuration.rabbitmq.exception.RabbitClientException: Creates a new exception.
RabbitConnection - Annotation Type in io.micronaut.configuration.rabbitmq.annotation: Stores options surrounding a RabbitMQ connection.
RabbitConnectionFactory - Class in io.micronaut.configuration.rabbitmq.connect: A factory for creating a connection to RabbitMQ.
RabbitConnectionFactory() - Constructor for class io.micronaut.configuration.rabbitmq.connect.RabbitConnectionFactory
RabbitConnectionFactoryConfig - Class in io.micronaut.configuration.rabbitmq.connect: Base class for RabbitMQ to be configured.
RabbitConnectionFactoryConfig(String) - Constructor for class io.micronaut.configuration.rabbitmq.connect.RabbitConnectionFactoryConfig: Default constructor.
RabbitConnectionFactoryConfig.ChannelPoolConfiguration - Class in io.micronaut.configuration.rabbitmq.connect: Configuration for the channel pool.
RabbitConnectionFactoryConfig.RpcConfiguration - Class in io.micronaut.configuration.rabbitmq.connect: Configuration for RPC.
RabbitConsumerExecutorFactory - Class in io.micronaut.configuration.rabbitmq.executor: Configures a ScheduledExecutorService for running RabbitListener instances.
RabbitConsumerExecutorFactory() - Constructor for class io.micronaut.configuration.rabbitmq.executor.RabbitConsumerExecutorFactory
RabbitConsumerState - Class in io.micronaut.configuration.rabbitmq.bind: Stores the state of a RabbitMQ message to be consumed.
RabbitConsumerState(Envelope, AMQP.BasicProperties, byte[], Channel) - Constructor for class io.micronaut.configuration.rabbitmq.bind.RabbitConsumerState: Default constructor.
RabbitDefaultBinder - Class in io.micronaut.configuration.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.configuration.rabbitmq.bind.RabbitDefaultBinder: Default constructor.
RabbitEnvelopeBinder - Class in io.micronaut.configuration.rabbitmq.bind: Binds an argument of type Envelope from the RabbitConsumerState.
RabbitEnvelopeBinder() - Constructor for class io.micronaut.configuration.rabbitmq.bind.RabbitEnvelopeBinder
RabbitHeaderBinder - Class in io.micronaut.configuration.rabbitmq.bind: Binds an argument of with the Header annotation from the RabbitConsumerState.
RabbitHeaderBinder(ConversionService) - Constructor for class io.micronaut.configuration.rabbitmq.bind.RabbitHeaderBinder: Default constructor.
RabbitHeaderConvertibleValues - Class in io.micronaut.configuration.rabbitmq.bind: Converts RabbitMQ header values to the requested type.
RabbitHeaderConvertibleValues(Map<String, Object>, ConversionService<?>) - Constructor for class io.micronaut.configuration.rabbitmq.bind.RabbitHeaderConvertibleValues: Default constructor.
RabbitListener - Annotation Type in io.micronaut.configuration.rabbitmq.annotation: Class level annotation to indicate that a bean will be consumers of messages from RabbitMQ.
RabbitListenerException - Exception in io.micronaut.configuration.rabbitmq.exception: Exception thrown when an error occurs processing a RabbitMQ message via a RabbitListener.
RabbitListenerException(String, Object, RabbitConsumerState) - Constructor for exception io.micronaut.configuration.rabbitmq.exception.RabbitListenerException: Creates a new exception.
RabbitListenerException(String, Throwable, Object, RabbitConsumerState) - Constructor for exception io.micronaut.configuration.rabbitmq.exception.RabbitListenerException: Creates a new exception.
RabbitListenerException(Throwable, Object, RabbitConsumerState) - Constructor for exception io.micronaut.configuration.rabbitmq.exception.RabbitListenerException: Creates a new exception.
RabbitListenerExceptionHandler - Interface in io.micronaut.configuration.rabbitmq.exception: Interface that RabbitListener beans can implement to handle exceptions.
RabbitMessageCloseable - Class in io.micronaut.configuration.rabbitmq.bind: Responsible for acknowledging or rejecting a message.
RabbitMessageCloseable(RabbitConsumerState, boolean, boolean) - Constructor for class io.micronaut.configuration.rabbitmq.bind.RabbitMessageCloseable: Default constructor.
RabbitMessageSerDes<T> - Interface in io.micronaut.configuration.rabbitmq.serdes: Responsible for serializing and deserializing RabbitMQ message bodies.
RabbitMessageSerDesRegistry - Interface in io.micronaut.configuration.rabbitmq.serdes: A registry of RabbitMessageSerDes instances.
RabbitMetricsInterceptor - Class in io.micronaut.configuration.rabbitmq.metrics: Interceptor of the connection factory to set the metrics collector.
RabbitMetricsInterceptor(Provider<MeterRegistry>, String, Map<String, String>) - Constructor for class io.micronaut.configuration.rabbitmq.metrics.RabbitMetricsInterceptor: Default constructor.
RabbitMQConsumerAdvice - Class in io.micronaut.configuration.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) - Constructor for class io.micronaut.configuration.rabbitmq.intercept.RabbitMQConsumerAdvice: Default constructor.
RabbitMQHealthIndicator - Class in io.micronaut.configuration.rabbitmq.health: A HealthIndicator for RabbitMQ.
RabbitMQHealthIndicator(Connection) - Constructor for class io.micronaut.configuration.rabbitmq.health.RabbitMQHealthIndicator: Default constructor.
RabbitMQIntroductionAdvice - Class in io.micronaut.configuration.rabbitmq.intercept: Implementation of the RabbitClient advice annotation.
RabbitMQIntroductionAdvice(BeanContext, ConversionService<?>, RabbitMessageSerDesRegistry, ExecutorService) - Constructor for class io.micronaut.configuration.rabbitmq.intercept.RabbitMQIntroductionAdvice: Default constructor.
RabbitProperties - Annotation Type in io.micronaut.configuration.rabbitmq.annotation: Annotation to collect a set of properties.
RabbitProperty - Annotation Type in io.micronaut.configuration.rabbitmq.annotation: Used to set properties while publishing or bind to properties while consuming.
RabbitPropertyBinder - Class in io.micronaut.configuration.rabbitmq.bind: Binds an argument of with the RabbitProperty annotation from the RabbitConsumerState.
RabbitPropertyBinder(ConversionService) - Constructor for class io.micronaut.configuration.rabbitmq.bind.RabbitPropertyBinder: Default constructor.
RabbitPublishState - Class in io.micronaut.configuration.rabbitmq.reactive: Stores the state of a RabbitMQ message to be published.
RabbitPublishState(String, String, AMQP.BasicProperties, byte[]) - Constructor for class io.micronaut.configuration.rabbitmq.reactive.RabbitPublishState: Default constructor.
RabbitTypeArgumentBinder<T> - Interface in io.micronaut.configuration.rabbitmq.bind: An interface for RabbitMQ argument binding based on argument type.
ReactivePublisher - Interface in io.micronaut.configuration.rabbitmq.reactive: A generic contract for publishing RabbitMQ messages reactively.
returnChannel(Channel) - Method in interface io.micronaut.configuration.rabbitmq.connect.ChannelPool: Returns a channel to the pool.
returnChannel(Channel) - Method in class io.micronaut.configuration.rabbitmq.connect.DefaultChannelPool
returnChannel(Channel) - Method in class io.micronaut.configuration.rabbitmq.reactive.RxJavaReactivePublisher: Removes confirm listeners from the channel and returns the channel to the pool.
RpcConfiguration() - Constructor for class io.micronaut.configuration.rabbitmq.connect.RabbitConnectionFactoryConfig.RpcConfiguration
RxJavaReactivePublisher - Class in io.micronaut.configuration.rabbitmq.reactive: A reactive publisher implementation that uses a single channel per publish operation and returns an RxJava2 Completable.
RxJavaReactivePublisher(ChannelPool, RabbitConnectionFactoryConfig) - Constructor for class io.micronaut.configuration.rabbitmq.reactive.RxJavaReactivePublisher: Default constructor.

S

serialize(Object, MutableBasicProperties) - Method in class io.micronaut.configuration.rabbitmq.serdes.JavaLangRabbitMessageSerDes
serialize(Object, MutableBasicProperties) - Method in class io.micronaut.configuration.rabbitmq.serdes.JsonRabbitMessageSerDes
serialize(T, MutableBasicProperties) - Method in interface io.micronaut.configuration.rabbitmq.serdes.RabbitMessageSerDes: Serializes the data into a byte[] to be published to RabbitMQ.
setAddresses(List<Address>) - Method in class io.micronaut.configuration.rabbitmq.connect.RabbitConnectionFactoryConfig: Sets the addresses to be passed to ConnectionFactory.newConnection(List).
setAppId(String) - Method in class io.micronaut.configuration.rabbitmq.intercept.MutableBasicProperties: Sets the app id.
setChannelPool(ClusterRabbitConnectionFactoryConfig.DefaultChannelPoolConfiguration) - Method in class io.micronaut.configuration.rabbitmq.connect.ClusterRabbitConnectionFactoryConfig: Sets the channel pool configuration.
setChannelPool(RabbitConnectionFactoryConfig.ChannelPoolConfiguration) - Method in class io.micronaut.configuration.rabbitmq.connect.RabbitConnectionFactoryConfig: Sets the channel pool configuration.
setChannelPool(SingleRabbitConnectionFactoryConfig.DefaultChannelPoolConfiguration) - Method in class io.micronaut.configuration.rabbitmq.connect.SingleRabbitConnectionFactoryConfig: Sets the channel pool configuration.
setClusterId(String) - Method in class io.micronaut.configuration.rabbitmq.intercept.MutableBasicProperties: Sets the cluster id.
setConsumerExecutor(String) - Method in class io.micronaut.configuration.rabbitmq.connect.RabbitConnectionFactoryConfig: Sets the name of which executor service consumers should be executed on.
setContentEncoding(String) - Method in class io.micronaut.configuration.rabbitmq.intercept.MutableBasicProperties: Sets the content encoding.
setContentType(String) - Method in class io.micronaut.configuration.rabbitmq.intercept.MutableBasicProperties: Sets the content type.
setCorrelationId(String) - Method in class io.micronaut.configuration.rabbitmq.intercept.MutableBasicProperties: Sets the correlation id.
setDeliveryMode(Integer) - Method in class io.micronaut.configuration.rabbitmq.intercept.MutableBasicProperties: Sets the delivery mode.
setExpiration(String) - Method in class io.micronaut.configuration.rabbitmq.intercept.MutableBasicProperties: Sets the expiration.
setHeaders(Map<String, Object>) - Method in class io.micronaut.configuration.rabbitmq.intercept.MutableBasicProperties: Sets the headers.
setMaxIdleChannels(Integer) - Method in class io.micronaut.configuration.rabbitmq.connect.RabbitConnectionFactoryConfig.ChannelPoolConfiguration: Sets the maximum number of idle channels that will be kept open.
setMessageId(String) - Method in class io.micronaut.configuration.rabbitmq.intercept.MutableBasicProperties: Sets the message id.
setPriority(Integer) - Method in class io.micronaut.configuration.rabbitmq.intercept.MutableBasicProperties: Sets the priority.
setReplyTo(String) - Method in class io.micronaut.configuration.rabbitmq.intercept.MutableBasicProperties: Sets the reply to.
setRpc(ClusterRabbitConnectionFactoryConfig.DefaultRpcConfiguration) - Method in class io.micronaut.configuration.rabbitmq.connect.ClusterRabbitConnectionFactoryConfig: Sets the RPC configuration.
setRpc(RabbitConnectionFactoryConfig.RpcConfiguration) - Method in class io.micronaut.configuration.rabbitmq.connect.RabbitConnectionFactoryConfig: Sets the RPC configuration.
setRpc(SingleRabbitConnectionFactoryConfig.DefaultRpcConfiguration) - Method in class io.micronaut.configuration.rabbitmq.connect.SingleRabbitConnectionFactoryConfig: Sets the RPC configuration.
setTimeout(Duration) - Method in class io.micronaut.configuration.rabbitmq.connect.RabbitConnectionFactoryConfig.RpcConfiguration: Sets the timeout duration before cancelling an RPC call.
setTimestamp(Date) - Method in class io.micronaut.configuration.rabbitmq.intercept.MutableBasicProperties: Sets the timestamp.
setType(String) - Method in class io.micronaut.configuration.rabbitmq.intercept.MutableBasicProperties: Sets the type.
setUserId(String) - Method in class io.micronaut.configuration.rabbitmq.intercept.MutableBasicProperties: Sets the user id.
SingleRabbitConnectionFactoryConfig - Class in io.micronaut.configuration.rabbitmq.connect: The default RabbitMQ configuration class.
SingleRabbitConnectionFactoryConfig() - Constructor for class io.micronaut.configuration.rabbitmq.connect.SingleRabbitConnectionFactoryConfig: Default constructor.
SingleRabbitConnectionFactoryConfig.DefaultChannelPoolConfiguration - Class in io.micronaut.configuration.rabbitmq.connect
SingleRabbitConnectionFactoryConfig.DefaultRpcConfiguration - Class in io.micronaut.configuration.rabbitmq.connect
supports(ArgumentConversionContext<Object>) - Method in class io.micronaut.configuration.rabbitmq.bind.RabbitPropertyBinder
supports(Argument<Object>) - Method in class io.micronaut.configuration.rabbitmq.serdes.JavaLangRabbitMessageSerDes
supports(Argument<Object>) - Method in class io.micronaut.configuration.rabbitmq.serdes.JsonRabbitMessageSerDes
supports(Argument<T>) - Method in interface io.micronaut.configuration.rabbitmq.serdes.RabbitMessageSerDes: Determines if this serdes supports the given type.

T

toBasicProperties() - Method in class io.micronaut.configuration.rabbitmq.intercept.MutableBasicProperties: Converts the mutable properties to the RabbitMQ properties.

V

valueOf(String) - Static method in enum io.micronaut.configuration.rabbitmq.reactive.BrokerResponse: Returns the enum constant of this type with the specified name.
values() - Method in class io.micronaut.configuration.rabbitmq.bind.RabbitHeaderConvertibleValues
values() - Static method in enum io.micronaut.configuration.rabbitmq.reactive.BrokerResponse: Returns an array containing the constants of this enum type, in the order they are declared.

W

withAcknowledge(Boolean) - Method in class io.micronaut.configuration.rabbitmq.bind.RabbitMessageCloseable: Builder style sets whether the message should be acknowledged.

A B C D F G H I J M N O P Q R S T V W