R-Index (Spring AMQP 3.1.0-M1 API)

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: Factory of MessageListenerContainers.
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: A NodeLocator using the RestTemplate.
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