Index

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

R

RABBIT_ADMIN_BEAN_NAME - Static variable in class org.springframework.amqp.rabbit.config.RabbitListenerConfigUtils
The bean name of the default RabbitAdmin.
RABBIT_CONNECTION_FACTORY_BEAN_NAME - Static variable in class org.springframework.amqp.rabbit.config.RabbitListenerConfigUtils
The bean name of the default ConnectionFactory.
RABBIT_EMPTY_STRING_ARGUMENTS_PROPERTY - Static variable in class org.springframework.amqp.rabbit.annotation.RabbitListenerAnnotationBeanPostProcessor
 
RABBIT_LISTENER_ANNOTATION_PROCESSOR_BEAN_NAME - Static variable in class org.springframework.amqp.rabbit.config.RabbitListenerConfigUtils
The bean name of the internally managed Rabbit listener annotation processor.
RABBIT_LISTENER_ENDPOINT_REGISTRY_BEAN_NAME - Static variable in class org.springframework.amqp.rabbit.config.RabbitListenerConfigUtils
The bean name of the internally managed Rabbit listener endpoint registry.
RabbitAccessor - Class in org.springframework.amqp.rabbit.connection
 
RabbitAccessor() - Constructor for class org.springframework.amqp.rabbit.connection.RabbitAccessor
 
RabbitAdmin - Class in org.springframework.amqp.rabbit.core
RabbitMQ implementation of portable AMQP administrative operations for AMQP >= 0.9.1.
RabbitAdmin(ConnectionFactory) - Constructor for class org.springframework.amqp.rabbit.core.RabbitAdmin
Construct an instance using the provided ConnectionFactory.
RabbitAdmin(RabbitTemplate) - Constructor for class org.springframework.amqp.rabbit.core.RabbitAdmin
Construct an instance using the provided RabbitTemplate.
RabbitAdminEvent - Class in org.springframework.amqp.rabbit.core
Base class for admin events.
RabbitAdminEvent(Object) - Constructor for class org.springframework.amqp.rabbit.core.RabbitAdminEvent
 
RabbitAvailable - Annotation Interface in org.springframework.amqp.rabbit.junit
Test classes annotated with this will not run if there is no broker on localhost.
RabbitAvailableCondition - Class in org.springframework.amqp.rabbit.junit
JUnit5 ExecutionCondition.
RabbitAvailableCondition() - Constructor for class org.springframework.amqp.rabbit.junit.RabbitAvailableCondition
 
RabbitBootstrapConfiguration - Class in org.springframework.amqp.rabbit.annotation
An ImportBeanDefinitionRegistrar class that registers a RabbitListenerAnnotationBeanPostProcessor bean capable of processing Spring's @RabbitListener annotation.
RabbitBootstrapConfiguration() - Constructor for class org.springframework.amqp.rabbit.annotation.RabbitBootstrapConfiguration
 
RabbitConnectionFactoryBean - Class in org.springframework.amqp.rabbit.connection
Factory bean to create a RabbitMQ ConnectionFactory, delegating most setter methods and optionally enabling SSL, with or without certificate validation.
RabbitConnectionFactoryBean() - Constructor for class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
 
RabbitConverterFuture<C> - Class in org.springframework.amqp.rabbit
A RabbitFuture with a return type of the template's generic parameter.
RabbitExceptionTranslator - Class in org.springframework.amqp.rabbit.support
Translates Rabbit Exceptions to the AmqpException class hierarchy.
RabbitFuture<T> - Class in org.springframework.amqp.rabbit
Base class for CompletableFutures returned by AsyncRabbitTemplate.
RabbitFuture(String, Message, BiConsumer<String, DirectReplyToMessageListenerContainer.ChannelHolder>, Function<RabbitFuture<?>, ScheduledFuture<?>>) - Constructor for class org.springframework.amqp.rabbit.RabbitFuture
 
RabbitGatewaySupport - Class in org.springframework.amqp.rabbit.core
Convenient super class for application classes that need RabbitMQ access.
RabbitGatewaySupport() - Constructor for class org.springframework.amqp.rabbit.core.RabbitGatewaySupport
 
RabbitHandler - Annotation Interface in org.springframework.amqp.rabbit.annotation
Annotation that marks a method to be the target of a Rabbit message listener within a class that is annotated with RabbitListener.
RabbitListener - Annotation Interface in org.springframework.amqp.rabbit.annotation
Annotation that marks a method to be the target of a Rabbit message listener on the specified RabbitListener.queues() (or RabbitListener.bindings()).
RabbitListenerAnnotationBeanPostProcessor - Class in org.springframework.amqp.rabbit.annotation
Bean post-processor that registers methods annotated with RabbitListener to be invoked by a AMQP message listener container created under the cover by a RabbitListenerContainerFactory according to the parameters of the annotation.
RabbitListenerAnnotationBeanPostProcessor() - Constructor for class org.springframework.amqp.rabbit.annotation.RabbitListenerAnnotationBeanPostProcessor
 
RabbitListenerConfigurationSelector - Class in org.springframework.amqp.rabbit.annotation
A DeferredImportSelector implementation with the lowest order to import a MultiRabbitBootstrapConfiguration and RabbitBootstrapConfiguration as late as possible.
RabbitListenerConfigurationSelector() - Constructor for class org.springframework.amqp.rabbit.annotation.RabbitListenerConfigurationSelector
 
RabbitListenerConfigurer - Interface in org.springframework.amqp.rabbit.annotation
Optional interface to be implemented by Spring managed bean willing to customize how Rabbit listener endpoints are configured.
RabbitListenerConfigUtils - Class in org.springframework.amqp.rabbit.config
Configuration constants for internal sharing across subpackages.
RabbitListenerConfigUtils() - Constructor for class org.springframework.amqp.rabbit.config.RabbitListenerConfigUtils
 
RabbitListenerContainerFactory<C extends MessageListenerContainer> - Interface in org.springframework.amqp.rabbit.listener
RabbitListenerEndpoint - Interface in org.springframework.amqp.rabbit.listener
Model for a Rabbit listener endpoint.
RabbitListenerEndpointRegistrar - Class in org.springframework.amqp.rabbit.listener
Helper bean for registering RabbitListenerEndpoint with a RabbitListenerEndpointRegistry.
RabbitListenerEndpointRegistrar() - Constructor for class org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistrar
 
RabbitListenerEndpointRegistry - Class in org.springframework.amqp.rabbit.listener
Creates the necessary MessageListenerContainer instances for the registered endpoints.
RabbitListenerEndpointRegistry() - Constructor for class org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistry
 
RabbitListenerErrorHandler - Interface in org.springframework.amqp.rabbit.listener.api
An error handler which is called when a {code @RabbitListener} method throws an exception.
RabbitListenerObservation - Enum Class in org.springframework.amqp.rabbit.support.micrometer
Spring Rabbit Observation for listeners.
RabbitListenerObservation.DefaultRabbitListenerObservationConvention - Class in org.springframework.amqp.rabbit.support.micrometer
Default RabbitListenerObservationConvention for Rabbit listener key values.
RabbitListenerObservation.ListenerLowCardinalityTags - Enum Class in org.springframework.amqp.rabbit.support.micrometer
Low cardinality tags.
RabbitListenerObservationConvention - Interface in org.springframework.amqp.rabbit.support.micrometer
ObservationConvention for Rabbit listener key values.
RabbitListeners - Annotation Interface in org.springframework.amqp.rabbit.annotation
Container annotation that aggregates several RabbitListener annotations.
RabbitListenerTest - Annotation Interface in org.springframework.amqp.rabbit.test
Annotate a @Configuration class with this to enable proxying @RabbitListener beans to capture arguments and result (if any).
RabbitListenerTestBootstrap - Class in org.springframework.amqp.rabbit.test
Overrides the default BPP with a RabbitListenerTestHarness.
RabbitListenerTestBootstrap() - Constructor for class org.springframework.amqp.rabbit.test.RabbitListenerTestBootstrap
 
RabbitListenerTestHarness - Class in org.springframework.amqp.rabbit.test
BeanPostProcessor extending RabbitListenerAnnotationBeanPostProcessor.
RabbitListenerTestHarness(AnnotationMetadata) - Constructor for class org.springframework.amqp.rabbit.test.RabbitListenerTestHarness
 
RabbitListenerTestHarness.InvocationData - Class in org.springframework.amqp.rabbit.test
 
RabbitListenerTestSelector - Class in org.springframework.amqp.rabbit.test
A RabbitListenerConfigurationSelector extension to register a RabbitListenerTestBootstrap, but already with the higher order, so the RabbitListenerTestHarness bean is registered earlier, than RabbitListenerAnnotationBeanPostProcessor.
RabbitListenerTestSelector() - Constructor for class org.springframework.amqp.rabbit.test.RabbitListenerTestSelector
 
RabbitMessageFuture - Class in org.springframework.amqp.rabbit
A RabbitFuture with a return type of Message.
RabbitMessageOperations - Interface in org.springframework.amqp.rabbit.core
A specialization of MessageSendingOperations and MessageRequestReplyOperations for AMQP related operations that allow to specify not only the exchange but also the routing key to use.
RabbitMessageReceiverContext - Class in org.springframework.amqp.rabbit.support.micrometer
ReceiverContext for Messages.
RabbitMessageReceiverContext(Message, String) - Constructor for class org.springframework.amqp.rabbit.support.micrometer.RabbitMessageReceiverContext
 
RabbitMessageSenderContext - Class in org.springframework.amqp.rabbit.support.micrometer
SenderContext for Messages.
RabbitMessageSenderContext(Message, String, String) - Constructor for class org.springframework.amqp.rabbit.support.micrometer.RabbitMessageSenderContext
 
RabbitMessagingTemplate - Class in org.springframework.amqp.rabbit.core
An implementation of RabbitMessageOperations.
RabbitMessagingTemplate() - Constructor for class org.springframework.amqp.rabbit.core.RabbitMessagingTemplate
Constructor for use with bean properties.
RabbitMessagingTemplate(RabbitTemplate) - Constructor for class org.springframework.amqp.rabbit.core.RabbitMessagingTemplate
Create an instance with the RabbitTemplate to use.
RABBITMQ - Static variable in class org.springframework.amqp.rabbit.junit.AbstractTestContainerTests
 
RabbitNamespaceHandler - Class in org.springframework.amqp.rabbit.config
Namespace handler for Rabbit.
RabbitNamespaceHandler() - Constructor for class org.springframework.amqp.rabbit.config.RabbitNamespaceHandler
 
RabbitNamespaceUtils - Class in org.springframework.amqp.rabbit.config
 
RabbitOperations - Interface in org.springframework.amqp.rabbit.core
Rabbit specific methods for Amqp functionality.
RabbitOperations.OperationsCallback<T> - Interface in org.springframework.amqp.rabbit.core
Callback for using the same channel for multiple RabbitTemplate operations.
RabbitResourceHolder - Class in org.springframework.amqp.rabbit.connection
Rabbit resource holder, wrapping a RabbitMQ Connection and Channel.
RabbitResourceHolder() - Constructor for class org.springframework.amqp.rabbit.connection.RabbitResourceHolder
Create a new RabbitResourceHolder that is open for resources to be added.
RabbitResourceHolder(Channel, boolean) - Constructor for class org.springframework.amqp.rabbit.connection.RabbitResourceHolder
Construct an instance for the channel.
RabbitRuntimeHints - Class in org.springframework.amqp.rabbit.aot
RuntimeHintsRegistrar for spring-rabbit.
RabbitRuntimeHints() - Constructor for class org.springframework.amqp.rabbit.aot.RabbitRuntimeHints
 
RabbitStreamListenerObservation - Enum Class in org.springframework.rabbit.stream.micrometer
Spring Rabbit Observation for stream listeners.
RabbitStreamListenerObservation.DefaultRabbitStreamListenerObservationConvention - Class in org.springframework.rabbit.stream.micrometer
Default RabbitStreamListenerObservationConvention for Rabbit listener key values.
RabbitStreamListenerObservation.ListenerLowCardinalityTags - Enum Class in org.springframework.rabbit.stream.micrometer
Low cardinality tags.
RabbitStreamListenerObservationConvention - Interface in org.springframework.rabbit.stream.micrometer
ObservationConvention for Rabbit stream listener key values.
RabbitStreamMessageReceiverContext - Class in org.springframework.rabbit.stream.micrometer
ReceiverContext for stream Messages.
RabbitStreamMessageReceiverContext(Message, String, String) - Constructor for class org.springframework.rabbit.stream.micrometer.RabbitStreamMessageReceiverContext
 
RabbitStreamMessageReceiverContext.DefaultRabbitListenerObservationConvention - Class in org.springframework.rabbit.stream.micrometer
Default RabbitListenerObservationConvention for Rabbit listener key values.
RabbitStreamMessageSenderContext - Class in org.springframework.rabbit.stream.micrometer
SenderContext for Messages.
RabbitStreamMessageSenderContext(Message, String, String) - Constructor for class org.springframework.rabbit.stream.micrometer.RabbitStreamMessageSenderContext
 
RabbitStreamOperations - Interface in org.springframework.rabbit.stream.producer
Provides methods for sending messages using a RabbitMQ Stream producer.
RabbitStreamTemplate - Class in org.springframework.rabbit.stream.producer
Default implementation of RabbitStreamOperations.
RabbitStreamTemplate(Environment, String) - Constructor for class org.springframework.rabbit.stream.producer.RabbitStreamTemplate
Construct an instance with the provided Environment.
RabbitStreamTemplateObservation - Enum Class in org.springframework.rabbit.stream.micrometer
Spring RabbitMQ Observation for RabbitStreamTemplate.
RabbitStreamTemplateObservation.DefaultRabbitStreamTemplateObservationConvention - Class in org.springframework.rabbit.stream.micrometer
Default RabbitStreamTemplateObservationConvention for Rabbit template key values.
RabbitStreamTemplateObservation.TemplateLowCardinalityTags - Enum Class in org.springframework.rabbit.stream.micrometer
Low cardinality tags.
RabbitStreamTemplateObservationConvention - Interface in org.springframework.rabbit.stream.micrometer
ObservationConvention for Rabbit stream template key values.
RabbitTemplate - Class in org.springframework.amqp.rabbit.core
Helper class that simplifies synchronous RabbitMQ access (sending and receiving messages).
RabbitTemplate() - Constructor for class org.springframework.amqp.rabbit.core.RabbitTemplate
Convenient constructor for use with setter injection.
RabbitTemplate(ConnectionFactory) - Constructor for class org.springframework.amqp.rabbit.core.RabbitTemplate
Create a rabbit template with default strategies and settings.
RabbitTemplate.ConfirmCallback - Interface in org.springframework.amqp.rabbit.core
A callback for publisher confirmations.
RabbitTemplate.ReturnsCallback - Interface in org.springframework.amqp.rabbit.core
A callback for returned messages.
RabbitTemplate.TemplateConsumer - Class in org.springframework.amqp.rabbit.core
Adds RabbitTemplate.TemplateConsumer.toString() to the DefaultConsumer.
RabbitTemplateObservation - Enum Class in org.springframework.amqp.rabbit.support.micrometer
Spring RabbitMQ Observation for RabbitTemplate.
RabbitTemplateObservation.DefaultRabbitTemplateObservationConvention - Class in org.springframework.amqp.rabbit.support.micrometer
Default RabbitTemplateObservationConvention for Rabbit template key values.
RabbitTemplateObservation.TemplateLowCardinalityTags - Enum Class in org.springframework.amqp.rabbit.support.micrometer
Low cardinality tags.
RabbitTemplateObservationConvention - Interface in org.springframework.amqp.rabbit.support.micrometer
ObservationConvention for Rabbit template key values.
RabbitTransactionManager - Class in org.springframework.amqp.rabbit.transaction
PlatformTransactionManager implementation for a single Rabbit ConnectionFactory.
RabbitTransactionManager() - Constructor for class org.springframework.amqp.rabbit.transaction.RabbitTransactionManager
Create a new RabbitTransactionManager for bean-style usage.
RabbitTransactionManager(ConnectionFactory) - Constructor for class org.springframework.amqp.rabbit.transaction.RabbitTransactionManager
Create a new RabbitTransactionManager, given a ConnectionFactory.
RabbitUtils - Class in org.springframework.amqp.rabbit.connection
 
RabbitUtils() - Constructor for class org.springframework.amqp.rabbit.connection.RabbitUtils
 
random - Enum constant in enum class org.springframework.amqp.core.QueueBuilder.LeaderLocator
Deploy on a random node.
RANDOM - Enum constant in enum class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory.AddressShuffleMode
Randomly shuffle the addresses before opening a connection; attempt connections in the new order.
RAW_MESSAGE - Static variable in class org.springframework.amqp.support.AmqpHeaders
The received raw message before conversion; this header usually only appears in an ErrorMessage.
receive() - Method in interface org.springframework.amqp.core.AmqpTemplate
Receive a message if there is one from a default queue.
receive() - Method in class org.springframework.amqp.rabbit.core.RabbitMessagingTemplate
 
receive() - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
 
receive(long) - Method in interface org.springframework.amqp.core.AmqpTemplate
Receive a message from a default queue, waiting up to the specified wait time if necessary for a message to become available.
receive(long) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
 
receive(String) - Method in interface org.springframework.amqp.core.AmqpTemplate
Receive a message if there is one from a specific queue.
receive(String) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
 
receive(String, long) - Method in interface org.springframework.amqp.core.AmqpTemplate
Receive a message from a specific queue, waiting up to the specified wait time if necessary for a message to become available.
receive(String, long) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
 
receiveAndConvert() - Method in interface org.springframework.amqp.core.AmqpTemplate
Receive a message if there is one from a default queue and convert it to a Java object.
receiveAndConvert() - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
 
receiveAndConvert(long) - Method in interface org.springframework.amqp.core.AmqpTemplate
Receive a message if there is one from a default queue and convert it to a Java object.
receiveAndConvert(long) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
 
receiveAndConvert(long, ParameterizedTypeReference<T>) - Method in interface org.springframework.amqp.core.AmqpTemplate
Receive a message if there is one from a default queue and convert it to a Java object.
receiveAndConvert(long, ParameterizedTypeReference<T>) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
 
receiveAndConvert(Class<T>) - Method in class org.springframework.amqp.rabbit.core.RabbitMessagingTemplate
 
receiveAndConvert(String) - Method in interface org.springframework.amqp.core.AmqpTemplate
Receive a message if there is one from a specific queue and convert it to a Java object.
receiveAndConvert(String) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
 
receiveAndConvert(String, long) - Method in interface org.springframework.amqp.core.AmqpTemplate
Receive a message if there is one from a specific queue and convert it to a Java object.
receiveAndConvert(String, long) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
 
receiveAndConvert(String, long, ParameterizedTypeReference<T>) - Method in interface org.springframework.amqp.core.AmqpTemplate
Receive a message if there is one from a specific queue and convert it to a Java object.
receiveAndConvert(String, long, ParameterizedTypeReference<T>) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
 
receiveAndConvert(String, ParameterizedTypeReference<T>) - Method in interface org.springframework.amqp.core.AmqpTemplate
Receive a message if there is one from a specific queue and convert it to a Java object.
receiveAndConvert(String, ParameterizedTypeReference<T>) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
 
receiveAndConvert(ParameterizedTypeReference<T>) - Method in interface org.springframework.amqp.core.AmqpTemplate
Receive a message if there is one from a default queue and convert it to a Java object.
receiveAndConvert(ParameterizedTypeReference<T>) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
 
receiveAndReply(String, ReceiveAndReplyCallback<R, S>) - Method in interface org.springframework.amqp.core.AmqpTemplate
Receive a message if there is one from provided queue, invoke provided ReceiveAndReplyCallback and send reply message, if the callback returns one, to the replyTo Address from MessageProperties or to default exchange and default routingKey.
receiveAndReply(String, ReceiveAndReplyCallback<R, S>) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
 
receiveAndReply(String, ReceiveAndReplyCallback<R, S>, String, String) - Method in interface org.springframework.amqp.core.AmqpTemplate
Receive a message if there is one from provided queue, invoke provided ReceiveAndReplyCallback and send reply message, if the callback returns one, to the provided exchange and routingKey.
receiveAndReply(String, ReceiveAndReplyCallback<R, S>, String, String) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
 
receiveAndReply(String, ReceiveAndReplyCallback<R, S>, ReplyToAddressCallback<S>) - Method in interface org.springframework.amqp.core.AmqpTemplate
Receive a message if there is one from provided queue, invoke provided ReceiveAndReplyCallback and send reply message, if the callback returns one, to the replyTo Address from result of ReplyToAddressCallback.
receiveAndReply(String, ReceiveAndReplyCallback<R, S>, ReplyToAddressCallback<S>) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
 
receiveAndReply(ReceiveAndReplyCallback<R, S>) - Method in interface org.springframework.amqp.core.AmqpTemplate
Receive a message if there is one from a default queue, invoke provided ReceiveAndReplyCallback and send reply message, if the callback returns one, to the replyTo Address from MessageProperties or to default exchange and default routingKey.
receiveAndReply(ReceiveAndReplyCallback<R, S>) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
 
receiveAndReply(ReceiveAndReplyCallback<R, S>, String, String) - Method in interface org.springframework.amqp.core.AmqpTemplate
Receive a message if there is one from default queue, invoke provided ReceiveAndReplyCallback and send reply message, if the callback returns one, to the provided exchange and routingKey.
receiveAndReply(ReceiveAndReplyCallback<R, S>, String, String) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
 
receiveAndReply(ReceiveAndReplyCallback<R, S>, ReplyToAddressCallback<S>) - Method in interface org.springframework.amqp.core.AmqpTemplate
Receive a message if there is one from a default queue, invoke provided ReceiveAndReplyCallback and send reply message, if the callback returns one, to the replyTo Address from result of ReplyToAddressCallback.
receiveAndReply(ReceiveAndReplyCallback<R, S>, ReplyToAddressCallback<S>) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
 
ReceiveAndReplyCallback<R,S> - Interface in org.springframework.amqp.core
To be used with the receive-and-reply methods of AmqpTemplate as processor for inbound object and producer for outbound object.
ReceiveAndReplyMessageCallback - Interface in org.springframework.amqp.core
Message exchanging contract of ReceiveAndReplyCallback.
RECEIVED_DELAY - Static variable in class org.springframework.amqp.support.AmqpHeaders
 
RECEIVED_DELIVERY_MODE - Static variable in class org.springframework.amqp.support.AmqpHeaders
 
RECEIVED_EXCHANGE - Static variable in class org.springframework.amqp.support.AmqpHeaders
 
RECEIVED_ROUTING_KEY - Static variable in class org.springframework.amqp.support.AmqpHeaders
 
RECEIVED_USER_ID - Static variable in class org.springframework.amqp.support.AmqpHeaders
 
recover(Message, MessageHandler.Context, Throwable) - Method in interface org.springframework.rabbit.stream.retry.StreamMessageRecoverer
Callback for message that was consumed but failed all retry attempts.
recover(Object[], Throwable) - Method in class org.springframework.amqp.rabbit.config.StatelessRetryOperationsInterceptorFactoryBean
 
recover(List<Message>, Throwable) - Method in interface org.springframework.amqp.rabbit.retry.MessageBatchRecoverer
Callback for message batch that was consumed but failed all retry attempts.
recover(Message, Throwable) - Method in class org.springframework.amqp.rabbit.retry.ImmediateRequeueMessageRecoverer
 
recover(Message, Throwable) - Method in interface org.springframework.amqp.rabbit.retry.MessageBatchRecoverer
 
recover(Message, Throwable) - Method in interface org.springframework.amqp.rabbit.retry.MessageRecoverer
Callback for message that was consumed but failed all retry attempts.
recover(Message, Throwable) - Method in class org.springframework.amqp.rabbit.retry.RejectAndDontRequeueRecoverer
 
recover(Message, Throwable) - Method in class org.springframework.amqp.rabbit.retry.RepublishMessageRecoverer
 
recover(Message, Throwable) - Method in interface org.springframework.rabbit.stream.retry.StreamMessageRecoverer
 
recoverer(MessageRecoverer) - Method in class org.springframework.amqp.rabbit.config.RetryInterceptorBuilder
Apply a Message recoverer - default is to log and discard after retry is exhausted.
recreate() - Method in class org.springframework.amqp.support.converter.RemoteInvocationResult
Recreate the invocation result, either returning the result value in case of a successful invocation of the target method, or rethrowing the exception thrown by the target method.
redeclareElementsIfNecessary() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
Use AmqpAdmin.initialize() to redeclare everything if necessary.
REDELIVERED - Static variable in class org.springframework.amqp.support.AmqpHeaders
 
REF_ATTRIBUTE - Static variable in class org.springframework.amqp.rabbit.config.NamespaceUtils
 
registerAllEndpoints() - Method in class org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistrar
 
registerBeanDefinitions(AnnotationMetadata, BeanDefinitionRegistry) - Method in class org.springframework.amqp.rabbit.annotation.MultiRabbitBootstrapConfiguration
 
registerBeanDefinitions(AnnotationMetadata, BeanDefinitionRegistry) - Method in class org.springframework.amqp.rabbit.annotation.RabbitBootstrapConfiguration
 
registerBeanDefinitions(AnnotationMetadata, BeanDefinitionRegistry) - Method in class org.springframework.amqp.rabbit.test.RabbitListenerTestBootstrap
 
registerConsumerChannel(Channel, ConnectionFactory) - Static method in class org.springframework.amqp.rabbit.connection.ConsumerChannelRegistry
If a listener container is configured to use a RabbitTransactionManager, the consumer's channel is registered here so that it is used as the bound resource when the transaction actually starts.
registerDeliveryTag(ConnectionFactory, Channel, Long) - Static method in class org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils
 
registerEndpoint(RabbitListenerEndpoint) - Method in class org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistrar
Register a new RabbitListenerEndpoint using the default RabbitListenerContainerFactory to create the underlying container.
registerEndpoint(RabbitListenerEndpoint, RabbitListenerContainerFactory<?>) - Method in class org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistrar
Register a new RabbitListenerEndpoint alongside the RabbitListenerContainerFactory to use to create the underlying container.
registerHints(RuntimeHints, ClassLoader) - Method in class org.springframework.amqp.rabbit.aot.RabbitRuntimeHints
 
registerListenerContainer(RabbitListenerEndpoint, RabbitListenerContainerFactory<?>) - Method in class org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistry
Create a message listener container for the given RabbitListenerEndpoint.
registerListenerContainer(RabbitListenerEndpoint, RabbitListenerContainerFactory<?>, boolean) - Method in class org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistry
Create a message listener container for the given RabbitListenerEndpoint.
RejectAndDontRequeueRecoverer - Class in org.springframework.amqp.rabbit.retry
MessageRecover that causes the listener container to reject the message without requeuing.
RejectAndDontRequeueRecoverer() - Constructor for class org.springframework.amqp.rabbit.retry.RejectAndDontRequeueRecoverer
Construct an instance with the default exception message.
RejectAndDontRequeueRecoverer(String) - Constructor for class org.springframework.amqp.rabbit.retry.RejectAndDontRequeueRecoverer
Construct an instance with the provided exception message.
RejectAndDontRequeueRecoverer(Supplier<String>) - Constructor for class org.springframework.amqp.rabbit.retry.RejectAndDontRequeueRecoverer
Construct an instance with the provided exception message supplier.
rejectPublish - Enum constant in enum class org.springframework.amqp.core.QueueBuilder.Overflow
Reject the new message.
release(T) - Method in class org.springframework.amqp.rabbit.support.ActiveObjectCounter
 
releaseBatches() - Method in interface org.springframework.amqp.rabbit.batch.BatchingStrategy
Release batch(es), perhaps due to a timeout.
releaseBatches() - Method in class org.springframework.amqp.rabbit.batch.SimpleBatchingStrategy
 
releaseConsumerFor(DirectReplyToMessageListenerContainer.ChannelHolder, boolean, String) - Method in class org.springframework.amqp.rabbit.listener.DirectReplyToMessageListenerContainer
Release the consumer associated with the channel for reuse.
releaseResources(RabbitResourceHolder) - Static method in class org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils
 
releaseSub(long, TimeUnit) - Method in class org.springframework.amqp.rabbit.log4j2.AmqpAppender.AmqpManager
 
RemoteInvocationAwareMessageConverterAdapter - Class in org.springframework.amqp.support.converter
A delegating adapter that unwraps RemoteInvocationResult after invoking the delegate to convert from a message.
RemoteInvocationAwareMessageConverterAdapter() - Constructor for class org.springframework.amqp.support.converter.RemoteInvocationAwareMessageConverterAdapter
 
RemoteInvocationAwareMessageConverterAdapter(MessageConverter) - Constructor for class org.springframework.amqp.support.converter.RemoteInvocationAwareMessageConverterAdapter
 
RemoteInvocationResult - Class in org.springframework.amqp.support.converter
Encapsulates a remote invocation result, holding a result value or an exception.
RemoteInvocationResult() - Constructor for class org.springframework.amqp.support.converter.RemoteInvocationResult
Create a new RemoteInvocationResult for JavaBean-style deserialization (e.g.
RemoteInvocationResult(Object) - Constructor for class org.springframework.amqp.support.converter.RemoteInvocationResult
Create a new RemoteInvocationResult for the given result value.
RemoteInvocationResult(Throwable) - Constructor for class org.springframework.amqp.support.converter.RemoteInvocationResult
Create a new RemoteInvocationResult for the given exception.
RemoteInvocationUtils - Class in org.springframework.amqp.support.converter
General utilities for handling remote invocations.
RemoteInvocationUtils() - Constructor for class org.springframework.amqp.support.converter.RemoteInvocationUtils
 
removeAfterReceivePostProcessor(MessagePostProcessor) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
Remove the provided MessagePostProcessor from the RabbitTemplate.afterReceivePostProcessors list.
removeAfterReceivePostProcessor(MessagePostProcessor) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
Remove the provided MessagePostProcessor from the AbstractMessageListenerContainer.afterReceivePostProcessors list.
removeArgument(String) - Method in class org.springframework.amqp.core.AbstractDeclarable
 
removeArgument(String) - Method in interface org.springframework.amqp.core.Declarable
Remove an argument from the declarable.
removeBeforePublishPostProcessor(MessagePostProcessor) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
Remove the provided MessagePostProcessor from the RabbitTemplate.beforePublishPostProcessors list.
removeBinding(Binding) - Method in interface org.springframework.amqp.core.AmqpAdmin
Remove a binding of a queue to an exchange.
removeBinding(Binding) - Method in class org.springframework.amqp.rabbit.core.RabbitAdmin
 
removeBlockedListener(BlockedListener) - Method in interface org.springframework.amqp.rabbit.connection.Connection
Remove a BlockedListener.
removeBlockedListener(BlockedListener) - Method in class org.springframework.amqp.rabbit.connection.SimpleConnection
 
removeChannel(AutorecoveringChannel) - Static method in class org.springframework.amqp.rabbit.connection.ClosingRecoveryListener
Remove the channel from the set used to ensure that ClosingRecoveryListener.addRecoveryListenerIfNecessary(Channel) is idempotent.
removeConfirmListener(ConfirmListener) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
 
removeConnectionListener(ConnectionListener) - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
 
removeConnectionListener(ConnectionListener) - Method in class org.springframework.amqp.rabbit.connection.AbstractRoutingConnectionFactory
 
removeConnectionListener(ConnectionListener) - Method in interface org.springframework.amqp.rabbit.connection.ConnectionFactory
 
removeConnectionListener(ConnectionListener) - Method in class org.springframework.amqp.rabbit.connection.LocalizedQueueConnectionFactory
 
removeConsumerArg(String) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
When using receive methods with a non-zero timeout, a Consumer is created to receive the message.
removeDecompressor(String) - Method in class org.springframework.amqp.support.postprocessor.DelegatingDecompressingPostProcessor
Remove the decompressor for this encoding; content will not be decompressed even if the MessageProperties.SPRING_AUTO_DECOMPRESS header is true.
removeDelegate(String) - Method in class org.springframework.amqp.support.converter.ContentTypeDelegatingMessageConverter
Remove the delegate for the content type.
removeDelegate(ConnectionListener) - Method in class org.springframework.amqp.rabbit.connection.CompositeConnectionListener
 
removeExchanges(String...) - Method in class org.springframework.amqp.rabbit.junit.BrokerRunningSupport
Remove exchanges from the broker.
removeHeader(String) - Method in class org.springframework.amqp.core.MessageBuilderSupport
 
removeHeaders() - Method in class org.springframework.amqp.core.MessageBuilderSupport
 
removeQueueNames(String...) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
Remove queue(s) from this container's list of queues.
removeQueueNames(String...) - Method in class org.springframework.amqp.rabbit.listener.DirectMessageListenerContainer
 
removeQueueNames(String...) - Method in class org.springframework.amqp.rabbit.listener.DirectReplyToMessageListenerContainer
 
removeQueueNames(String...) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer
Remove queues from this container's list of queues.
removeQueueOrTagToMethodName(String) - Method in class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter
Remove the mapping of a queue name or consumer tag to a method name.
removeQueues(Queue...) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
Remove queue(s) from this container's list of queues.
removeQueues(Queue...) - Method in class org.springframework.amqp.rabbit.listener.DirectMessageListenerContainer
 
removeQueues(Queue...) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer
Remove queues from this container's list of queues.
removeReturnListener(ReturnListener) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
 
removeShutdownListener(ShutdownListener) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
 
removeTargetConnectionFactory(Object) - Method in class org.springframework.amqp.rabbit.connection.AbstractRoutingConnectionFactory
Removes the ConnectionFactory associated with the given lookup key and returns it.
removeTestQueues(String...) - Method in class org.springframework.amqp.rabbit.junit.BrokerRunning
Remove any test queues that were created by an BrokerRunning.isRunningWithEmptyQueues(String...) method.
removeTestQueues(String...) - Method in class org.springframework.amqp.rabbit.junit.BrokerRunningSupport
Remove any test queues that were created by an BrokerRunningSupport.isRunningWithEmptyQueues(String...) method.
REPLY_TO - Static variable in class org.springframework.amqp.support.AmqpHeaders
 
replyContentType() - Element in annotation interface org.springframework.amqp.rabbit.annotation.RabbitListener
Used to set the content type of a reply message.
ReplyExpressionRoot(Message, Object, Object) - Constructor for class org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener.ReplyExpressionRoot
 
ReplyFailureException - Exception in org.springframework.amqp.rabbit.listener.adapter
Exception to be thrown when the reply of a message failed to be sent.
ReplyFailureException(String, Throwable) - Constructor for exception org.springframework.amqp.rabbit.listener.adapter.ReplyFailureException
 
ReplyingMessageListener<T,R> - Interface in org.springframework.amqp.rabbit.listener.adapter
A Message Listener that returns a reply - intended for lambda use in a MessageListenerAdapter.
replyPostProcessor() - Element in annotation interface org.springframework.amqp.rabbit.annotation.RabbitListener
The bean name of a ReplyPostProcessor to post process a response before it is sent.
ReplyPostProcessor - Interface in org.springframework.amqp.rabbit.listener.adapter
A post processor for replies.
replyTimedOut(String) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
Subclasses can implement this to be notified that a reply has timed out.
ReplyToAddressCallback<T> - Interface in org.springframework.amqp.core
To be used with the receive-and-reply methods of AmqpTemplate to determine Address for Message to send at runtime.
RepublishMessageRecoverer - Class in org.springframework.amqp.rabbit.retry
MessageRecoverer implementation that republishes recovered messages to a specified exchange with the exception stack trace stored in the message header x-exception.
RepublishMessageRecoverer(AmqpTemplate) - Constructor for class org.springframework.amqp.rabbit.retry.RepublishMessageRecoverer
Create an instance with the provided template.
RepublishMessageRecoverer(AmqpTemplate, String) - Constructor for class org.springframework.amqp.rabbit.retry.RepublishMessageRecoverer
Create an instance with the provided properties.
RepublishMessageRecoverer(AmqpTemplate, String, String) - Constructor for class org.springframework.amqp.rabbit.retry.RepublishMessageRecoverer
Create an instance with the provided properties.
RepublishMessageRecoverer(AmqpTemplate, Expression, Expression) - Constructor for class org.springframework.amqp.rabbit.retry.RepublishMessageRecoverer
Create an instance with the provided properties.
RepublishMessageRecovererWithConfirms - Class in org.springframework.amqp.rabbit.retry
A RepublishMessageRecoverer supporting publisher confirms and returns.
RepublishMessageRecovererWithConfirms(RabbitTemplate, String, String, CachingConnectionFactory.ConfirmType) - Constructor for class org.springframework.amqp.rabbit.retry.RepublishMessageRecovererWithConfirms
Use the supplied template to publish the messsage with the provided confirm type to the provided exchange with the provided routing key.
RepublishMessageRecovererWithConfirms(RabbitTemplate, String, CachingConnectionFactory.ConfirmType) - Constructor for class org.springframework.amqp.rabbit.retry.RepublishMessageRecovererWithConfirms
Use the supplied template to publish the messsage with the provided confirm type to the provided exchange with the default routing key.
RepublishMessageRecovererWithConfirms(RabbitTemplate, CachingConnectionFactory.ConfirmType) - Constructor for class org.springframework.amqp.rabbit.retry.RepublishMessageRecovererWithConfirms
Use the supplied template to publish the messsage with the provided confirm type.
reset() - Method in class org.springframework.amqp.rabbit.support.ActiveObjectCounter
 
reset(List<ChannelProxy>, List<ChannelProxy>, Map<Channel, ChannelProxy>) - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory
 
resetAllManualDeclarations() - Method in class org.springframework.amqp.rabbit.core.RabbitAdmin
Invoke this method to prevent the admin from recovering any declarations made by calls to declare*() methods.
resetConnection() - Method in class org.springframework.amqp.rabbit.connection.AbstractRoutingConnectionFactory
 
resetConnection() - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory
Close the connection(s).
resetConnection() - Method in interface org.springframework.amqp.rabbit.connection.ConnectionFactory
Close any connection(s) that might be cached by this factory.
resetConnection() - Method in class org.springframework.amqp.rabbit.connection.LocalizedQueueConnectionFactory
 
resetConnection() - Method in class org.springframework.amqp.rabbit.connection.PooledChannelConnectionFactory
Close the connection(s).
resetConnection() - Method in class org.springframework.amqp.rabbit.connection.ThreadChannelConnectionFactory
Close the connection(s).
resolveArgument(MethodParameter, Message<?>) - Method in class org.springframework.amqp.rabbit.listener.adapter.ContinuationHandlerMethodArgumentResolver
 
resolveExpressionAsString(String, String) - Method in class org.springframework.amqp.rabbit.annotation.RabbitListenerAnnotationBeanPostProcessor
 
resolveMultiRabbitAdminName(RabbitListener) - Method in class org.springframework.amqp.rabbit.annotation.MultiRabbitListenerAnnotationBeanPostProcessor
Resolves the name of the RabbitAdmin bean based on the RabbitListener, or falls back to the default RabbitAdmin name provided by MultiRabbit.
resolveParameter(ParameterContext, ExtensionContext) - Method in class org.springframework.amqp.rabbit.junit.RabbitAvailableCondition
 
restCall(RestTemplateHolder, String, String, String) - Method in class org.springframework.amqp.rabbit.connection.RestTemplateNodeLocator
 
restCall(WebClient, String, String, String) - Method in class org.springframework.amqp.rabbit.connection.WebFluxNodeLocator
 
restCall(T, String, String, String) - Method in interface org.springframework.amqp.rabbit.connection.NodeLocator
Retrieve a map of queue properties using the RabbitMQ Management REST API.
RestTemplateNodeLocator - Class in org.springframework.amqp.rabbit.connection
RestTemplateNodeLocator() - Constructor for class org.springframework.amqp.rabbit.connection.RestTemplateNodeLocator
 
restUri() - Static method in class org.springframework.amqp.rabbit.junit.AbstractTestContainerTests
 
retrieveHeader(MessageProperties, String) - Method in class org.springframework.amqp.support.converter.AbstractJavaTypeMapper
 
retrieveHeaderAsString(MessageProperties, String) - Method in class org.springframework.amqp.support.converter.AbstractJavaTypeMapper
 
RetryInterceptorBuilder<B extends RetryInterceptorBuilder<B,T>,T extends MethodInterceptor> - Class in org.springframework.amqp.rabbit.config
Simplified facade to make it easier and simpler to build a StatefulRetryOperationsInterceptor or (stateless) RetryOperationsInterceptor by providing a fluent interface to defining the behavior on error.
RetryInterceptorBuilder() - Constructor for class org.springframework.amqp.rabbit.config.RetryInterceptorBuilder
 
RetryInterceptorBuilder.StatefulRetryInterceptorBuilder - Class in org.springframework.amqp.rabbit.config
Builder for a stateful interceptor.
RetryInterceptorBuilder.StatelessRetryInterceptorBuilder - Class in org.springframework.amqp.rabbit.config
Builder for a stateless interceptor.
retryOperations(RetryOperations) - Method in class org.springframework.amqp.rabbit.config.RetryInterceptorBuilder
Apply the retry operations - once this is set, other properties can no longer be set; can't be set if other properties have been applied.
retryPolicy(RetryPolicy) - Method in class org.springframework.amqp.rabbit.config.RetryInterceptorBuilder
Apply the retry policy - cannot be used if a custom retry template has been provided, or the max attempts or back off options or policy have been applied.
RETURN_EXCHANGE - Static variable in class org.springframework.amqp.support.AmqpHeaders
 
RETURN_LISTENER_CORRELATION_KEY - Static variable in interface org.springframework.amqp.rabbit.connection.PublisherCallbackChannel
Header used to determine which listener to invoke for a returned message.
RETURN_REPLY_CODE - Static variable in class org.springframework.amqp.support.AmqpHeaders
 
RETURN_REPLY_TEXT - Static variable in class org.springframework.amqp.support.AmqpHeaders
 
RETURN_ROUTING_KEY - Static variable in class org.springframework.amqp.support.AmqpHeaders
 
RETURNED_MESSAGE_CORRELATION_KEY - Static variable in interface org.springframework.amqp.rabbit.connection.PublisherCallbackChannel
Header used to locate a pending confirm to which to attach a returned message.
returnedMessage(ReturnedMessage) - Method in class org.springframework.amqp.rabbit.AsyncRabbitTemplate
 
returnedMessage(ReturnedMessage) - Method in interface org.springframework.amqp.rabbit.core.RabbitTemplate.ReturnsCallback
Returned message callback.
ReturnedMessage - Class in org.springframework.amqp.core
Returned message and its metadata.
ReturnedMessage(Message, int, String, String, String) - Constructor for class org.springframework.amqp.core.ReturnedMessage
 
returnExceptions() - Element in annotation interface org.springframework.amqp.rabbit.annotation.RabbitListener
Set to "true" to cause exceptions thrown by the listener to be sent to the sender using normal replyTo/@SendTo semantics.
revertLevels(String, JUnitUtils.LevelsContainer) - Static method in class org.springframework.amqp.rabbit.junit.JUnitUtils
 
revoke(Channel) - Method in interface org.springframework.amqp.rabbit.connection.PublisherCallbackChannel.Listener
When called, this listener should remove all references to the channel - it will no longer be invoked by the channel.
revoke(Channel) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
 
rollbackAll() - Method in class org.springframework.amqp.rabbit.connection.RabbitResourceHolder
 
rollbackIfNecessary(Channel) - Static method in class org.springframework.amqp.rabbit.connection.RabbitUtils
 
rollbackOn(Throwable) - Method in class org.springframework.amqp.rabbit.listener.ListenerFailedRuleBasedTransactionAttribute
 
rollbackOnExceptionIfNecessary(Throwable) - Method in class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer
Perform a rollback, handling rollback exceptions properly.
rollbackOnExceptionIfNecessary(Throwable, long) - Method in class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer
Perform a rollback, handling rollback exceptions properly.
RoutingConnectionFactory - Interface in org.springframework.amqp.rabbit.connection
Implementations select a connection factory based on a supplied key.
rpc(Method) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
 
run() - Method in class org.springframework.amqp.rabbit.log4j2.AmqpAppender.EventSender
 
run() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender.EventSender
 
run() - Method in class org.springframework.amqp.rabbit.TimeoutTask
 
run(Runnable) - Method in class org.springframework.amqp.rabbit.connection.ConnectionFactoryContextWrapper
Execute a Runnable binding to the default ConnectionFactory and finally unbinding it.
run(String, Runnable) - Method in class org.springframework.amqp.rabbit.connection.ConnectionFactoryContextWrapper
Execute a Runnable binding the given ConnectionFactory and finally unbinding it.
RUN_LONG_INTEGRATION_TESTS - Static variable in class org.springframework.amqp.rabbit.junit.LongRunningIntegrationTest
 
A B C D E F G H I J K L M N O P Q R S T U V W X Z _ 
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form