Index (Spring AMQP 1.6.0.M1 API)

A B C D E F G H I J L M N O P Q R S T U V W X Z

A

abort() - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl

abort(int, String) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl

AbstractAdaptableMessageListener - Class in org.springframework.amqp.rabbit.listener.adapter

An abstract MessageListener adapter providing the necessary infrastructure to extract the payload of a Message

AbstractAdaptableMessageListener() - Constructor for class org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener

AbstractCompressingPostProcessor - Class in org.springframework.amqp.support.postprocessor

Base class for post processors that compress the message body.

AbstractCompressingPostProcessor() - Constructor for class org.springframework.amqp.support.postprocessor.AbstractCompressingPostProcessor

Construct a post processor that will include the MessageProperties.SPRING_AUTO_DECOMPRESS header set to 'true'.

AbstractCompressingPostProcessor(boolean) - Constructor for class org.springframework.amqp.support.postprocessor.AbstractCompressingPostProcessor

Construct a post processor that will include (or not include) the MessageProperties.SPRING_AUTO_DECOMPRESS header.

AbstractConnectionFactory - Class in org.springframework.amqp.rabbit.connection

AbstractConnectionFactory(ConnectionFactory) - Constructor for class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory

Create a new AbstractConnectionFactory for the given target ConnectionFactory.

AbstractDeclarable - Class in org.springframework.amqp.core

Base class for Declarable classes.

AbstractDeclarable() - Constructor for class org.springframework.amqp.core.AbstractDeclarable

AbstractDecompressingPostProcessor - Class in org.springframework.amqp.support.postprocessor

Base class for post processors that decompress the message body if the MessageProperties.SPRING_AUTO_DECOMPRESS header is true or to optionally always decompress if the content encoding matches AbstractDecompressingPostProcessor.getEncoding(), or starts with AbstractDecompressingPostProcessor.getEncoding() + ":", in which case the encoding following the colon becomes the final content encoding of the decompressed message.

AbstractDecompressingPostProcessor() - Constructor for class org.springframework.amqp.support.postprocessor.AbstractDecompressingPostProcessor

Construct a post processor that will decompress the supported content encoding only if MessageProperties.SPRING_AUTO_DECOMPRESS header is present and true.

AbstractDecompressingPostProcessor(boolean) - Constructor for class org.springframework.amqp.support.postprocessor.AbstractDecompressingPostProcessor

Construct a post processor that will decompress the supported content encoding if MessageProperties.SPRING_AUTO_DECOMPRESS header is present and true or if alwaysDecompress is true.

AbstractDeflaterPostProcessor - Class in org.springframework.amqp.support.postprocessor

Base class for post processors based on Deflater

AbstractDeflaterPostProcessor() - Constructor for class org.springframework.amqp.support.postprocessor.AbstractDeflaterPostProcessor

AbstractDeflaterPostProcessor(boolean) - Constructor for class org.springframework.amqp.support.postprocessor.AbstractDeflaterPostProcessor

AbstractExchange - Class in org.springframework.amqp.core

Common properties that describe all exchange types.

AbstractExchange(String) - Constructor for class org.springframework.amqp.core.AbstractExchange

Construct a new Exchange for bean usage.

AbstractExchange(String, boolean, boolean) - Constructor for class org.springframework.amqp.core.AbstractExchange

Construct a new Exchange, given a name, durability flag, auto-delete flag.

AbstractExchange(String, boolean, boolean, Map<String, Object>) - Constructor for class org.springframework.amqp.core.AbstractExchange

Construct a new Exchange, given a name, durability flag, and auto-delete flag, and arguments.

AbstractExchangeParser - Class in org.springframework.amqp.rabbit.config

AbstractExchangeParser() - Constructor for class org.springframework.amqp.rabbit.config.AbstractExchangeParser

AbstractJavaTypeMapper - Class in org.springframework.amqp.support.converter

AbstractJavaTypeMapper() - Constructor for class org.springframework.amqp.support.converter.AbstractJavaTypeMapper

AbstractJsonMessageConverter - Class in org.springframework.amqp.support.converter

AbstractJsonMessageConverter() - Constructor for class org.springframework.amqp.support.converter.AbstractJsonMessageConverter

AbstractMessageConverter - Class in org.springframework.amqp.support.converter

Convenient base class for MessageConverter implementations.

AbstractMessageConverter() - Constructor for class org.springframework.amqp.support.converter.AbstractMessageConverter

AbstractMessageListenerContainer - Class in org.springframework.amqp.rabbit.listener

AbstractMessageListenerContainer() - Constructor for class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer

AbstractMessageListenerContainer.SharedConnectionNotInitializedException - Exception in org.springframework.amqp.rabbit.listener

Exception that indicates that the initial setup of this container's shared Rabbit Connection failed.

AbstractRabbitListenerContainerFactory<C extends AbstractMessageListenerContainer> - Class in org.springframework.amqp.rabbit.config

Base RabbitListenerContainerFactory for Spring's base container implementation.

AbstractRabbitListenerContainerFactory() - Constructor for class org.springframework.amqp.rabbit.config.AbstractRabbitListenerContainerFactory

AbstractRabbitListenerEndpoint - Class in org.springframework.amqp.rabbit.listener

Base model for a Rabbit listener endpoint

AbstractRabbitListenerEndpoint() - Constructor for class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint

AbstractRetryOperationsInterceptorFactoryBean - Class in org.springframework.amqp.rabbit.config

Convenient base class for interceptor factories.

AbstractRetryOperationsInterceptorFactoryBean() - Constructor for class org.springframework.amqp.rabbit.config.AbstractRetryOperationsInterceptorFactoryBean

AbstractRoutingConnectionFactory - Class in org.springframework.amqp.rabbit.connection

Abstract ConnectionFactory implementation that routes AbstractRoutingConnectionFactory.createConnection() calls to one of various target ConnectionFactories based on a lookup key.

AbstractRoutingConnectionFactory() - Constructor for class org.springframework.amqp.rabbit.connection.AbstractRoutingConnectionFactory

AcknowledgeMode - Enum in org.springframework.amqp.core

activateOptions() - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender

ActiveObjectCounter<T> - Class in org.springframework.amqp.rabbit.listener

ActiveObjectCounter() - Constructor for class org.springframework.amqp.rabbit.listener.ActiveObjectCounter

add(T) - Method in class org.springframework.amqp.rabbit.listener.ActiveObjectCounter

addAndStartConsumers(int) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer

addArgument(String, Object) - Method in class org.springframework.amqp.core.AbstractExchange

addChannel(Channel) - Method in class org.springframework.amqp.rabbit.connection.RabbitResourceHolder

addChannel(Channel, Connection) - Method in class org.springframework.amqp.rabbit.connection.RabbitResourceHolder

addChannelListener(ChannelListener) - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory

addConfirmListener(ConfirmListener) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl

addConnection(Connection) - Method in class org.springframework.amqp.rabbit.connection.RabbitResourceHolder

addConnectionListener(ConnectionListener) - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory

addConnectionListener(ConnectionListener) - Method in class org.springframework.amqp.rabbit.connection.AbstractRoutingConnectionFactory

addConnectionListener(ConnectionListener) - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory

addConnectionListener(ConnectionListener) - Method in interface org.springframework.amqp.rabbit.connection.ConnectionFactory

addConnectionListener(ConnectionListener) - Method in class org.springframework.amqp.rabbit.connection.LocalizedQueueConnectionFactory

addConstructorArgBooleanValueIfAttributeDefined(BeanDefinitionBuilder, Element, String, boolean) - Static method in class org.springframework.amqp.rabbit.config.NamespaceUtils

Populates the bean definition constructor argument with the boolean value of that attribute if it is defined in the given element or else uses the default provided.

addConstructorArgParentRefIfAttributeDefined(BeanDefinitionBuilder, Element, String) - Static method in class org.springframework.amqp.rabbit.config.NamespaceUtils

Populates the bean definition constructor argument with a reference to a bean with parent id equal to the attribute if it is defined in the given element.

addConstructorArgRefIfAttributeDefined(BeanDefinitionBuilder, Element, String) - Static method in class org.springframework.amqp.rabbit.config.NamespaceUtils

Populates the bean definition constructor argument with a reference to a bean with id equal to the attribute if it is defined in the given element.

addConstructorArgValueIfAttributeDefined(BeanDefinitionBuilder, Element, String) - Static method in class org.springframework.amqp.rabbit.config.NamespaceUtils

Populates the bean definition constructor argument with the value of that attribute if it is defined in the given element.

addDecompressor(String, MessagePostProcessor) - Method in class org.springframework.amqp.support.postprocessor.DelegatingDecompressingPostProcessor

Add a message post processor to the map of decompressing MessageProcessors.

addDelegate(ChannelListener) - Method in class org.springframework.amqp.rabbit.connection.CompositeChannelListener

addDelegate(ConnectionListener) - Method in class org.springframework.amqp.rabbit.connection.CompositeConnectionListener

addDelegate(String, MessageConverter) - Method in class org.springframework.amqp.support.converter.ContentTypeDelegatingMessageConverter

addDelgate(String, MessageConverter) - Method in class org.springframework.amqp.support.converter.ContentTypeDelegatingMessageConverter

Deprecated.

in favor of ContentTypeDelegatingMessageConverter.addDelegate(String, MessageConverter)

addDeliveryTag(Channel, long) - Method in class org.springframework.amqp.rabbit.connection.RabbitResourceHolder

addExchange(Exchange) - Method in interface org.springframework.amqp.core.AmqpManagementOperations

Add an exchange to the default vhost ('/').

addExchange(String, Exchange) - Method in interface org.springframework.amqp.core.AmqpManagementOperations

Add an exchange to the specified vhost.

addExchange(Exchange) - Method in class org.springframework.amqp.rabbit.core.RabbitManagementTemplate

addExchange(String, Exchange) - Method in class org.springframework.amqp.rabbit.core.RabbitManagementTemplate

addFlowListener(FlowListener) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl

addHeader(MessageProperties, String, Class<?>) - Method in class org.springframework.amqp.support.converter.AbstractJavaTypeMapper

additionalHeaders(Message, Throwable) - Method in class org.springframework.amqp.rabbit.retry.RepublishMessageRecoverer

Subclasses can override this method to add more headers to the republished message.

addListener(PublisherCallbackChannel.Listener) - Method in interface org.springframework.amqp.rabbit.support.PublisherCallbackChannel

Adds a PublisherCallbackChannel.Listener

addListener(PublisherCallbackChannel.Listener) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl

Add the listener and return the internal map of pending confirmations for that listener.

addPendingConfirm(PublisherCallbackChannel.Listener, long, PendingConfirm) - Method in interface org.springframework.amqp.rabbit.support.PublisherCallbackChannel

Adds a pending confirmation to this channel's map.

addPendingConfirm(PublisherCallbackChannel.Listener, long, PendingConfirm) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl

addQueue(Queue) - Method in interface org.springframework.amqp.core.AmqpManagementOperations

Add a queue to the default vhost ('/').

addQueue(String, Queue) - Method in interface org.springframework.amqp.core.AmqpManagementOperations

Add a queue to the specified vhost.

addQueue(Queue) - Method in class org.springframework.amqp.rabbit.core.RabbitManagementTemplate

addQueue(String, Queue) - Method in class org.springframework.amqp.rabbit.core.RabbitManagementTemplate

addQueueNames(String...) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer

Add queue(s) to this container's list of queues.

addQueueNames(String...) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer

Add queue(s) to this container's list of queues.

addQueueOrTagToMethodName(String, String) - Method in class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter

Add the mapping of a queue name or consumer tag to a method name.

addQueues(Queue...) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer

Add queue(s) to this container's list of queues.

addQueues(Queue...) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer

Add queue(s) to this container's list of queues.

Address - Class in org.springframework.amqp.core

Represents an address for publication of an AMQP message.

Address(String) - Constructor for class org.springframework.amqp.core.Address

Create an Address instance from a structured String in the form

 (exchange)/(routingKey)

Address(String, String, String) - Constructor for class org.springframework.amqp.core.Address

Deprecated.

Address(String, String) - Constructor for class org.springframework.amqp.core.Address

Create an Address given the exchange name and routing key.

AddressUtils - Class in org.springframework.amqp.core

Deprecated.

AddressUtils() - Constructor for class org.springframework.amqp.core.AddressUtils

Deprecated.

addReturnListener(ReturnListener) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl

addShutdownListener(ShutdownListener) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl

addTargetConnectionFactory(Object, ConnectionFactory) - Method in class org.springframework.amqp.rabbit.connection.AbstractRoutingConnectionFactory

Adds the given ConnectionFactory and associates it with the given lookup key

addToBatch(String, String, Message) - Method in interface org.springframework.amqp.rabbit.core.support.BatchingStrategy

Add a message to the batch and optionally release the batch.

addToBatch(String, String, Message) - Method in class org.springframework.amqp.rabbit.core.support.SimpleBatchingStrategy

afterPropertiesSet() - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory

afterPropertiesSet() - Method in class org.springframework.amqp.rabbit.connection.RabbitAccessor

afterPropertiesSet() - Method in class org.springframework.amqp.rabbit.core.RabbitAdmin

If autoStartup is set to true, registers a callback on the ConnectionFactory to declare all exchanges and queues in the enclosing application context.

afterPropertiesSet() - Method in class org.springframework.amqp.rabbit.core.RabbitGatewaySupport

afterPropertiesSet() - Method in class org.springframework.amqp.rabbit.core.RabbitMessagingTemplate

afterPropertiesSet() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer

Delegates to AbstractMessageListenerContainer.validateConfiguration() and AbstractMessageListenerContainer.initialize().

afterPropertiesSet() - Method in class org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistrar

afterPropertiesSet() - Method in class org.springframework.amqp.rabbit.transaction.RabbitTransactionManager

Make sure the ConnectionFactory has been set.

afterPropertiesSet() - Method in class org.springframework.amqp.remoting.client.AmqpProxyFactoryBean

afterPropertiesSet() - Method in class org.springframework.amqp.support.converter.AbstractJavaTypeMapper

afterPropertiesSet() - Method in class org.springframework.amqp.support.converter.DefaultClassMapper

afterPropertiesSet() - Method in class org.springframework.amqp.support.converter.MarshallingMessageConverter

afterPropertiesSet() - Method in class org.springframework.amqp.support.converter.MessagingMessageConverter

afterSingletonsInstantiated() - Method in class org.springframework.amqp.rabbit.annotation.RabbitListenerAnnotationBeanPostProcessor

AMQ_RABBITMQ_REPLY_TO - Static variable in class org.springframework.amqp.core.Address

Use this value in RabbitTemplate#setReplyAddress(String) to explicitly indicate that direct reply-to is to be used.

AMQ_RABBITMQ_REPLY_TO - Static variable in class org.springframework.amqp.core.AddressUtils

Deprecated.

Use the constant in Address.AMQ_RABBITMQ_REPLY_TO.

AmqpAdmin - Interface in org.springframework.amqp.core

Specifies a basic set of portable AMQP administrative operations for AMQP > 0.8

AmqpAppender - Class in org.springframework.amqp.rabbit.log4j

A Log4J appender that publishes logging events to an AMQP Exchange.

AmqpAppender() - Constructor for class org.springframework.amqp.rabbit.log4j.AmqpAppender

AmqpAppender - Class in org.springframework.amqp.rabbit.log4j2

A Log4j 2 appender that publishes logging events to an AMQP Exchange.

AmqpAppender(String, Filter, Layout<? extends Serializable>, boolean, AmqpAppender.AmqpManager) - Constructor for class org.springframework.amqp.rabbit.log4j2.AmqpAppender

AmqpAppender - Class in org.springframework.amqp.rabbit.logback

A Lockback appender that publishes logging events to an AMQP Exchange.

AmqpAppender() - Constructor for class org.springframework.amqp.rabbit.logback.AmqpAppender

AmqpAppender.Event - Class in org.springframework.amqp.rabbit.log4j

Small helper class to encapsulate a LoggingEvent, its MDC properties, and the number of retries.

AmqpAppender.Event - Class in org.springframework.amqp.rabbit.log4j2

Helper class to encapsulate a LoggingEvent, its MDC properties, and the number of retries.

AmqpAppender.Event - Class in org.springframework.amqp.rabbit.logback

Small helper class to encapsulate a LoggingEvent, its MDC properties, and the number of retries.

AmqpAppender.EventSender - Class in org.springframework.amqp.rabbit.log4j

Helper class to actually send LoggingEvents asynchronously.

AmqpAppender.EventSender - Class in org.springframework.amqp.rabbit.log4j2

Helper class to actually send LoggingEvents asynchronously.

AmqpAppender.EventSender - Class in org.springframework.amqp.rabbit.logback

Helper class to actually send LoggingEvents asynchronously.

AmqpAuthenticationException - Exception in org.springframework.amqp

Runtime wrapper for an authentication exception.

AmqpAuthenticationException(Throwable) - Constructor for exception org.springframework.amqp.AmqpAuthenticationException

AmqpClientInterceptor - Class in org.springframework.amqp.remoting.client

MethodInterceptor for accessing RMI-style AMQP services.

AmqpClientInterceptor() - Constructor for class org.springframework.amqp.remoting.client.AmqpClientInterceptor

AmqpConnectException - Exception in org.springframework.amqp

RuntimeException wrapper for an ConnectException which can be commonly thrown from AMQP operations if the remote process dies or there is a network issue.

AmqpConnectException(Exception) - Constructor for exception org.springframework.amqp.AmqpConnectException

AmqpEvent - Class in org.springframework.amqp.event

Base class for events.

AmqpEvent(Object) - Constructor for class org.springframework.amqp.event.AmqpEvent

AmqpException - Exception in org.springframework.amqp

Base RuntimeException for errors that occur when executing AMQP operations.

AmqpException(String) - Constructor for exception org.springframework.amqp.AmqpException

AmqpException(Throwable) - Constructor for exception org.springframework.amqp.AmqpException

AmqpException(String, Throwable) - Constructor for exception org.springframework.amqp.AmqpException

AmqpHeaderMapper - Interface in org.springframework.amqp.support

Strategy interface for mapping messaging Message headers to an outbound MessageProperties (e.g.

AmqpHeaders - Class in org.springframework.amqp.support

Pre-defined names and prefixes to be used for setting and/or retrieving AMQP MessageProperties from/to Message Headers.

AmqpHeaders() - Constructor for class org.springframework.amqp.support.AmqpHeaders

AmqpIllegalStateException - Exception in org.springframework.amqp

Equivalent of an IllegalStateException but within the AmqpException hierarchy.

AmqpIllegalStateException(String) - Constructor for exception org.springframework.amqp.AmqpIllegalStateException

AmqpIllegalStateException(String, Throwable) - Constructor for exception org.springframework.amqp.AmqpIllegalStateException

AmqpInvokerServiceExporter - Class in org.springframework.amqp.remoting.service

This message listener exposes a plain java service via AMQP.

AmqpInvokerServiceExporter() - Constructor for class org.springframework.amqp.remoting.service.AmqpInvokerServiceExporter

AmqpIOException - Exception in org.springframework.amqp

RuntimeException wrapper for an IOException which can be commonly thrown from AMQP operations.

AmqpIOException(IOException) - Constructor for exception org.springframework.amqp.AmqpIOException

AmqpManagementOperations - Interface in org.springframework.amqp.core

Interface specifying management operations.

AmqpMessageHeaderAccessor - Class in org.springframework.amqp.support

A MessageHeaderAccessor implementation giving access to AMQP-specific headers.

AmqpMessageHeaderAccessor(Map<String, List<String>>) - Constructor for class org.springframework.amqp.support.AmqpMessageHeaderAccessor

AmqpMessageHeaderAccessor(Message<?>) - Constructor for class org.springframework.amqp.support.AmqpMessageHeaderAccessor

AmqpMessageReturnedException - Exception in org.springframework.amqp.core

Exception thrown in an RPC scenario if the request message cannot be delivered when the mandatory flag is set.

AmqpMessageReturnedException(String, Message, int, String, String, String) - Constructor for exception org.springframework.amqp.core.AmqpMessageReturnedException

AmqpProxyFactoryBean - Class in org.springframework.amqp.remoting.client

FactoryBean for AMQP proxies.

AmqpProxyFactoryBean() - Constructor for class org.springframework.amqp.remoting.client.AmqpProxyFactoryBean

AmqpRejectAndDontRequeueException - Exception in org.springframework.amqp

Exception for listener implementations used to indicate the basic.reject will be sent with requeue=false in order to enable features such as DLQ.

AmqpRejectAndDontRequeueException(String, Throwable) - Constructor for exception org.springframework.amqp.AmqpRejectAndDontRequeueException

AmqpRejectAndDontRequeueException(String) - Constructor for exception org.springframework.amqp.AmqpRejectAndDontRequeueException

AmqpRejectAndDontRequeueException(Throwable) - Constructor for exception org.springframework.amqp.AmqpRejectAndDontRequeueException

AmqpTemplate - Interface in org.springframework.amqp.core

Specifies a basic set of AMQP operations.

AmqpTimeoutException - Exception in org.springframework.amqp

Exception thrown when some time-bound operation fails to execute in the desired time.

AmqpTimeoutException(String, Throwable) - Constructor for exception org.springframework.amqp.AmqpTimeoutException

AmqpTimeoutException(String) - Constructor for exception org.springframework.amqp.AmqpTimeoutException

AmqpTimeoutException(Throwable) - Constructor for exception org.springframework.amqp.AmqpTimeoutException

AmqpUnsupportedEncodingException - Exception in org.springframework.amqp

RuntimeException for unsupported encoding in an AMQP operation.

AmqpUnsupportedEncodingException(Throwable) - Constructor for exception org.springframework.amqp.AmqpUnsupportedEncodingException

and(Map<String, Object>) - Method in class org.springframework.amqp.core.BindingBuilder.GenericArgumentsConfigurer

andProperties(MessageProperties) - Method in class org.springframework.amqp.core.MessageBuilder

Makes this builder's properties builder use a reference to properties.

AnonymousQueue - Class in org.springframework.amqp.core

Represents an anonymous, non-durable, exclusive, auto-delete queue.

AnonymousQueue() - Constructor for class org.springframework.amqp.core.AnonymousQueue

Construct a queue with a UUID name.

AnonymousQueue(Map<String, Object>) - Constructor for class org.springframework.amqp.core.AnonymousQueue

Construct a queue with a UUID name with the supplied arguments.

AnonymousQueue(AnonymousQueue.NamingStrategy) - Constructor for class org.springframework.amqp.core.AnonymousQueue

Construct a queue with a name provided by the supplied naming strategy.

AnonymousQueue(AnonymousQueue.NamingStrategy, Map<String, Object>) - Constructor for class org.springframework.amqp.core.AnonymousQueue

Construct a queue with a name provided by the supplied naming strategy with the supplied arguments.

AnonymousQueue.Base64UrlNamingStrategy - Class in org.springframework.amqp.core

Generates names with the form <prefix><base64url> where 'prefix' is 'spring.gen-' by default; the 'base64url' String is generated from a UUID.

AnonymousQueue.NamingStrategy - Interface in org.springframework.amqp.core

A strategy to name anonymous queues

answer(InvocationOnMock) - Method in class org.springframework.amqp.rabbit.test.mockito.LambdaAnswer

answer(InvocationOnMock) - Method in class org.springframework.amqp.rabbit.test.mockito.LatchCountDownAndCallRealMethodAnswer

APP_ID - Static variable in class org.springframework.amqp.support.AmqpHeaders

append(LoggingEvent) - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender

append(LogEvent) - Method in class org.springframework.amqp.rabbit.log4j2.AmqpAppender

append(ILoggingEvent) - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender

APPLICATION_ID - Static variable in class org.springframework.amqp.rabbit.log4j.AmqpAppender

Key name for the application id (if there is one set via the appender config) in the message properties.

APPLICATION_ID - Static variable in class org.springframework.amqp.rabbit.log4j2.AmqpAppender

Key name for the application id (if there is one set via the appender config) in the message properties.

APPLICATION_ID - Static variable in class org.springframework.amqp.rabbit.logback.AmqpAppender

Key name for the application id (if there is one set via the appender config) in the message properties.

apply(InvocationOnMock, T) - Method in interface org.springframework.amqp.rabbit.test.mockito.LambdaAnswer.ValueToReturn

applyCommonSettings(AbstractRetryOperationsInterceptorFactoryBean) - Method in class org.springframework.amqp.rabbit.config.RetryInterceptorBuilder

AsyncRabbitTemplate - Class in org.springframework.amqp.rabbit.core

Provides asynchronous send and receive operations returning a ListenableFuture allowing the caller to obtain the reply later, using get() or a callback.

AsyncRabbitTemplate(ConnectionFactory, String, String, String) - Constructor for class org.springframework.amqp.rabbit.core.AsyncRabbitTemplate

Construct an instance using the provided arguments.

AsyncRabbitTemplate(ConnectionFactory, String, String, String, String) - Constructor for class org.springframework.amqp.rabbit.core.AsyncRabbitTemplate

Construct an instance using the provided arguments.

AsyncRabbitTemplate(RabbitTemplate, SimpleMessageListenerContainer) - Constructor for class org.springframework.amqp.rabbit.core.AsyncRabbitTemplate

Construct an instance using the provided arguments.

AsyncRabbitTemplate(RabbitTemplate, SimpleMessageListenerContainer, String) - Constructor for class org.springframework.amqp.rabbit.core.AsyncRabbitTemplate

Construct an instance using the provided arguments.

AsyncRabbitTemplate.RabbitConverterFuture<C> - Class in org.springframework.amqp.rabbit.core

A AsyncRabbitTemplate.RabbitFuture with a return type of the template's generic parameter.

AsyncRabbitTemplate.RabbitFuture<T> - Class in org.springframework.amqp.rabbit.core

Base class for ListenableFutures returned by AsyncRabbitTemplate.

AsyncRabbitTemplate.RabbitMessageFuture - Class in org.springframework.amqp.rabbit.core

A AsyncRabbitTemplate.RabbitFuture with a return type of Message.

asyncRpc(Method) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl

await(Long, TimeUnit) - Method in class org.springframework.amqp.rabbit.listener.ActiveObjectCounter

B

backOffOptions(long, double, long) - Method in class org.springframework.amqp.rabbit.config.RetryInterceptorBuilder: Apply the backoff options.
backOffOptions(long, double, long) - Method in class org.springframework.amqp.rabbit.config.RetryInterceptorBuilder.StatefulRetryInterceptorBuilder
backOffPolicy(BackOffPolicy) - Method in class org.springframework.amqp.rabbit.config.RetryInterceptorBuilder: Apply the back off policy.
backOffPolicy(BackOffPolicy) - Method in class org.springframework.amqp.rabbit.config.RetryInterceptorBuilder.StatefulRetryInterceptorBuilder
Base64UrlNamingStrategy() - Constructor for class org.springframework.amqp.core.AnonymousQueue.Base64UrlNamingStrategy: Construct an instance using the default prefix spring.gen-.
Base64UrlNamingStrategy(String) - Constructor for class org.springframework.amqp.core.AnonymousQueue.Base64UrlNamingStrategy: Construct an instance using the supplied prefix.
basicAck(long, boolean) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
basicCancel() - Method in class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer
basicCancel(String) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
basicConsume(String, Consumer) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
basicConsume(String, boolean, Consumer) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
basicConsume(String, boolean, String, Consumer) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
basicConsume(String, boolean, Map<String, Object>, Consumer) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl: Added to the 3.3.x client
basicConsume(String, boolean, String, boolean, boolean, Map<String, Object>, Consumer) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
basicGet(String, boolean) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
basicNack(long, boolean, boolean) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
basicPublish(String, String, AMQP.BasicProperties, byte[]) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
basicPublish(String, String, boolean, boolean, AMQP.BasicProperties, byte[]) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
basicPublish(String, String, boolean, AMQP.BasicProperties, byte[]) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
basicQos(int, int, boolean) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
basicQos(int, boolean) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl: Added to the 3.3.x client
basicQos(int) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
basicRecover() - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
basicRecover(boolean) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
basicReject(long, boolean) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
BATCH_FORMAT_LENGTH_HEADER4 - Static variable in class org.springframework.amqp.core.MessageProperties
BatchingRabbitTemplate - Class in org.springframework.amqp.rabbit.core: A RabbitTemplate that permits batching individual messages into a larger message.
BatchingRabbitTemplate(BatchingStrategy, TaskScheduler) - Constructor for class org.springframework.amqp.rabbit.core.BatchingRabbitTemplate
BatchingStrategy - Interface in org.springframework.amqp.rabbit.core.support: Strategy for batching messages.
bind(Queue) - Static method in class org.springframework.amqp.core.BindingBuilder
bind(Exchange) - Static method in class org.springframework.amqp.core.BindingBuilder
bind(Object, Object) - Static method in class org.springframework.amqp.rabbit.connection.SimpleResourceHolder: Bind the given resource for the given key to the current thread.
Binding - Class in org.springframework.amqp.core: Simple container collecting information to describe a binding.
Binding(String, Binding.DestinationType, String, String, Map<String, Object>) - Constructor for class org.springframework.amqp.core.Binding
Binding.DestinationType - Enum in org.springframework.amqp.core
BINDING_ARGUMENTS - Static variable in class org.springframework.amqp.rabbit.config.AbstractExchangeParser
BINDING_EXCHANGE_ATTR - Static variable in class org.springframework.amqp.rabbit.config.AbstractExchangeParser
BINDING_QUEUE_ATTR - Static variable in class org.springframework.amqp.rabbit.config.AbstractExchangeParser
BindingBuilder - Class in org.springframework.amqp.core: Basic builder class to create bindings for a more fluent API style in code based configuration.
BindingBuilder() - Constructor for class org.springframework.amqp.core.BindingBuilder
BindingBuilder.DestinationConfigurer - Class in org.springframework.amqp.core
BindingBuilder.DirectExchangeRoutingKeyConfigurer - Class in org.springframework.amqp.core
BindingBuilder.GenericArgumentsConfigurer - Class in org.springframework.amqp.core
BindingBuilder.GenericExchangeRoutingKeyConfigurer - Class in org.springframework.amqp.core
BindingBuilder.HeadersExchangeMapConfigurer - Class in org.springframework.amqp.core
BindingBuilder.HeadersExchangeMapConfigurer.HeadersExchangeKeysBindingCreator - Class in org.springframework.amqp.core
BindingBuilder.HeadersExchangeMapConfigurer.HeadersExchangeMapBindingCreator - Class in org.springframework.amqp.core
BindingBuilder.HeadersExchangeMapConfigurer.HeadersExchangeSingleValueBindingCreator - Class in org.springframework.amqp.core
BindingBuilder.TopicExchangeRoutingKeyConfigurer - Class in org.springframework.amqp.core
BindingFactoryBean - Class in org.springframework.amqp.rabbit.config
BindingFactoryBean() - Constructor for class org.springframework.amqp.rabbit.config.BindingFactoryBean
bindResourceToTransaction(RabbitResourceHolder, ConnectionFactory, boolean) - Static method in class org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils
BlockingQueueConsumer - Class in org.springframework.amqp.rabbit.listener: Specialized consumer encapsulating knowledge of the broker connections and having its own lifecycle (start and stop).
BlockingQueueConsumer(ConnectionFactory, MessagePropertiesConverter, ActiveObjectCounter<BlockingQueueConsumer>, AcknowledgeMode, boolean, int, String...) - Constructor for class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer: Create a consumer.
BlockingQueueConsumer(ConnectionFactory, MessagePropertiesConverter, ActiveObjectCounter<BlockingQueueConsumer>, AcknowledgeMode, boolean, int, boolean, String...) - Constructor for class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer: Create a consumer.
BlockingQueueConsumer(ConnectionFactory, MessagePropertiesConverter, ActiveObjectCounter<BlockingQueueConsumer>, AcknowledgeMode, boolean, int, boolean, Map<String, Object>, String...) - Constructor for class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer: Create a consumer.
BlockingQueueConsumer(ConnectionFactory, MessagePropertiesConverter, ActiveObjectCounter<BlockingQueueConsumer>, AcknowledgeMode, boolean, int, boolean, Map<String, Object>, boolean, String...) - Constructor for class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer: Create a consumer.
build() - Method in class org.springframework.amqp.core.MessageBuilder
build() - Method in class org.springframework.amqp.core.MessageBuilderSupport
build() - Method in class org.springframework.amqp.core.MessagePropertiesBuilder
build() - Method in class org.springframework.amqp.rabbit.config.RetryInterceptorBuilder
build() - Method in class org.springframework.amqp.rabbit.config.RetryInterceptorBuilder.StatefulRetryInterceptorBuilder
build() - Method in class org.springframework.amqp.rabbit.config.RetryInterceptorBuilder.StatelessRetryInterceptorBuilder
buildListenerArguments(Object) - Method in class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter: Build an array of arguments to be passed into the target listener method.
buildMessage(Channel, Object) - Method in class org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener: Build a Rabbit message to be sent as response based on the given result object.
buildMessage(Channel, Object) - Method in class org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter: Build a Rabbit message to be sent as response based on the given result object.
buildProperties() - Method in class org.springframework.amqp.core.MessageBuilderSupport

C

CachingConnectionFactory - Class in org.springframework.amqp.rabbit.connection: A ConnectionFactory implementation that (when the cache mode is CachingConnectionFactory.CacheMode.CHANNEL (default) returns the same Connection from all CachingConnectionFactory.createConnection() calls, and ignores calls to Connection.close() and caches Channel.
CachingConnectionFactory() - Constructor for class org.springframework.amqp.rabbit.connection.CachingConnectionFactory: Create a new CachingConnectionFactory initializing the hostname to be the value returned from InetAddress.getLocalHost(), or "localhost" if getLocalHost() throws an exception.
CachingConnectionFactory(String, int) - Constructor for class org.springframework.amqp.rabbit.connection.CachingConnectionFactory: Create a new CachingConnectionFactory given a host name and port.
CachingConnectionFactory(URI) - Constructor for class org.springframework.amqp.rabbit.connection.CachingConnectionFactory: Create a new CachingConnectionFactory given a URI.
CachingConnectionFactory(int) - Constructor for class org.springframework.amqp.rabbit.connection.CachingConnectionFactory: Create a new CachingConnectionFactory given a port on the hostname returned from InetAddress.getLocalHost(), or "localhost" if getLocalHost() throws an exception.
CachingConnectionFactory(String) - Constructor for class org.springframework.amqp.rabbit.connection.CachingConnectionFactory: Create a new CachingConnectionFactory given a host name.
CachingConnectionFactory(ConnectionFactory) - Constructor for class org.springframework.amqp.rabbit.connection.CachingConnectionFactory: Create a new CachingConnectionFactory for the given target ConnectionFactory.
CachingConnectionFactory.CacheMode - Enum in org.springframework.amqp.rabbit.connection
cancel(boolean) - Method in class org.springframework.amqp.rabbit.core.AsyncRabbitTemplate.RabbitFuture
CATEGORY_LEVEL - Static variable in class org.springframework.amqp.rabbit.log4j.AmqpAppender: Key name for the logger level name in the message properties
CATEGORY_LEVEL - Static variable in class org.springframework.amqp.rabbit.log4j2.AmqpAppender: Key name for the logger level name in the message properties
CATEGORY_LEVEL - Static variable in class org.springframework.amqp.rabbit.logback.AmqpAppender: Key name for the logger level name in the message properties
CATEGORY_NAME - Static variable in class org.springframework.amqp.rabbit.log4j.AmqpAppender: Key name for the logger category name in the message properties
CATEGORY_NAME - Static variable in class org.springframework.amqp.rabbit.log4j2.AmqpAppender: Key name for the logger category name in the message properties
CATEGORY_NAME - Static variable in class org.springframework.amqp.rabbit.logback.AmqpAppender: Key name for the logger category name in the message properties
CHANNEL - Static variable in class org.springframework.amqp.support.AmqpHeaders
ChannelAwareMessageListener - Interface in org.springframework.amqp.rabbit.core: A message listener that is aware of the Channel on which the message was received.
ChannelCallback<T> - Interface in org.springframework.amqp.rabbit.core: Basic callback for use in RabbitTemplate
ChannelListener - Interface in org.springframework.amqp.rabbit.connection
ChannelProxy - Interface in org.springframework.amqp.rabbit.connection: Subinterface of Channel to be implemented by Channel proxies.
checkMessageListener(Object) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer: Check the given message listener, throwing an exception if it does not correspond to a supported listener type.
ClassMapper - Interface in org.springframework.amqp.support.converter: Strategy for setting metadata on messages such that one can create the class that needs to be instantiated when receiving a message.
clear() - Static method in class org.springframework.amqp.rabbit.connection.SimpleResourceHolder: Clear resources for the current thread.
clearConfirmListeners() - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
clearConnectionListeners() - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
clearConnectionListeners() - Method in class org.springframework.amqp.rabbit.connection.AbstractRoutingConnectionFactory
clearConnectionListeners() - Method in interface org.springframework.amqp.rabbit.connection.ConnectionFactory
clearConnectionListeners() - Method in class org.springframework.amqp.rabbit.connection.LocalizedQueueConnectionFactory
clearDelegates() - Method in class org.springframework.amqp.rabbit.connection.CompositeConnectionListener
clearFlowListeners() - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
clearReturnListeners() - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
close() - Method in interface org.springframework.amqp.rabbit.connection.Connection: Close this connection and all its channels with the AMQP.REPLY_SUCCESS close code and message 'OK'.
close() - Method in class org.springframework.amqp.rabbit.connection.SimpleConnection
close() - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender
close(int, String) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
close() - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
closeAll() - Method in class org.springframework.amqp.rabbit.connection.RabbitResourceHolder
closeChannel(Channel) - Static method in class org.springframework.amqp.rabbit.connection.RabbitUtils: Close the given RabbitMQ Channel and ignore any thrown exception.
closeConnection(Connection) - Static method in class org.springframework.amqp.rabbit.connection.RabbitUtils: Close the given RabbitMQ Connection and ignore any thrown exception.
closeMessageConsumer(Channel, Collection<String>, boolean) - Static method in class org.springframework.amqp.rabbit.connection.RabbitUtils
CLUSTER_ID - Static variable in class org.springframework.amqp.support.AmqpHeaders
commitAll() - Method in class org.springframework.amqp.rabbit.connection.RabbitResourceHolder
commitIfNecessary(Channel) - Static method in class org.springframework.amqp.rabbit.connection.RabbitUtils: Commit the Channel if not within a JTA transaction.
commitIfNecessary(boolean) - Method in class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer: Perform a commit or message acknowledgement, as appropriate.
CompositeChannelListener - Class in org.springframework.amqp.rabbit.connection
CompositeChannelListener() - Constructor for class org.springframework.amqp.rabbit.connection.CompositeChannelListener
CompositeConnectionListener - Class in org.springframework.amqp.rabbit.connection
CompositeConnectionListener() - Constructor for class org.springframework.amqp.rabbit.connection.CompositeConnectionListener
ConditionalExceptionLogger - Interface in org.springframework.amqp.support: For components that support customization of the logging of certain events, users can provide an implementation of this interface to modify the existing logging behavior.
ConditionalRejectingErrorHandler - Class in org.springframework.amqp.rabbit.listener: ErrorHandler that conditionally wraps the Exception in an AmqpRejectAndDontRequeueException if the configured rejection strategy determines that the message is fatal and should not be requeued.
ConditionalRejectingErrorHandler() - Constructor for class org.springframework.amqp.rabbit.listener.ConditionalRejectingErrorHandler: Create a handler with the ConditionalRejectingErrorHandler.DefaultExceptionStrategy.
ConditionalRejectingErrorHandler(FatalExceptionStrategy) - Constructor for class org.springframework.amqp.rabbit.listener.ConditionalRejectingErrorHandler: Create a handler with the supplied FatalExceptionStrategy implementation.
configureListenerAdapter(MessagingMessageListenerAdapter) - Method in class org.springframework.amqp.rabbit.listener.MethodRabbitListenerEndpoint: Create a HandlerAdapter for this listener adapter.
configureListenerAdapter(MessagingMessageListenerAdapter) - Method in class org.springframework.amqp.rabbit.listener.MultiMethodRabbitListenerEndpoint
configureRabbitListeners(RabbitListenerEndpointRegistrar) - Method in interface org.springframework.amqp.rabbit.annotation.RabbitListenerConfigurer: Callback allowing a RabbitListenerEndpointRegistry and specific RabbitListenerEndpoint instances to be registered against the given RabbitListenerEndpointRegistrar.
confirm(CorrelationData, boolean, String) - Method in class org.springframework.amqp.rabbit.core.AsyncRabbitTemplate
confirm(CorrelationData, boolean, String) - Method in interface org.springframework.amqp.rabbit.core.RabbitTemplate.ConfirmCallback: Confirmation callback.
confirmSelect() - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
Connection - Interface in org.springframework.amqp.rabbit.connection
ConnectionFactory - Interface in org.springframework.amqp.rabbit.connection: An interface based ConnectionFactory for creating Connections.
connectionFactory - Variable in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
ConnectionFactoryUtils - Class in org.springframework.amqp.rabbit.connection: Helper class for managing a Spring based Rabbit ConnectionFactory, in particular for obtaining transactional Rabbit resources for a given ConnectionFactory.
ConnectionFactoryUtils() - Constructor for class org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils
ConnectionFactoryUtils.ResourceFactory - Interface in org.springframework.amqp.rabbit.connection: Callback interface for resource creation.
ConnectionListener - Interface in org.springframework.amqp.rabbit.connection
ConnectionProxy - Interface in org.springframework.amqp.rabbit.connection: Subinterface of Connection to be implemented by Connection proxies.
CONSUMER_QUEUE - Static variable in class org.springframework.amqp.support.AmqpHeaders: The queue from which the listener container consumer received the message.
CONSUMER_TAG - Static variable in class org.springframework.amqp.support.AmqpHeaders: The tag of the listener container consumer that received the message.
ConsumerCancelledException - Exception in org.springframework.amqp.rabbit.support: Thrown when the broker cancels the consumer and the message queue is drained.
ConsumerCancelledException() - Constructor for exception org.springframework.amqp.rabbit.support.ConsumerCancelledException
ConsumerCancelledException(Throwable) - Constructor for exception org.springframework.amqp.rabbit.support.ConsumerCancelledException
ConsumerChannelRegistry - Class in org.springframework.amqp.rabbit.connection: Consumers register their primary channels with this class.
ConsumerChannelRegistry() - Constructor for class org.springframework.amqp.rabbit.connection.ConsumerChannelRegistry
consumerCount(String) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
ConsumerTagStrategy - Interface in org.springframework.amqp.support: A strategy interface to determine the consumer tag to be used when issuing a basicConsume operation.
containsChannel(Channel) - Method in class org.springframework.amqp.rabbit.connection.RabbitResourceHolder
CONTENT_ENCODING - Static variable in class org.springframework.amqp.support.AmqpHeaders
CONTENT_LENGTH - Static variable in class org.springframework.amqp.support.AmqpHeaders
CONTENT_TYPE - Static variable in class org.springframework.amqp.support.AmqpHeaders
CONTENT_TYPE_BYTES - Static variable in class org.springframework.amqp.core.MessageProperties
CONTENT_TYPE_JSON - Static variable in class org.springframework.amqp.core.MessageProperties
CONTENT_TYPE_JSON_ALT - Static variable in class org.springframework.amqp.core.MessageProperties
CONTENT_TYPE_SERIALIZED_OBJECT - Static variable in class org.springframework.amqp.core.MessageProperties
CONTENT_TYPE_TEXT_PLAIN - Static variable in class org.springframework.amqp.core.MessageProperties
CONTENT_TYPE_XML - Static variable in class org.springframework.amqp.core.MessageProperties
ContentTypeDelegatingMessageConverter - Class in org.springframework.amqp.support.converter: A composite MessageConverter that delegates to an actual MessageConverter based on the contentType header.
ContentTypeDelegatingMessageConverter() - Constructor for class org.springframework.amqp.support.converter.ContentTypeDelegatingMessageConverter: Constructs an instance using a default SimpleMessageConverter.
ContentTypeDelegatingMessageConverter(MessageConverter) - Constructor for class org.springframework.amqp.support.converter.ContentTypeDelegatingMessageConverter: Constructs an instance using a the supplied default converter.
convertAmqpException(RuntimeException) - Method in class org.springframework.amqp.rabbit.core.RabbitMessagingTemplate
convertAmqpMessage(Message) - Method in class org.springframework.amqp.rabbit.core.RabbitMessagingTemplate
convertAndSend(Object) - Method in interface org.springframework.amqp.core.AmqpTemplate: Convert a Java object to an Amqp Message and send it to a default exchange with a default routing key.
convertAndSend(String, Object) - Method in interface org.springframework.amqp.core.AmqpTemplate: Convert a Java object to an Amqp Message and send it to a default exchange with a specific routing key.
convertAndSend(String, String, Object) - Method in interface org.springframework.amqp.core.AmqpTemplate: Convert a Java object to an Amqp Message and send it to a specific exchange with a specific routing key.
convertAndSend(Object, MessagePostProcessor) - Method in interface org.springframework.amqp.core.AmqpTemplate: Convert a Java object to an Amqp Message and send it to a default exchange with a default routing key.
convertAndSend(String, Object, MessagePostProcessor) - Method in interface org.springframework.amqp.core.AmqpTemplate: Convert a Java object to an Amqp Message and send it to a default exchange with a specific routing key.
convertAndSend(String, String, Object, MessagePostProcessor) - Method in interface org.springframework.amqp.core.AmqpTemplate: Convert a Java object to an Amqp Message and send it to a specific exchange with a specific routing key.
convertAndSend(String, String, Object) - Method in interface org.springframework.amqp.rabbit.core.RabbitMessageOperations: Convert the given Object to serialized form, possibly using a MessageConverter, wrap it as a message and send it to a specific exchange with a specific routing key.
convertAndSend(String, String, Object, Map<String, Object>) - Method in interface org.springframework.amqp.rabbit.core.RabbitMessageOperations: Convert the given Object to serialized form, possibly using a MessageConverter, wrap it as a message with the given headers and send it to a specific exchange with a specific routing key.
convertAndSend(String, String, Object, MessagePostProcessor) - Method in interface org.springframework.amqp.rabbit.core.RabbitMessageOperations: Convert the given Object to serialized form, possibly using a MessageConverter, wrap it as a message, apply the given post processor, and send the resulting message to a specific exchange with a specific routing key.
convertAndSend(String, String, Object, Map<String, Object>, MessagePostProcessor) - Method in interface org.springframework.amqp.rabbit.core.RabbitMessageOperations: Convert the given Object to serialized form, possibly using a MessageConverter, wrap it as a message with the given headers, apply the given post processor, and send the resulting message to a specific exchange with a specific routing key.
convertAndSend(String, String, Object) - Method in class org.springframework.amqp.rabbit.core.RabbitMessagingTemplate
convertAndSend(String, String, Object, Map<String, Object>) - Method in class org.springframework.amqp.rabbit.core.RabbitMessagingTemplate
convertAndSend(String, String, Object, MessagePostProcessor) - Method in class org.springframework.amqp.rabbit.core.RabbitMessagingTemplate
convertAndSend(String, String, Object, Map<String, Object>, MessagePostProcessor) - Method in class org.springframework.amqp.rabbit.core.RabbitMessagingTemplate
convertAndSend(Object) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
convertAndSend(String, Object) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
convertAndSend(String, Object, CorrelationData) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
convertAndSend(String, String, Object) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
convertAndSend(String, String, Object, CorrelationData) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
convertAndSend(Object, MessagePostProcessor) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
convertAndSend(String, Object, MessagePostProcessor) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
convertAndSend(String, Object, MessagePostProcessor, CorrelationData) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
convertAndSend(String, String, Object, MessagePostProcessor) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
convertAndSend(String, String, Object, MessagePostProcessor, CorrelationData) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
convertMessageIfNecessary(Object) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
convertRabbitAccessException(Exception) - Method in class org.springframework.amqp.rabbit.connection.RabbitAccessor
convertRabbitAccessException(Throwable) - Static method in class org.springframework.amqp.rabbit.support.RabbitExceptionTranslator
convertSendAndReceive(Object) - Method in interface org.springframework.amqp.core.AmqpTemplate: Basic RPC pattern with conversion.
convertSendAndReceive(String, Object) - Method in interface org.springframework.amqp.core.AmqpTemplate: Basic RPC pattern with conversion.
convertSendAndReceive(String, String, Object) - Method in interface org.springframework.amqp.core.AmqpTemplate: Basic RPC pattern with conversion.
convertSendAndReceive(Object, MessagePostProcessor) - Method in interface org.springframework.amqp.core.AmqpTemplate: Basic RPC pattern with conversion.
convertSendAndReceive(String, Object, MessagePostProcessor) - Method in interface org.springframework.amqp.core.AmqpTemplate: Basic RPC pattern with conversion.
convertSendAndReceive(String, String, Object, MessagePostProcessor) - Method in interface org.springframework.amqp.core.AmqpTemplate: Basic RPC pattern with conversion.
convertSendAndReceive(Object) - Method in class org.springframework.amqp.rabbit.core.AsyncRabbitTemplate: Convert the object to a message and send it to the default exchange with the default routing key.
convertSendAndReceive(String, Object) - Method in class org.springframework.amqp.rabbit.core.AsyncRabbitTemplate: Convert the object to a message and send it to the default exchange with the provided routing key.
convertSendAndReceive(String, String, Object) - Method in class org.springframework.amqp.rabbit.core.AsyncRabbitTemplate: Convert the object to a message and send it to the provided exchange and routing key.
convertSendAndReceive(Object, MessagePostProcessor) - Method in class org.springframework.amqp.rabbit.core.AsyncRabbitTemplate: Convert the object to a message and send it to the default exchange with the default routing key after invoking the MessagePostProcessor.
convertSendAndReceive(String, Object, MessagePostProcessor) - Method in class org.springframework.amqp.rabbit.core.AsyncRabbitTemplate: Convert the object to a message and send it to the default exchange with the provided routing key after invoking the MessagePostProcessor.
convertSendAndReceive(String, String, Object, MessagePostProcessor) - Method in class org.springframework.amqp.rabbit.core.AsyncRabbitTemplate: Convert the object to a message and send it to the provided exchange and routing key after invoking the MessagePostProcessor.
convertSendAndReceive(String, String, Object, Class<T>) - Method in interface org.springframework.amqp.rabbit.core.RabbitMessageOperations: Convert the given request Object to serialized form, possibly using a MessageConverter, send it as a Message to a specific exchange with a specific routing key, receive the reply and convert its body of the specified target class.
convertSendAndReceive(String, String, Object, Map<String, Object>, Class<T>) - Method in interface org.springframework.amqp.rabbit.core.RabbitMessageOperations: Convert the given request Object to serialized form, possibly using a MessageConverter, send it as a Message with the given headers, to a specific exchange with a specific routing key, receive the reply and convert its body of the specified target class.
convertSendAndReceive(String, String, Object, Class<T>, MessagePostProcessor) - Method in interface org.springframework.amqp.rabbit.core.RabbitMessageOperations: Convert the given request Object to serialized form, possibly using a MessageConverter, apply the given post processor and send the resulting Message to a specific exchange with a specific routing key, receive the reply and convert its body of the given target class.
convertSendAndReceive(String, String, Object, Map<String, Object>, Class<T>, MessagePostProcessor) - Method in interface org.springframework.amqp.rabbit.core.RabbitMessageOperations: Convert the given request Object to serialized form, possibly using a MessageConverter, wrap it as a message with the given headers, apply the given post processor and send the resulting Message to a specific exchange with a specific routing key,, receive the reply and convert its body of the given target class.
convertSendAndReceive(String, String, Object, Class<T>) - Method in class org.springframework.amqp.rabbit.core.RabbitMessagingTemplate
convertSendAndReceive(String, String, Object, Map<String, Object>, Class<T>) - Method in class org.springframework.amqp.rabbit.core.RabbitMessagingTemplate
convertSendAndReceive(String, String, Object, Class<T>, MessagePostProcessor) - Method in class org.springframework.amqp.rabbit.core.RabbitMessagingTemplate
convertSendAndReceive(String, String, Object, Map<String, Object>, Class<T>, MessagePostProcessor) - Method in class org.springframework.amqp.rabbit.core.RabbitMessagingTemplate
convertSendAndReceive(Object) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
convertSendAndReceive(Object, CorrelationData) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
convertSendAndReceive(String, Object) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
convertSendAndReceive(String, Object, CorrelationData) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
convertSendAndReceive(String, String, Object) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
convertSendAndReceive(String, String, Object, CorrelationData) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
convertSendAndReceive(Object, MessagePostProcessor) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
convertSendAndReceive(Object, MessagePostProcessor, CorrelationData) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
convertSendAndReceive(String, Object, MessagePostProcessor) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
convertSendAndReceive(String, Object, MessagePostProcessor, CorrelationData) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
convertSendAndReceive(String, String, Object, MessagePostProcessor) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
convertSendAndReceive(String, String, Object, MessagePostProcessor, CorrelationData) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
copyHeaders(Map<String, Object>) - Method in class org.springframework.amqp.core.MessageBuilderSupport
copyHeadersIfAbsent(Map<String, Object>) - Method in class org.springframework.amqp.core.MessageBuilderSupport
copyProperties(MessageProperties) - Method in class org.springframework.amqp.core.MessageBuilderSupport
copyProperties(MessageProperties) - Method in class org.springframework.amqp.core.MessagePropertiesBuilder
CORRELATION_ID - Static variable in class org.springframework.amqp.support.AmqpHeaders
correlationconvertAndSend(Object, CorrelationData) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate: Deprecated.
correlationConvertAndSend(Object, CorrelationData) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
CorrelationData - Class in org.springframework.amqp.rabbit.support: Base class for correlating publisher confirms to sent messages.
CorrelationData(String) - Constructor for class org.springframework.amqp.rabbit.support.CorrelationData
counter - Variable in class org.springframework.amqp.rabbit.config.AbstractRabbitListenerContainerFactory
createAppender(String, Layout<? extends Serializable>, Filter, boolean, String, int, String, String, String, int, int, String, String, boolean, String, String, String, boolean, boolean, boolean, String, String, String) - Static method in class org.springframework.amqp.rabbit.log4j2.AmqpAppender
createBareConnection() - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
createBlockingQueueConsumer() - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer
createChannel(boolean) - Method in interface org.springframework.amqp.rabbit.connection.Connection: Create a new channel, using an internally allocated channel number.
createChannel(Connection) - Method in interface org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils.ResourceFactory: Create a new RabbitMQ Session for registration with a RabbitResourceHolder.
createChannel(boolean) - Method in class org.springframework.amqp.rabbit.connection.SimpleConnection
createClient(String, String, String) - Method in class org.springframework.amqp.rabbit.connection.LocalizedQueueConnectionFactory: Create a client instance.
createConnection() - Method in class org.springframework.amqp.rabbit.connection.AbstractRoutingConnectionFactory
createConnection() - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory
createConnection() - Method in interface org.springframework.amqp.rabbit.connection.ConnectionFactory
createConnection() - Method in interface org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils.ResourceFactory: Create a new RabbitMQ Connection for registration with a RabbitResourceHolder.
createConnection() - Method in class org.springframework.amqp.rabbit.connection.LocalizedQueueConnectionFactory
createConnection() - Method in class org.springframework.amqp.rabbit.connection.RabbitAccessor: Create a RabbitMQ Connection via this template's ConnectionFactory and its host and port values.
createConnectionFactory(String, String) - Method in class org.springframework.amqp.rabbit.connection.LocalizedQueueConnectionFactory: Create a dedicated connection factory for the address.
createConsumerTag(String) - Method in interface org.springframework.amqp.support.ConsumerTagStrategy: Create the consumer tag, optionally based on the queue name that the consumer will listen to.
createContainerInstance() - Method in class org.springframework.amqp.rabbit.config.AbstractRabbitListenerContainerFactory: Create an empty container instance.
createContainerInstance() - Method in class org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory
createElementDescription(Element) - Static method in class org.springframework.amqp.rabbit.config.NamespaceUtils: Provides a user friendly description of an element based on its node name and, if available, its "id" attribute value.
createExpressionDefIfAttributeDefined(String, Element) - Static method in class org.springframework.amqp.rabbit.config.NamespaceUtils
createExpressionDefinitionFromValueOrExpression(String, String, ParserContext, Element, boolean) - Static method in class org.springframework.amqp.rabbit.config.NamespaceUtils
createInstance() - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
createInstance() - Method in class org.springframework.amqp.rabbit.support.ExpressionFactoryBean
createListenerContainer(RabbitListenerEndpoint) - Method in class org.springframework.amqp.rabbit.config.AbstractRabbitListenerContainerFactory
createListenerContainer(RabbitListenerEndpoint) - Method in interface org.springframework.amqp.rabbit.listener.RabbitListenerContainerFactory: Create a MessageListenerContainer for the given RabbitListenerEndpoint.
createListenerContainer(RabbitListenerEndpoint, RabbitListenerContainerFactory<?>) - Method in class org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistry: Create and start a new MessageListenerContainer using the specified factory.
createMessage(Object, MessageProperties) - Method in class org.springframework.amqp.support.converter.AbstractMessageConverter: Crate a message from the payload object and message properties provided.
createMessage(Object, MessageProperties) - Method in class org.springframework.amqp.support.converter.Jackson2JsonMessageConverter
createMessage(Object, MessageProperties) - Method in class org.springframework.amqp.support.converter.JsonMessageConverter
createMessage(Object, MessageProperties) - Method in class org.springframework.amqp.support.converter.MarshallingMessageConverter: Marshals the given object to a Message.
createMessage(Object, MessageProperties) - Method in class org.springframework.amqp.support.converter.SerializerMessageConverter: Creates an AMQP Message from the provided Object.
createMessage(Object, MessageProperties) - Method in class org.springframework.amqp.support.converter.SimpleMessageConverter: Creates an AMQP Message from the provided Object.
createMessageListener(MessageListenerContainer) - Method in class org.springframework.amqp.rabbit.config.SimpleRabbitListenerEndpoint
createMessageListener(MessageListenerContainer) - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint: Create a MessageListener that is able to serve this endpoint for the specified container.
createMessageListener(MessageListenerContainer) - Method in class org.springframework.amqp.rabbit.listener.MethodRabbitListenerEndpoint
createMessageListenerInstance() - Method in class org.springframework.amqp.rabbit.listener.MethodRabbitListenerEndpoint: Create an empty MessagingMessageListenerAdapter instance.
createMessageListenerInstance() - Method in class org.springframework.amqp.rabbit.listener.MultiMethodRabbitListenerEndpoint
createObjectInputStream(InputStream, String) - Method in class org.springframework.amqp.support.converter.SimpleMessageConverter: Create an ObjectInputStream for the given InputStream and codebase.
createRabbitTemplate(ConnectionFactory) - Method in class org.springframework.amqp.rabbit.core.RabbitGatewaySupport: Create a RabbitTemplate for the given ConnectionFactory.
createSSLContext() - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean: Override this method to create and/or configure the SSLContext used by the ConnectionFactory.
CustomExchange - Class in org.springframework.amqp.core: Simple container collecting information to describe a custom exchange.
CustomExchange(String, String) - Constructor for class org.springframework.amqp.core.CustomExchange
CustomExchange(String, String, boolean, boolean) - Constructor for class org.springframework.amqp.core.CustomExchange
CustomExchange(String, String, boolean, boolean, Map<String, Object>) - Constructor for class org.springframework.amqp.core.CustomExchange

D

Declarable - Interface in org.springframework.amqp.core: Classes implementing this interface can be auto-declared with the broker during context initialization by an AmqpAdmin.
DeclarationExceptionEvent - Class in org.springframework.amqp.rabbit.core: Application event published when a declaration exception occurs.
DeclarationExceptionEvent(RabbitAdmin, Declarable, Throwable) - Constructor for class org.springframework.amqp.rabbit.core.DeclarationExceptionEvent
declareBinding(Binding) - Method in interface org.springframework.amqp.core.AmqpAdmin: Declare a binding of a queue to an exchange.
declareBinding(Binding) - Method in class org.springframework.amqp.rabbit.core.RabbitAdmin
declareExchange(Exchange) - Method in interface org.springframework.amqp.core.AmqpAdmin: Declare an exchange
declareExchange(Exchange) - Method in class org.springframework.amqp.rabbit.core.RabbitAdmin
DeclareExchangeConnectionListener - Class in org.springframework.amqp.rabbit.support: A ConnectionListener that will declare a single exchange when the connection is established.
DeclareExchangeConnectionListener(Exchange, RabbitAdmin) - Constructor for class org.springframework.amqp.rabbit.support.DeclareExchangeConnectionListener
declareQueue() - Method in interface org.springframework.amqp.core.AmqpAdmin: Declare a queue whose name is automatically named.
declareQueue(Queue) - Method in interface org.springframework.amqp.core.AmqpAdmin: Declare the given queue
declareQueue(Queue) - Method in class org.springframework.amqp.rabbit.core.RabbitAdmin: Declare the given queue.
declareQueue() - Method in class org.springframework.amqp.rabbit.core.RabbitAdmin: Declares a server-named exclusive, autodelete, non-durable queue.
declareTransactional(Channel) - Static method in class org.springframework.amqp.rabbit.connection.RabbitUtils: Declare to that broker that a channel is going to be used transactionally, and convert exceptions that arise.
decodeReplyToAddress(Message) - Static method in class org.springframework.amqp.core.AddressUtils: Deprecated.

Decodes the reply-to Address into exchange/key.
DEFAULT - Static variable in class org.springframework.amqp.core.DirectExchange
DEFAULT_CHARSET - Static variable in class org.springframework.amqp.support.converter.AbstractJsonMessageConverter
DEFAULT_CHARSET - Static variable in class org.springframework.amqp.support.converter.SerializerMessageConverter
DEFAULT_CHARSET - Static variable in class org.springframework.amqp.support.converter.SimpleMessageConverter
DEFAULT_CLASSID_FIELD_NAME - Static variable in class org.springframework.amqp.support.converter.AbstractJavaTypeMapper
DEFAULT_CLASSID_FIELD_NAME - Static variable in class org.springframework.amqp.support.converter.DefaultClassMapper
DEFAULT_CLOSE_TIMEOUT - Static variable in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
DEFAULT_CONTENT_CLASSID_FIELD_NAME - Static variable in class org.springframework.amqp.support.converter.AbstractJavaTypeMapper
DEFAULT_DEBATCHING_ENABLED - Static variable in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
DEFAULT_EXCHANGE_NAME - Static variable in class org.springframework.amqp.rabbit.core.RabbitAdmin: The default exchange name.
DEFAULT_KEY_CLASSID_FIELD_NAME - Static variable in class org.springframework.amqp.support.converter.AbstractJavaTypeMapper
DEFAULT_PORT - Static variable in class org.springframework.amqp.rabbit.connection.RabbitUtils
DEFAULT_PREFETCH_COUNT - Static variable in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer
DEFAULT_RECEIVE_TIMEOUT - Static variable in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer
DEFAULT_RECOVERY_INTERVAL - Static variable in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer: The default recovery interval: 5000 ms = 5 seconds.
DEFAULT_SHUTDOWN_TIMEOUT - Static variable in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer
DefaultClassMapper - Class in org.springframework.amqp.support.converter: Maps to/from JSON using type information in the MessageProperties; the default name of the message property containing the type is '__TypeId__'.
DefaultClassMapper() - Constructor for class org.springframework.amqp.support.converter.DefaultClassMapper
DefaultJackson2JavaTypeMapper - Class in org.springframework.amqp.support.converter
DefaultJackson2JavaTypeMapper() - Constructor for class org.springframework.amqp.support.converter.DefaultJackson2JavaTypeMapper
DefaultJavaTypeMapper - Class in org.springframework.amqp.support.converter
DefaultJavaTypeMapper() - Constructor for class org.springframework.amqp.support.converter.DefaultJavaTypeMapper
DefaultMessagePropertiesConverter - Class in org.springframework.amqp.rabbit.support: Default implementation of the MessagePropertiesConverter strategy.
DefaultMessagePropertiesConverter() - Constructor for class org.springframework.amqp.rabbit.support.DefaultMessagePropertiesConverter: Construct an instance where LongStrings will be returned unconverted when longer than 1024 bytes.
DefaultMessagePropertiesConverter(int) - Constructor for class org.springframework.amqp.rabbit.support.DefaultMessagePropertiesConverter: Construct an instance where LongStrings will be returned unconverted when longer than this limit.
DefaultMessagePropertiesConverter(int, boolean) - Constructor for class org.springframework.amqp.rabbit.support.DefaultMessagePropertiesConverter: Construct an instance where LongStrings will be returned unconverted or as a DataInputStream when longer than this limit.
DefaultMessagePropertiesConverter.CorrelationIdPolicy - Enum in org.springframework.amqp.rabbit.support
defaultRabbitListenerEndpointRegistry() - Method in class org.springframework.amqp.rabbit.annotation.RabbitBootstrapConfiguration
DELAY - Static variable in class org.springframework.amqp.support.AmqpHeaders
DELAYED - Static variable in class org.springframework.amqp.core.ExchangeTypes
DelegatingDecompressingPostProcessor - Class in org.springframework.amqp.support.postprocessor: A MessagePostProcessor that delegates to one of its MessagePostProcessors depending on the content encoding.
DelegatingDecompressingPostProcessor() - Constructor for class org.springframework.amqp.support.postprocessor.DelegatingDecompressingPostProcessor
DelegatingInvocableHandler - Class in org.springframework.amqp.rabbit.listener.adapter: Delegates to an InvocableHandlerMethod based on the message payload type.
DelegatingInvocableHandler(List<InvocableHandlerMethod>, Object, BeanExpressionResolver, BeanExpressionContext) - Constructor for class org.springframework.amqp.rabbit.listener.adapter.DelegatingInvocableHandler: Construct an instance with the supplied handlers for the bean.
deleteExchange(String) - Method in interface org.springframework.amqp.core.AmqpAdmin: Delete an exchange.
deleteExchange(Exchange) - Method in interface org.springframework.amqp.core.AmqpManagementOperations: Delete an exchange from the default vhost ('/').
deleteExchange(String, Exchange) - Method in interface org.springframework.amqp.core.AmqpManagementOperations: Delete an exchange from the provided vhost.
deleteExchange(String) - Method in class org.springframework.amqp.rabbit.core.RabbitAdmin
deleteExchange(Exchange) - Method in class org.springframework.amqp.rabbit.core.RabbitManagementTemplate
deleteExchange(String, Exchange) - Method in class org.springframework.amqp.rabbit.core.RabbitManagementTemplate
deleteQueue(String) - Method in interface org.springframework.amqp.core.AmqpAdmin: Delete a queue, without regard for whether it is in use or has messages on it
deleteQueue(String, boolean, boolean) - Method in interface org.springframework.amqp.core.AmqpAdmin: Delete a queue
deleteQueue(Queue) - Method in interface org.springframework.amqp.core.AmqpManagementOperations: Delete a queue from the default vhost ('/').
deleteQueue(String, Queue) - Method in interface org.springframework.amqp.core.AmqpManagementOperations: Delete a queue from the provided vhost.
deleteQueue(String) - Method in class org.springframework.amqp.rabbit.core.RabbitAdmin
deleteQueue(String, boolean, boolean) - Method in class org.springframework.amqp.rabbit.core.RabbitAdmin
deleteQueue(Queue) - Method in class org.springframework.amqp.rabbit.core.RabbitManagementTemplate
deleteQueue(String, Queue) - Method in class org.springframework.amqp.rabbit.core.RabbitManagementTemplate
DELIVERY_MODE - Static variable in class org.springframework.amqp.support.AmqpHeaders
DELIVERY_TAG - Static variable in class org.springframework.amqp.support.AmqpHeaders
deserialize(byte[]) - Static method in class org.springframework.amqp.utils.SerializationUtils
deserialize(ObjectInputStream) - Static method in class org.springframework.amqp.utils.SerializationUtils
destination - Variable in class org.springframework.amqp.core.BindingBuilder.HeadersExchangeMapConfigurer
destroy() - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
destroy() - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory: Close the underlying shared connection.
destroy() - Method in class org.springframework.amqp.rabbit.connection.LocalizedQueueConnectionFactory
destroy() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer: Calls AbstractMessageListenerContainer.shutdown() when the BeanFactory destroys the container instance.
destroy() - Method in class org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistry
determineCurrentLookupKey() - Method in class org.springframework.amqp.rabbit.connection.AbstractRoutingConnectionFactory: Determine the current lookup key.
determineCurrentLookupKey() - Method in class org.springframework.amqp.rabbit.connection.SimpleRoutingConnectionFactory
determineTargetConnectionFactory() - Method in class org.springframework.amqp.rabbit.connection.AbstractRoutingConnectionFactory: Retrieve the current target ConnectionFactory.
DIRECT - Static variable in class org.springframework.amqp.core.ExchangeTypes
DirectExchange - Class in org.springframework.amqp.core: Simple container collecting information to describe a direct exchange.
DirectExchange(String) - Constructor for class org.springframework.amqp.core.DirectExchange
DirectExchange(String, boolean, boolean) - Constructor for class org.springframework.amqp.core.DirectExchange
DirectExchange(String, boolean, boolean, Map<String, Object>) - Constructor for class org.springframework.amqp.core.DirectExchange
DirectExchangeParser - Class in org.springframework.amqp.rabbit.config
DirectExchangeParser() - Constructor for class org.springframework.amqp.rabbit.config.DirectExchangeParser
doBegin(Object, TransactionDefinition) - Method in class org.springframework.amqp.rabbit.transaction.RabbitTransactionManager
doCleanupAfterCompletion(Object) - Method in class org.springframework.amqp.rabbit.transaction.RabbitTransactionManager
doCommit(DefaultTransactionStatus) - Method in class org.springframework.amqp.rabbit.transaction.RabbitTransactionManager
doGetTransaction() - Method in class org.springframework.amqp.rabbit.transaction.RabbitTransactionManager
doInitialize() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer: Register any invokers within this container.
doInitialize() - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer: Creates the specified number of concurrent consumers, in the form of a Rabbit Channel plus associated MessageConsumer.
doInRabbit(Channel) - Method in interface org.springframework.amqp.rabbit.core.ChannelCallback: Execute any number of operations against the supplied RabbitMQ Channel, possibly returning a result.
doInvokeListener(ChannelAwareMessageListener, Channel, Message) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer: Invoke the specified listener as Spring ChannelAwareMessageListener, exposing a new Rabbit Session (potentially with its own transaction) to the listener if demanded.
doInvokeListener(MessageListener, Message) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer: Invoke the specified listener as Spring Rabbit MessageListener.
doParse(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.amqp.rabbit.config.AbstractExchangeParser
doParse(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.amqp.rabbit.config.QueueParser
doParseBindings(Element, ParserContext, String, Element, AbstractExchangeParser) - Method in class org.springframework.amqp.rabbit.config.AbstractExchangeParser
doReceive(String) - Method in class org.springframework.amqp.rabbit.core.RabbitMessagingTemplate
doReceiveNoWait(String) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate: Non-blocking receive.
doResume(Object, Object) - Method in class org.springframework.amqp.rabbit.transaction.RabbitTransactionManager
doRollback(DefaultTransactionStatus) - Method in class org.springframework.amqp.rabbit.transaction.RabbitTransactionManager
doSend(String, Message<?>) - Method in class org.springframework.amqp.rabbit.core.RabbitMessagingTemplate
doSend(String, String, Message<?>) - Method in class org.springframework.amqp.rabbit.core.RabbitMessagingTemplate
doSend(Channel, String, String, Message, boolean, CorrelationData) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate: Send the given message to the specified exchange.
doSendAndReceive(String, Message<?>) - Method in class org.springframework.amqp.rabbit.core.RabbitMessagingTemplate
doSendAndReceive(String, String, Message<?>) - Method in class org.springframework.amqp.rabbit.core.RabbitMessagingTemplate
doSendAndReceive(String, String, Message, CorrelationData) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate: Send a message and wait for a reply.
doSendAndReceiveWithFixed(String, String, Message, CorrelationData) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
doSendAndReceiveWithTemporary(String, String, Message, CorrelationData) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
doSetRollbackOnly(DefaultTransactionStatus) - Method in class org.springframework.amqp.rabbit.transaction.RabbitTransactionManager
doShutdown() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer: Close the registered invokers.
doShutdown() - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer
doStart() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer: Start this container, and notify all invoker tasks.
doStart() - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer: Re-initializes this container's Rabbit message consumers, if not initialized already.
doStop() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer: This method is invoked when the container is stopping.
doStop() - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer
doSuspend(Object) - Method in class org.springframework.amqp.rabbit.transaction.RabbitTransactionManager

E

EnableRabbit - Annotation Type in org.springframework.amqp.rabbit.annotation: Enable Rabbit listener annotated endpoints that are created under the cover by a RabbitListenerContainerFactory.
equals(Object) - Method in class org.springframework.amqp.core.Address
equals(Object) - Method in class org.springframework.amqp.core.Message
equals(Object) - Method in class org.springframework.amqp.core.MessageProperties
equals(Object) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
errorRoutingKeyPrefix(String) - Method in class org.springframework.amqp.rabbit.retry.RepublishMessageRecoverer: Apply a prefix to the outbound routing key, which will be prefixed to the original message routing key (if no explicit routing key was provided in the constructor; ignored otherwise.
Event(LoggingEvent, Map) - Constructor for class org.springframework.amqp.rabbit.log4j.AmqpAppender.Event
Event(LogEvent, Map) - Constructor for class org.springframework.amqp.rabbit.log4j2.AmqpAppender.Event
Event(ILoggingEvent) - Constructor for class org.springframework.amqp.rabbit.logback.AmqpAppender.Event
EventSender() - Constructor for class org.springframework.amqp.rabbit.log4j.AmqpAppender.EventSender
EventSender() - Constructor for class org.springframework.amqp.rabbit.log4j2.AmqpAppender.EventSender
EventSender() - Constructor for class org.springframework.amqp.rabbit.logback.AmqpAppender.EventSender
exchange - Variable in class org.springframework.amqp.core.BindingBuilder.HeadersExchangeMapConfigurer
Exchange - Interface in org.springframework.amqp.core
Exchange - Annotation Type in org.springframework.amqp.rabbit.annotation: An exchange to which to bind a RabbitListener queue.
exchangeBind(String, String, String) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
exchangeBind(String, String, String, Map<String, Object>) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
exchangeBindNoWait(String, String, String, Map<String, Object>) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
exchangeDeclare(String, String) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
exchangeDeclare(String, String, boolean) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
exchangeDeclare(String, String, boolean, boolean, Map<String, Object>) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
exchangeDeclare(String, String, boolean, boolean, boolean, Map<String, Object>) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
exchangeDeclareNoWait(String, String, boolean, boolean, boolean, Map<String, Object>) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
exchangeDeclarePassive(String) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
exchangeDelete(String, boolean) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
exchangeDelete(String) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
exchangeDeleteNoWait(String, boolean) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
ExchangeTypes - Class in org.springframework.amqp.core: Constants for the standard Exchange type names.
ExchangeTypes() - Constructor for class org.springframework.amqp.core.ExchangeTypes
exchangeUnbind(String, String, String) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
exchangeUnbind(String, String, String, Map<String, Object>) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
exchangeUnbindNoWait(String, String, String, Map<String, Object>) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
execute(ChannelCallback<T>) - Method in interface org.springframework.amqp.rabbit.core.RabbitOperations
execute(ChannelCallback<T>) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
executeListener(Channel, Message) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer: Execute the specified listener, committing or rolling back the transaction afterwards (if necessary).
exist() - Method in class org.springframework.amqp.core.BindingBuilder.HeadersExchangeMapConfigurer.HeadersExchangeKeysBindingCreator
exists() - Method in class org.springframework.amqp.core.BindingBuilder.HeadersExchangeMapConfigurer.HeadersExchangeSingleValueBindingCreator
expectedQueueNames() - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate: Invoked by the container during startup so it can verify the queue is correctly configured (if a simple reply queue name is used instead of exchange/routingKey.
expectedQueueNames() - Method in interface org.springframework.amqp.rabbit.support.ListenerContainerAware: Return the queue names that the listener expects to listen to.
EXPIRATION - Static variable in class org.springframework.amqp.support.AmqpHeaders
expire(PublisherCallbackChannel.Listener, long) - Method in interface org.springframework.amqp.rabbit.support.PublisherCallbackChannel: Expire (remove) any PendingConfirms created before cutoffTime for the supplied listener and return them to the caller.
expire(PublisherCallbackChannel.Listener, long) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
ExpressionFactoryBean - Class in org.springframework.amqp.rabbit.support: FactoryBean for creating Expression instances.
ExpressionFactoryBean(String) - Constructor for class org.springframework.amqp.rabbit.support.ExpressionFactoryBean
extractMessage(Message) - Method in class org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener: Extract the message body from the given Rabbit message.
extractPayload(Message) - Method in class org.springframework.amqp.support.converter.MessagingMessageConverter: Extract the payload of the specified Message.

F

FANOUT - Static variable in class org.springframework.amqp.core.ExchangeTypes
FanoutExchange - Class in org.springframework.amqp.core: Simple container collecting information to describe a fanout exchange.
FanoutExchange(String) - Constructor for class org.springframework.amqp.core.FanoutExchange
FanoutExchange(String, boolean, boolean) - Constructor for class org.springframework.amqp.core.FanoutExchange
FanoutExchange(String, boolean, boolean, Map<String, Object>) - Constructor for class org.springframework.amqp.core.FanoutExchange
FanoutExchangeParser - Class in org.springframework.amqp.rabbit.config
FanoutExchangeParser() - Constructor for class org.springframework.amqp.rabbit.config.FanoutExchangeParser
FatalExceptionStrategy - Interface in org.springframework.amqp.rabbit.listener: A strategy interface for the ConditionalRejectingErrorHandler to decide whether an exception should be considered to be fatal and the message should not be requeued.
FatalListenerExecutionException - Exception in org.springframework.amqp.rabbit.listener.exception: Exception to be thrown when the execution of a listener method failed unrecoverably.
FatalListenerExecutionException(String, Throwable) - Constructor for exception org.springframework.amqp.rabbit.listener.exception.FatalListenerExecutionException: Constructor for ListenerExecutionFailedException.
FatalListenerExecutionException(String) - Constructor for exception org.springframework.amqp.rabbit.listener.exception.FatalListenerExecutionException: Constructor for ListenerExecutionFailedException.
FatalListenerStartupException - Exception in org.springframework.amqp.rabbit.listener.exception: Exception to be thrown when the execution of a listener method failed on startup.
FatalListenerStartupException(String, Throwable) - Constructor for exception org.springframework.amqp.rabbit.listener.exception.FatalListenerStartupException: Constructor for ListenerExecutionFailedException.
findHandlerForPayload(Class<? extends Object>) - Method in class org.springframework.amqp.rabbit.listener.adapter.DelegatingInvocableHandler
flowBlocked() - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl: Deprecated.
in the 3.5.3 client
flush() - Method in class org.springframework.amqp.rabbit.core.BatchingRabbitTemplate: Flush any partial in-progress batches.
fromClass(Class<?>, MessageProperties) - Method in interface org.springframework.amqp.support.converter.ClassMapper
fromClass(Class<?>, MessageProperties) - Method in class org.springframework.amqp.support.converter.DefaultClassMapper
fromClass(Class<?>, MessageProperties) - Method in class org.springframework.amqp.support.converter.DefaultJackson2JavaTypeMapper
fromClass(Class<?>, MessageProperties) - Method in class org.springframework.amqp.support.converter.DefaultJavaTypeMapper
fromClonedMessage(Message) - Static method in class org.springframework.amqp.core.MessageBuilder: The final message will have a copy of the message body, the MessageProperties will be cloned (top level only).
fromClonedProperties(MessageProperties) - Static method in class org.springframework.amqp.core.MessagePropertiesBuilder: Performs a shallow copy of the properties for the initial value.
fromHeaders(MessageHeaders, MessageProperties) - Method in class org.springframework.amqp.support.SimpleAmqpHeaderMapper
fromInt(int) - Static method in enum org.springframework.amqp.core.MessageDeliveryMode
fromJavaType(JavaType, MessageProperties) - Method in class org.springframework.amqp.support.converter.DefaultJackson2JavaTypeMapper
fromJavaType(JavaType, MessageProperties) - Method in class org.springframework.amqp.support.converter.DefaultJavaTypeMapper
fromJavaType(JavaType, MessageProperties) - Method in interface org.springframework.amqp.support.converter.Jackson2JavaTypeMapper
fromJavaType(JavaType, MessageProperties) - Method in interface org.springframework.amqp.support.converter.JavaTypeMapper
fromMessage(Message) - Static method in class org.springframework.amqp.core.MessageBuilder: The final message body will be a direct reference to the message body, the MessageProperties will be a shallow copy.
fromMessage(Message) - Method in class org.springframework.amqp.support.converter.AbstractMessageConverter
fromMessage(Message) - Method in class org.springframework.amqp.support.converter.ContentTypeDelegatingMessageConverter
fromMessage(Message) - Method in class org.springframework.amqp.support.converter.Jackson2JsonMessageConverter
fromMessage(Message) - Method in class org.springframework.amqp.support.converter.JsonMessageConverter
fromMessage(Message) - Method in class org.springframework.amqp.support.converter.MarshallingMessageConverter: Unmarshals the given Message into an object.
fromMessage(Message) - Method in interface org.springframework.amqp.support.converter.MessageConverter: Convert from a Message to a Java object.
fromMessage(Message) - Method in class org.springframework.amqp.support.converter.MessagingMessageConverter
fromMessage(Message) - Method in class org.springframework.amqp.support.converter.SerializerMessageConverter: Converts from a AMQP Message to an Object.
fromMessage(Message) - Method in class org.springframework.amqp.support.converter.SimpleMessageConverter: Converts from a AMQP Message to an Object.
fromMessageProperties(MessageProperties, String) - Method in class org.springframework.amqp.rabbit.support.DefaultMessagePropertiesConverter
fromMessageProperties(MessageProperties, String) - Method in interface org.springframework.amqp.rabbit.support.MessagePropertiesConverter
fromProperties(MessageProperties) - Static method in class org.springframework.amqp.core.MessagePropertiesBuilder: Initializes the builder with the supplied properties; the same object will be returned by MessagePropertiesBuilder.build().

G

generateName() - Method in class org.springframework.amqp.core.AnonymousQueue.Base64UrlNamingStrategy
generateName() - Method in interface org.springframework.amqp.core.AnonymousQueue.NamingStrategy
GenericArgumentsConfigurer(BindingBuilder.GenericExchangeRoutingKeyConfigurer, String) - Constructor for class org.springframework.amqp.core.BindingBuilder.GenericArgumentsConfigurer
get(Object) - Static method in class org.springframework.amqp.rabbit.connection.SimpleResourceHolder: Retrieve a resource for the given key that is bound to the current thread.
getAcknowledgeMode() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
getActiveConsumerCount() - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer
getAdmin() - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint
getAmqpMessageConverter() - Method in class org.springframework.amqp.rabbit.core.RabbitMessagingTemplate
getAmqpTemplate() - Method in class org.springframework.amqp.remoting.client.AmqpClientInterceptor
getAmqpTemplate() - Method in class org.springframework.amqp.remoting.service.AmqpInvokerServiceExporter
getAppId() - Method in class org.springframework.amqp.core.MessageProperties
getAppId() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
getApplicationContext() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
getApplicationId() - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender
getApplicationId() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
getArguments() - Method in class org.springframework.amqp.core.AbstractExchange: Return the collection of arbitrary arguments to use when declaring an exchange.
getArguments() - Method in class org.springframework.amqp.core.Binding
getArguments() - Method in interface org.springframework.amqp.core.Exchange: A map of arguments used to declare the exchange.
getArguments() - Method in class org.springframework.amqp.core.Queue
getArguments() - Method in class org.springframework.amqp.rabbit.test.RabbitListenerTestHarness.InvocationData
getBackOffExecution() - Method in class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer
getBean() - Method in class org.springframework.amqp.rabbit.listener.adapter.DelegatingInvocableHandler
getBean() - Method in class org.springframework.amqp.rabbit.listener.adapter.HandlerAdapter
getBean() - Method in class org.springframework.amqp.rabbit.listener.MethodRabbitListenerEndpoint
getBeanClass(Element) - Method in class org.springframework.amqp.rabbit.config.DirectExchangeParser
getBeanClass(Element) - Method in class org.springframework.amqp.rabbit.config.FanoutExchangeParser
getBeanClass(Element) - Method in class org.springframework.amqp.rabbit.config.HeadersExchangeParser
getBeanClass(Element) - Method in class org.springframework.amqp.rabbit.config.QueueParser
getBeanClass(Element) - Method in class org.springframework.amqp.rabbit.config.TopicExchangeParser
getBeanExpressionContext() - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint
getBeanFactory() - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint
getBeanName() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
getBindings() - Method in interface org.springframework.amqp.core.AmqpManagementOperations: Get all bindings.
getBindings(String) - Method in interface org.springframework.amqp.core.AmqpManagementOperations: Get all bindings in the provided vhost.
getBindings() - Method in class org.springframework.amqp.rabbit.core.RabbitManagementTemplate
getBindings(String) - Method in class org.springframework.amqp.rabbit.core.RabbitManagementTemplate
getBindingsForExchange(String, String) - Method in interface org.springframework.amqp.core.AmqpManagementOperations: Get all bindings from the provided exchange in the provided vhost.
getBindingsForExchange(String, String) - Method in class org.springframework.amqp.rabbit.core.RabbitManagementTemplate
getBody() - Method in class org.springframework.amqp.core.Message
getCacheMode() - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory
getCause() - Method in class org.springframework.amqp.rabbit.support.PendingConfirm
getChannel(RabbitResourceHolder) - Method in interface org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils.ResourceFactory: Fetch an appropriate Channel from the given RabbitResourceHolder.
getChannel(RabbitResourceHolder) - Method in class org.springframework.amqp.rabbit.connection.RabbitAccessor: Fetch an appropriate Channel from the given RabbitResourceHolder.
getChannel() - Method in class org.springframework.amqp.rabbit.connection.RabbitResourceHolder
getChannel() - Method in class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer
getChannelCacheSize() - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory
getChannelListener() - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory: A composite channel listener to be used by subclasses when creating and closing channels.
getChannelNumber() - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
getCharset() - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender
getCharset() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
getClassIdFieldName() - Method in class org.springframework.amqp.support.converter.AbstractJavaTypeMapper
getClassIdFieldName() - Method in class org.springframework.amqp.support.converter.DefaultClassMapper
getClassMapper() - Method in class org.springframework.amqp.support.converter.AbstractJsonMessageConverter
getClient() - Method in class org.springframework.amqp.rabbit.core.RabbitManagementTemplate
getCloseReason() - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
getCloseTimeout() - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
getClusterId() - Method in class org.springframework.amqp.core.MessageProperties
getClusterId() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
getCompressorStream(OutputStream) - Method in class org.springframework.amqp.support.postprocessor.AbstractCompressingPostProcessor
getCompressorStream(OutputStream) - Method in class org.springframework.amqp.support.postprocessor.GZipPostProcessor
getCompressorStream(OutputStream) - Method in class org.springframework.amqp.support.postprocessor.ZipPostProcessor
getConfirm() - Method in class org.springframework.amqp.rabbit.core.AsyncRabbitTemplate.RabbitFuture: When confirms are enabled contains a ListenableFuture for the confirmation.
getConnection(RabbitResourceHolder) - Method in interface org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils.ResourceFactory: Fetch an appropriate Connection from the given RabbitResourceHolder.
getConnection(RabbitResourceHolder) - Method in class org.springframework.amqp.rabbit.connection.RabbitAccessor: Fetch an appropriate Connection from the given RabbitResourceHolder.
getConnection() - Method in class org.springframework.amqp.rabbit.connection.RabbitResourceHolder
getConnection(Class<? extends Connection>) - Method in class org.springframework.amqp.rabbit.connection.RabbitResourceHolder
getConnection() - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
getConnectionCachesize() - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory: Deprecated.
getConnectionCacheSize() - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory
getConnectionFactory() - Method in class org.springframework.amqp.rabbit.connection.RabbitAccessor
getConnectionFactory() - Method in class org.springframework.amqp.rabbit.core.RabbitGatewaySupport
getConnectionFactory() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
getConnectionFactory() - Method in class org.springframework.amqp.rabbit.transaction.RabbitTransactionManager
getConnectionListener() - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory: A composite connection listener to be used by subclasses when creating and closing connections.
getConsumerChannel() - Static method in class org.springframework.amqp.rabbit.connection.ConsumerChannelRegistry: See registerConsumerChannel.
getConsumerChannel(ConnectionFactory) - Static method in class org.springframework.amqp.rabbit.connection.ConsumerChannelRegistry: See registerConsumerChannel.
getConsumerQueue() - Method in class org.springframework.amqp.core.MessageProperties
getConsumerQueue() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
getConsumerTag() - Method in class org.springframework.amqp.core.MessageProperties
getConsumerTag() - Method in class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer
getConsumerTag() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
getContentClassIdFieldName() - Method in class org.springframework.amqp.support.converter.AbstractJavaTypeMapper
getContentEncoding() - Method in class org.springframework.amqp.core.MessageProperties
getContentEncoding() - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender
getContentEncoding() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
getContentEncoding() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
getContentLength() - Method in class org.springframework.amqp.core.MessageProperties
getContentLength() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
getContentType() - Method in class org.springframework.amqp.core.MessageProperties
getContentType() - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender
getContentType() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
getContentType() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
getConverterForContentType(String) - Method in class org.springframework.amqp.support.converter.ContentTypeDelegatingMessageConverter
getCorrelationData() - Method in class org.springframework.amqp.rabbit.support.PendingConfirm: The correlation data supplied by the client when sending the message corresponding to this confirmation.
getCorrelationId() - Method in class org.springframework.amqp.core.MessageProperties
getCorrelationId() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
getCorrelationIdString() - Method in class org.springframework.amqp.core.MessageProperties
getCount() - Method in class org.springframework.amqp.rabbit.listener.ActiveObjectCounter
getDeclarable() - Method in class org.springframework.amqp.rabbit.core.DeclarationExceptionEvent
getDeclaringAdmins() - Method in class org.springframework.amqp.core.AbstractDeclarable
getDeclaringAdmins() - Method in interface org.springframework.amqp.core.Declarable: The collection of AmqpAdmins that should declare this object; if empty, all admins should declare.
getDecompressorStream(InputStream) - Method in class org.springframework.amqp.support.postprocessor.AbstractDecompressingPostProcessor
getDecompressorStream(InputStream) - Method in class org.springframework.amqp.support.postprocessor.GUnzipPostProcessor
getDecompressorStream(InputStream) - Method in class org.springframework.amqp.support.postprocessor.UnzipPostProcessor
getDefaultCharset() - Method in class org.springframework.amqp.support.converter.AbstractJsonMessageConverter
getDefaultConsumer() - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
getDefaultHostName() - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
getDefaultListenerMethod() - Method in class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter
getDefaultReplyTo() - Method in class org.springframework.amqp.rabbit.listener.adapter.DelegatingInvocableHandler
getDelay() - Method in class org.springframework.amqp.core.MessageProperties: The x-delay header (outbound).
getDelegate() - Method in class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter
getDelegate() - Method in interface org.springframework.amqp.rabbit.support.PublisherCallbackChannel: Use this to invoke methods on the underlying rabbit client Channel that are not supported by this implementation.
getDelegate() - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
getDelegates() - Method in class org.springframework.amqp.support.converter.ContentTypeDelegatingMessageConverter
getDeliveryMode() - Method in class org.springframework.amqp.core.MessageProperties
getDeliveryMode() - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender
getDeliveryMode() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
getDeliveryMode() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
getDeliveryTag() - Method in class org.springframework.amqp.core.MessageProperties
getDeliveryTag() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
getDestination() - Method in class org.springframework.amqp.core.Binding
getDestinationType() - Method in class org.springframework.amqp.core.Binding
getEncoding() - Method in class org.springframework.amqp.support.postprocessor.AbstractCompressingPostProcessor
getEncoding() - Method in class org.springframework.amqp.support.postprocessor.AbstractDecompressingPostProcessor
getEncoding() - Method in class org.springframework.amqp.support.postprocessor.GUnzipPostProcessor
getEncoding() - Method in class org.springframework.amqp.support.postprocessor.GZipPostProcessor
getEncoding() - Method in class org.springframework.amqp.support.postprocessor.UnzipPostProcessor
getEncoding() - Method in class org.springframework.amqp.support.postprocessor.ZipPostProcessor
getEndpointDescription() - Method in class org.springframework.amqp.rabbit.config.SimpleRabbitListenerEndpoint
getEndpointDescription() - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint
getEndpointDescription() - Method in class org.springframework.amqp.rabbit.listener.MethodRabbitListenerEndpoint
getEndpointRegistry() - Method in class org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistrar
getEvent() - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender.Event
getEvent() - Method in class org.springframework.amqp.rabbit.log4j2.AmqpAppender.Event
getEvent() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender.Event
getExchange(String) - Method in interface org.springframework.amqp.core.AmqpManagementOperations: Get a specific queue from the default vhost ('/').
getExchange(String, String) - Method in interface org.springframework.amqp.core.AmqpManagementOperations: Get a specific exchange from the provided vhost.
getExchange() - Method in exception org.springframework.amqp.core.AmqpMessageReturnedException
getExchange() - Method in class org.springframework.amqp.core.Binding
getExchange(String) - Method in class org.springframework.amqp.rabbit.core.RabbitManagementTemplate
getExchange(String, String) - Method in class org.springframework.amqp.rabbit.core.RabbitManagementTemplate
getExchange() - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
getExchange() - Method in class org.springframework.amqp.rabbit.core.support.MessageBatch
getExchangeName() - Method in class org.springframework.amqp.core.Address
getExchangeName() - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender
getExchangeName() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
getExchanges() - Method in interface org.springframework.amqp.core.AmqpManagementOperations: Get all exchanges.
getExchanges(String) - Method in interface org.springframework.amqp.core.AmqpManagementOperations: Get all exchanges in the provided vhost.
getExchanges() - Method in class org.springframework.amqp.rabbit.core.RabbitManagementTemplate
getExchanges(String) - Method in class org.springframework.amqp.rabbit.core.RabbitManagementTemplate
getExchangeType() - Method in class org.springframework.amqp.core.Address: Deprecated.
getExchangeType() - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender
getExchangeType() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
getExecutorService() - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
getExpiration() - Method in class org.springframework.amqp.core.MessageProperties
getExpiration() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
getExpressionString() - Method in class org.springframework.amqp.rabbit.support.ValueExpression
getFailedMessage() - Method in exception org.springframework.amqp.rabbit.listener.exception.ListenerExecutionFailedException
getGroup() - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint
getGroup() - Method in interface org.springframework.amqp.rabbit.listener.RabbitListenerEndpoint
getHandlerForPayload(Class<? extends Object>) - Method in class org.springframework.amqp.rabbit.listener.adapter.DelegatingInvocableHandler
getHeaders() - Method in class org.springframework.amqp.core.MessageProperties
getHost() - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
getHost() - Method in class org.springframework.amqp.rabbit.connection.AbstractRoutingConnectionFactory
getHost() - Method in interface org.springframework.amqp.rabbit.connection.ConnectionFactory
getHost() - Method in class org.springframework.amqp.rabbit.connection.LocalizedQueueConnectionFactory
getHost() - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender
getHost() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
getId() - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint
getId() - Method in interface org.springframework.amqp.rabbit.listener.RabbitListenerEndpoint
getId() - Method in class org.springframework.amqp.rabbit.support.CorrelationData
getIdClassMapping() - Method in class org.springframework.amqp.support.converter.AbstractJavaTypeMapper
getIdleTime() - Method in class org.springframework.amqp.rabbit.listener.ListenerContainerIdleEvent: How long the container has been idle.
getJavaTypeMapper() - Method in class org.springframework.amqp.support.converter.Jackson2JsonMessageConverter
getJavaTypeMapper() - Method in class org.springframework.amqp.support.converter.JsonMessageConverter
getKey(Message) - Method in interface org.springframework.amqp.rabbit.retry.MessageKeyGenerator: Generate a unique key for the message that is repeatable on redelivery.
getKeyClassIdFieldName() - Method in class org.springframework.amqp.support.converter.AbstractJavaTypeMapper
getKeyStore() - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
getKeyStorePassphrase() - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
getLastDeclarationExceptionEvent() - Method in class org.springframework.amqp.rabbit.core.RabbitAdmin
getLatch() - Method in class org.springframework.amqp.rabbit.test.mockito.LatchCountDownAndCallRealMethodAnswer
getListenerContainer(String) - Method in class org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistry: Return the MessageListenerContainer with the specified id or null if no such container exists.
getListenerContainerIds() - Method in class org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistry: Return the ids of the managed MessageListenerContainer instance(s).
getListenerContainers() - Method in class org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistry
getListenerId() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer: The 'id' attribute of the listener.
getListenerId() - Method in class org.springframework.amqp.rabbit.listener.ListenerContainerIdleEvent: The id of the listener (if @RabbitListener) or the container bean name.
getListenerMethodName(Message, Object) - Method in class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter: Determine the name of the listener method that will handle the given message.
getMaxSenderRetries() - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender
getMaxSenderRetries() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
getMessage() - Method in class org.springframework.amqp.rabbit.core.support.MessageBatch
getMessageConverter() - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate: Return the message converter for this template.
getMessageConverter() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
getMessageConverter() - Method in class org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener: Return the converter that will convert incoming Rabbit messages to listener method arguments, and objects returned from listener methods back to Rabbit messages.
getMessageConverter() - Method in interface org.springframework.amqp.rabbit.listener.MessageListenerContainer
getMessageConverter() - Method in class org.springframework.amqp.remoting.service.AmqpInvokerServiceExporter
getMessageCount() - Method in class org.springframework.amqp.core.MessageProperties
getMessageCount() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
getMessageHandlerMethodFactory() - Method in class org.springframework.amqp.rabbit.listener.MethodRabbitListenerEndpoint
getMessageHandlerMethodFactory() - Method in class org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistrar
getMessageId() - Method in class org.springframework.amqp.core.MessageProperties
getMessageId() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
getMessageListener() - Method in class org.springframework.amqp.rabbit.config.SimpleRabbitListenerEndpoint
getMessageListener() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
getMessageProperties() - Method in class org.springframework.amqp.core.Message
getMessageRecoverer() - Method in class org.springframework.amqp.rabbit.config.AbstractRetryOperationsInterceptorFactoryBean
getMessagingMessageConverter() - Method in class org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter
getMethod() - Method in class org.springframework.amqp.rabbit.listener.MethodRabbitListenerEndpoint
getMethodAsString(Object) - Method in class org.springframework.amqp.rabbit.listener.adapter.HandlerAdapter
getMethodNameFor(Object) - Method in class org.springframework.amqp.rabbit.listener.adapter.DelegatingInvocableHandler: Return a string representation of the method that will be invoked for this payload.
getNackCause() - Method in class org.springframework.amqp.rabbit.core.AsyncRabbitTemplate.RabbitFuture: When confirms are enabled and a nack is received, contains the cause for the nack, if any.
getName() - Method in class org.springframework.amqp.core.AbstractExchange
getName() - Method in interface org.springframework.amqp.core.Exchange: The name of the exchange.
getName() - Method in class org.springframework.amqp.core.Queue
getNextInvocationDataFor(String, long, TimeUnit) - Method in class org.springframework.amqp.rabbit.test.RabbitListenerTestHarness
getNextPublishSeqNo() - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
getObject() - Method in class org.springframework.amqp.rabbit.config.BindingFactoryBean
getObject() - Method in class org.springframework.amqp.rabbit.config.StatefulRetryOperationsInterceptorFactoryBean
getObject() - Method in class org.springframework.amqp.rabbit.config.StatelessRetryOperationsInterceptorFactoryBean
getObject() - Method in class org.springframework.amqp.remoting.client.AmqpProxyFactoryBean
getObjectType() - Method in class org.springframework.amqp.rabbit.config.BindingFactoryBean
getObjectType() - Method in class org.springframework.amqp.rabbit.config.StatefulRetryOperationsInterceptorFactoryBean
getObjectType() - Method in class org.springframework.amqp.rabbit.config.StatelessRetryOperationsInterceptorFactoryBean
getObjectType() - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
getObjectType() - Method in class org.springframework.amqp.rabbit.support.ExpressionFactoryBean
getObjectType() - Method in class org.springframework.amqp.remoting.client.AmqpProxyFactoryBean
getOrder() - Method in class org.springframework.amqp.rabbit.annotation.RabbitListenerAnnotationBeanPostProcessor
getOrder() - Method in class org.springframework.amqp.support.postprocessor.AbstractCompressingPostProcessor
getOrder() - Method in class org.springframework.amqp.support.postprocessor.AbstractDecompressingPostProcessor
getOrder() - Method in class org.springframework.amqp.support.postprocessor.DelegatingDecompressingPostProcessor
getPassword() - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender
getPassword() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
getPhase() - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory
getPhase() - Method in class org.springframework.amqp.rabbit.core.AsyncRabbitTemplate
getPhase() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
getPhase() - Method in class org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistry
getPort() - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
getPort() - Method in class org.springframework.amqp.rabbit.connection.AbstractRoutingConnectionFactory
getPort() - Method in interface org.springframework.amqp.rabbit.connection.ConnectionFactory
getPort() - Method in class org.springframework.amqp.rabbit.connection.LocalizedQueueConnectionFactory
getPort() - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender
getPort() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
getPriority() - Method in class org.springframework.amqp.core.MessageProperties
getPriority() - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint
getPriority() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
getProperties() - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender.Event
getProperties() - Method in class org.springframework.amqp.rabbit.log4j2.AmqpAppender.Event
getProperties() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender.Event
getPropertyValue(Object, String) - Static method in class org.springframework.amqp.utils.test.TestUtils: Uses nested DirectFieldAccessors to obtain a property using dotted notation to traverse fields; e.g.
getPropertyValue(Object, String, Class<T>) - Static method in class org.springframework.amqp.utils.test.TestUtils
getQueue(String) - Method in interface org.springframework.amqp.core.AmqpManagementOperations: Get a specific queue from the default vhost ('/').
getQueue(String, String) - Method in interface org.springframework.amqp.core.AmqpManagementOperations: Get a specific queue from the provided vhost.
getQueue(String) - Method in class org.springframework.amqp.rabbit.core.RabbitManagementTemplate
getQueue(String, String) - Method in class org.springframework.amqp.rabbit.core.RabbitManagementTemplate
getQueueNames() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
getQueueNames() - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint
getQueueNamesAsSet() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
getQueueProperties(String) - Method in interface org.springframework.amqp.core.AmqpAdmin: Returns an implementation-specific Map of properties if the queue exists.
getQueueProperties(String) - Method in class org.springframework.amqp.rabbit.core.RabbitAdmin: Returns 3 properties RabbitAdmin.QUEUE_NAME, RabbitAdmin.QUEUE_MESSAGE_COUNT, RabbitAdmin.QUEUE_CONSUMER_COUNT, or null if the queue doesn't exist.
getQueues() - Method in interface org.springframework.amqp.core.AmqpManagementOperations: Get all queues.
getQueues(String) - Method in interface org.springframework.amqp.core.AmqpManagementOperations: Get all queues in the provided vhost.
getQueues() - Method in class org.springframework.amqp.rabbit.core.RabbitManagementTemplate
getQueues(String) - Method in class org.springframework.amqp.rabbit.core.RabbitManagementTemplate
getQueues() - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint
getQueues() - Method in class org.springframework.amqp.rabbit.listener.ListenerContainerIdleEvent: The queues the container is listening to.
getRabbitAdmin() - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer
getRabbitTemplate() - Method in class org.springframework.amqp.rabbit.core.RabbitAdmin
getRabbitTemplate() - Method in class org.springframework.amqp.rabbit.core.RabbitGatewaySupport
getRabbitTemplate() - Method in class org.springframework.amqp.rabbit.core.RabbitMessagingTemplate
getReason() - Method in class org.springframework.amqp.rabbit.listener.ListenerContainerConsumerFailedEvent
getReceivedDelay() - Method in class org.springframework.amqp.core.MessageProperties: When a delayed message exchange is used the x-delay header on a received message contains the delay.
getReceivedExchange() - Method in class org.springframework.amqp.core.MessageProperties
getReceivedExchange(Message) - Method in class org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener
getReceivedExchange() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
getReceivedRoutingKey() - Method in class org.springframework.amqp.core.MessageProperties
getReceivedRoutingKey() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
getRedelivered() - Method in class org.springframework.amqp.core.MessageProperties
getRedelivered() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
getRemoteInvocationFactory() - Method in class org.springframework.amqp.remoting.client.AmqpClientInterceptor
getReplyCode() - Method in exception org.springframework.amqp.core.AmqpMessageReturnedException
getReplyText() - Method in exception org.springframework.amqp.core.AmqpMessageReturnedException
getReplyTo() - Method in class org.springframework.amqp.core.MessageProperties
getReplyTo() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
getReplyToAddress() - Method in class org.springframework.amqp.core.MessageProperties
getReplyToAddress(Message, T) - Method in interface org.springframework.amqp.core.ReplyToAddressCallback
getReplyToAddress(Message) - Method in class org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener: Determine a reply-to Address for the given message.
getRequiredQueueNames() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
getResolver() - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint
getResourceFactory() - Method in class org.springframework.amqp.rabbit.transaction.RabbitTransactionManager
getResources() - Static method in class org.springframework.amqp.rabbit.connection.SimpleResourceHolder: Return all resources that are bound to the current thread.
getResult() - Method in class org.springframework.amqp.rabbit.test.RabbitListenerTestHarness.InvocationData
getRetryOperations() - Method in class org.springframework.amqp.rabbit.config.AbstractRetryOperationsInterceptorFactoryBean
getReturnedMessage() - Method in exception org.springframework.amqp.core.AmqpMessageReturnedException
getRoutingKey() - Method in class org.springframework.amqp.core.Address
getRoutingKey() - Method in exception org.springframework.amqp.core.AmqpMessageReturnedException
getRoutingKey() - Method in class org.springframework.amqp.core.Binding
getRoutingKey() - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
getRoutingKey() - Method in class org.springframework.amqp.rabbit.core.support.MessageBatch
getRoutingKey() - Method in class org.springframework.amqp.remoting.client.AmqpClientInterceptor
getRoutingKeyPattern() - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender
getRoutingKeyPattern() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
getSenderPoolSize() - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender
getSenderPoolSize() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
getSslAlgorithm() - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
getSslPropertiesLocation() - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
getTargetChannel() - Method in interface org.springframework.amqp.rabbit.connection.ChannelProxy: Return the target Channel of this proxy.
getTargetConnection() - Method in interface org.springframework.amqp.rabbit.connection.ConnectionProxy: Return the target Channel of this proxy.
getTargetConnectionFactory(Object) - Method in class org.springframework.amqp.rabbit.connection.AbstractRoutingConnectionFactory
getTargetConnectionFactory(Object) - Method in class org.springframework.amqp.rabbit.connection.LocalizedQueueConnectionFactory
getTargetConnectionFactory(Object) - Method in interface org.springframework.amqp.rabbit.connection.RoutingConnectionFactory: Returns the ConnectionFactory bound to given lookup key, or null if one does not exist
getThrowable() - Method in class org.springframework.amqp.rabbit.core.DeclarationExceptionEvent
getThrowable() - Method in class org.springframework.amqp.rabbit.listener.ListenerContainerConsumerFailedEvent
getThrowable() - Method in class org.springframework.amqp.rabbit.test.RabbitListenerTestHarness.InvocationData
getTimestamp() - Method in class org.springframework.amqp.core.MessageProperties
getTimestamp() - Method in class org.springframework.amqp.rabbit.support.PendingConfirm
getTimestamp() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
getTransactionalResourceHolder(ConnectionFactory, boolean) - Static method in class org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils: Obtain a RabbitMQ Channel that is synchronized with the current transaction, if any.
getTransactionalResourceHolder() - Method in class org.springframework.amqp.rabbit.connection.RabbitAccessor
getTrustStore() - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
getTrustStorePassphrase() - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
getType() - Method in class org.springframework.amqp.core.AbstractExchange
getType() - Method in class org.springframework.amqp.core.CustomExchange
getType() - Method in class org.springframework.amqp.core.DirectExchange
getType() - Method in interface org.springframework.amqp.core.Exchange: The type of the exchange.
getType() - Method in class org.springframework.amqp.core.FanoutExchange
getType() - Method in class org.springframework.amqp.core.HeadersExchange
getType() - Method in class org.springframework.amqp.core.MessageProperties
getType() - Method in class org.springframework.amqp.core.TopicExchange
getType() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
getUnconfirmed(long) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate: Gets unconfirmed correlation data older than age and removes them.
getUserId() - Method in class org.springframework.amqp.core.MessageProperties
getUserId() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
getUsername() - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender
getUsername() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
getUUID() - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
getUUID() - Method in interface org.springframework.amqp.rabbit.support.PublisherCallbackChannel.Listener: Returns the UUID used to identify this Listener for returns.
getValue() - Method in class org.springframework.amqp.rabbit.support.ValueExpression
getValue(Object) - Method in class org.springframework.amqp.rabbit.support.ValueExpression
getValue(EvaluationContext) - Method in class org.springframework.amqp.rabbit.support.ValueExpression
getValue(EvaluationContext, Object) - Method in class org.springframework.amqp.rabbit.support.ValueExpression
getValue(Object, Class<T>) - Method in class org.springframework.amqp.rabbit.support.ValueExpression
getValue(Class<T>) - Method in class org.springframework.amqp.rabbit.support.ValueExpression
getValue(EvaluationContext, Object, Class<T>) - Method in class org.springframework.amqp.rabbit.support.ValueExpression
getValue(EvaluationContext, Class<T>) - Method in class org.springframework.amqp.rabbit.support.ValueExpression
getValueType() - Method in class org.springframework.amqp.rabbit.support.ValueExpression
getValueType(Object) - Method in class org.springframework.amqp.rabbit.support.ValueExpression
getValueType(EvaluationContext) - Method in class org.springframework.amqp.rabbit.support.ValueExpression
getValueType(EvaluationContext, Object) - Method in class org.springframework.amqp.rabbit.support.ValueExpression
getValueTypeDescriptor() - Method in class org.springframework.amqp.rabbit.support.ValueExpression
getValueTypeDescriptor(Object) - Method in class org.springframework.amqp.rabbit.support.ValueExpression
getValueTypeDescriptor(EvaluationContext) - Method in class org.springframework.amqp.rabbit.support.ValueExpression
getValueTypeDescriptor(EvaluationContext, Object) - Method in class org.springframework.amqp.rabbit.support.ValueExpression
getVirtualHost() - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
getVirtualHost() - Method in class org.springframework.amqp.rabbit.connection.AbstractRoutingConnectionFactory
getVirtualHost() - Method in interface org.springframework.amqp.rabbit.connection.ConnectionFactory
getVirtualHost() - Method in class org.springframework.amqp.rabbit.connection.LocalizedQueueConnectionFactory
getVirtualHost() - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender
getVirtualHost() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
GUnzipPostProcessor - Class in org.springframework.amqp.support.postprocessor: A post processor that uses a GZIPInputStream to decompress the message body.
GUnzipPostProcessor() - Constructor for class org.springframework.amqp.support.postprocessor.GUnzipPostProcessor
GUnzipPostProcessor(boolean) - Constructor for class org.springframework.amqp.support.postprocessor.GUnzipPostProcessor
GZipPostProcessor - Class in org.springframework.amqp.support.postprocessor: A post processor that uses a GZIPOutputStream to compress the message body.
GZipPostProcessor() - Constructor for class org.springframework.amqp.support.postprocessor.GZipPostProcessor
GZipPostProcessor(boolean) - Constructor for class org.springframework.amqp.support.postprocessor.GZipPostProcessor

H

handle(R) - Method in interface org.springframework.amqp.core.ReceiveAndReplyCallback
handleAck(long, boolean) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
handleConfirm(PendingConfirm, boolean) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
handleConfirm(PendingConfirm, boolean) - Method in interface org.springframework.amqp.rabbit.support.PublisherCallbackChannel.Listener: Invoked by the channel when a confirm is received.
handleError(Throwable) - Method in class org.springframework.amqp.rabbit.listener.ConditionalRejectingErrorHandler
handleListenerException(Throwable) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer: Handle the given exception that arose during listener execution.
handleListenerException(Throwable) - Method in class org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener: Handle the given exception that arose during listener execution.
handleNack(long, boolean) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
HandlerAdapter - Class in org.springframework.amqp.rabbit.listener.adapter: A wrapper for either an InvocableHandlerMethod or DelegatingInvocableHandler.
HandlerAdapter(InvocableHandlerMethod) - Constructor for class org.springframework.amqp.rabbit.listener.adapter.HandlerAdapter
HandlerAdapter(DelegatingInvocableHandler) - Constructor for class org.springframework.amqp.rabbit.listener.adapter.HandlerAdapter
handleResult(Object, Message, Channel) - Method in class org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener: Handle the given result object returned from the listener method, sending a response message back.
handleReturn(int, String, String, String, AMQP.BasicProperties, byte[]) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
handleReturn(int, String, String, String, AMQP.BasicProperties, byte[]) - Method in interface org.springframework.amqp.rabbit.support.PublisherCallbackChannel.Listener
handleReturn(int, String, String, String, AMQP.BasicProperties, byte[]) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
handleStartupFailure(BackOffExecution) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer: Wait for a period determined by the recoveryInterval or SimpleMessageListenerContainer.setRecoveryBackOff(BackOff) to give the container a chance to recover from consumer startup failure, e.g.
has(Object) - Static method in class org.springframework.amqp.rabbit.connection.SimpleResourceHolder: Check if there is a resource for the given key bound to the current thread.
hasDelivery() - Method in class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer
hashCode() - Method in class org.springframework.amqp.core.Address
hashCode() - Method in class org.springframework.amqp.core.Message
hashCode() - Method in class org.springframework.amqp.core.MessageProperties
hashCode() - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
HEADERS - Static variable in class org.springframework.amqp.core.ExchangeTypes
HeadersExchange - Class in org.springframework.amqp.core
HeadersExchange(String) - Constructor for class org.springframework.amqp.core.HeadersExchange
HeadersExchange(String, boolean, boolean) - Constructor for class org.springframework.amqp.core.HeadersExchange
HeadersExchange(String, boolean, boolean, Map<String, Object>) - Constructor for class org.springframework.amqp.core.HeadersExchange
HeadersExchangeParser - Class in org.springframework.amqp.rabbit.config
HeadersExchangeParser() - Constructor for class org.springframework.amqp.rabbit.config.HeadersExchangeParser

I

ImmediateAcknowledgeAmqpException - Exception in org.springframework.amqp: Special exception for listener implementations that want to signal that the current batch of messages should be acknowledged immediately (i.e.
ImmediateAcknowledgeAmqpException(String) - Constructor for exception org.springframework.amqp.ImmediateAcknowledgeAmqpException
ImmediateAcknowledgeAmqpException(Throwable) - Constructor for exception org.springframework.amqp.ImmediateAcknowledgeAmqpException
ImmediateAcknowledgeAmqpException(String, Throwable) - Constructor for exception org.springframework.amqp.ImmediateAcknowledgeAmqpException
incrementRetries() - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender.Event
incrementRetries() - Method in class org.springframework.amqp.rabbit.log4j2.AmqpAppender.Event
incrementRetries() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender.Event
init() - Method in class org.springframework.amqp.rabbit.config.RabbitNamespaceHandler
initDefaultStrategies() - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate: Set up the default strategies.
initGateway() - Method in class org.springframework.amqp.rabbit.core.RabbitGatewaySupport: Subclasses can override this for custom initialization behavior.
initialize() - Method in class org.springframework.amqp.rabbit.core.RabbitAdmin: Declares all the exchanges, queues and bindings in the enclosing application context, if any.
initialize() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer: Initialize this container.
initializeConsumers() - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer
initializeContainer(C) - Method in class org.springframework.amqp.rabbit.config.AbstractRabbitListenerContainerFactory: Further initialize the specified container.
initializeContainer(SimpleMessageListenerContainer) - Method in class org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory
initializeJsonObjectMapper() - Method in class org.springframework.amqp.support.converter.Jackson2JsonMessageConverter: Subclass and override to customize.
initializeJsonObjectMapper() - Method in class org.springframework.amqp.support.converter.JsonMessageConverter: Subclass and override to customize.
InvocationData(MethodInvocation, Object) - Constructor for class org.springframework.amqp.rabbit.test.RabbitListenerTestHarness.InvocationData
InvocationData(MethodInvocation, Throwable) - Constructor for class org.springframework.amqp.rabbit.test.RabbitListenerTestHarness.InvocationData
invoke(Message<?>, Object...) - Method in class org.springframework.amqp.rabbit.listener.adapter.DelegatingInvocableHandler: Invoke the method with the given message.
invoke(Message<?>, Object...) - Method in class org.springframework.amqp.rabbit.listener.adapter.HandlerAdapter
invoke(MethodInvocation) - Method in class org.springframework.amqp.rabbit.retry.MissingMessageIdAdvice
invoke(MethodInvocation) - Method in class org.springframework.amqp.remoting.client.AmqpClientInterceptor
invokeErrorHandler(Throwable) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer: Invoke the registered ErrorHandler, if any.
invokeListener(Channel, Message) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer: Invoke the specified listener: either as standard MessageListener or (preferably) as SessionAwareMessageListener.
invokeListener(Channel, Message) - Method in interface org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer.ContainerDelegate
invokeListener(Channel, Message) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer
invokeListenerMethod(String, Object[]) - Method in class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter: Deprecated.
in favor of MessageListenerAdapter.invokeListenerMethod(String, Object[], Message)
invokeListenerMethod(String, Object[], Message) - Method in class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter: Invoke the specified listener method.
isActive() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
isAttributeDefined(Element, String) - Static method in class org.springframework.amqp.rabbit.config.NamespaceUtils: Checks the attribute to see if it is defined in the given element.
isAutoAck() - Method in enum org.springframework.amqp.core.AcknowledgeMode
isAutoDelete() - Method in class org.springframework.amqp.core.AbstractExchange
isAutoDelete() - Method in interface org.springframework.amqp.core.Exchange: True if the server should delete the exchange when it is no longer in use (if all bindings are deleted).
isAutoDelete() - Method in class org.springframework.amqp.core.Queue: True if the server should delete the queue when it is no longer in use (the last consumer is cancelled).
isAutoDelete() - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender
isAutoDelete() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
isAutoStartup() - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory
isAutoStartup() - Method in class org.springframework.amqp.rabbit.core.AsyncRabbitTemplate
isAutoStartup() - Method in class org.springframework.amqp.rabbit.core.RabbitAdmin
isAutoStartup() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
isAutoStartup() - Method in class org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistry
isChannelLocallyTransacted(Channel) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate: Check whether the given Channel is locally transacted, that is, whether its transaction is managed by this template's Channel handling and not by an external transaction coordinator.
isChannelLocallyTransacted(Channel) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer: Check whether the given Channel is locally transacted, that is, whether its transaction is managed by this listener container's Channel handling and not by an external transaction coordinator.
isChannelLocallyTransacted(Channel) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer
isChannelTransacted() - Method in class org.springframework.amqp.rabbit.connection.RabbitAccessor
isChannelTransactional(Channel, ConnectionFactory) - Static method in class org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils: Determine whether the given RabbitMQ Channel is transactional, that is, bound to the current thread by Spring's transaction facilities.
isChannelTransactional() - Method in class org.springframework.amqp.rabbit.connection.RabbitResourceHolder
isConfirmListener() - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
isConfirmListener() - Method in interface org.springframework.amqp.rabbit.support.PublisherCallbackChannel.Listener
isContentLengthSet() - Method in class org.springframework.amqp.core.MessageProperties
isCreateMessageIds() - Method in class org.springframework.amqp.support.converter.AbstractMessageConverter: Flag to indicate that new messages should have unique identifiers added to their properties before sending.
isDeclareExchange() - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender
isDeclareExchange() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
isDelayed() - Method in class org.springframework.amqp.core.AbstractExchange
isDelayed() - Method in interface org.springframework.amqp.core.Exchange: Is a delayed message exchange; currently requires a broker plugin.
isDeliveryTagSet() - Method in class org.springframework.amqp.core.MessageProperties
isDestinationQueue() - Method in class org.springframework.amqp.core.Binding
isDurable() - Method in class org.springframework.amqp.core.AbstractExchange
isDurable() - Method in interface org.springframework.amqp.core.Exchange: A durable exchange will survive a server restart
isDurable() - Method in class org.springframework.amqp.core.Queue: A durable queue will survive a server restart
isDurable() - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender
isDurable() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
isExchangeDeclarationFailure(Exception) - Static method in class org.springframework.amqp.rabbit.connection.RabbitUtils: Return true if there is a ShutdownSignalException in the cause tree and its reason is "COMMAND_INVALID" and the operation being performed was exchangeDeclare.
isExclusive() - Method in class org.springframework.amqp.core.Queue: True if the server should only send messages to the declarer's connection.
isExclusive() - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint
isExclusiveUseChannelClose(ShutdownSignalException) - Static method in class org.springframework.amqp.rabbit.connection.RabbitUtils: Return true if the ShutdownSignalException reason is AMQP.Channel.Close and the operation that failed was basicConsumer and the failure text contains "exclusive".
isExistingTransaction(Object) - Method in class org.springframework.amqp.rabbit.transaction.RabbitTransactionManager
isExposeListenerChannel() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
isFatal(Throwable) - Method in interface org.springframework.amqp.rabbit.listener.FatalExceptionStrategy
isFatal() - Method in class org.springframework.amqp.rabbit.listener.ListenerContainerConsumerFailedEvent
isFrozen() - Method in class org.springframework.amqp.rabbit.connection.RabbitResourceHolder
isGenerateId() - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender
isGenerateId() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
isLenientFallback() - Method in class org.springframework.amqp.rabbit.connection.AbstractRoutingConnectionFactory
isManual() - Method in enum org.springframework.amqp.core.AcknowledgeMode
isMismatchedQueueArgs(Exception) - Static method in class org.springframework.amqp.rabbit.connection.RabbitUtils: Return true if there is a ShutdownSignalException in the cause tree and its reason is "PRECONDITION_FAILED" and the operation being performed was queueDeclare.
isNew(Message) - Method in interface org.springframework.amqp.rabbit.retry.NewMessageIdentifier: Query a message to see if it has been seen before.
isNormalChannelClose(ShutdownSignalException) - Static method in class org.springframework.amqp.rabbit.connection.RabbitUtils: Return true if the ShutdownSignalException reason is AMQP.Channel.Close and the reply code was AMQP.REPLY_SUCCESS (200) and the text equals "OK".
isNormalShutdown(ShutdownSignalException) - Static method in class org.springframework.amqp.rabbit.connection.RabbitUtils: Return true if the ShutdownSignalException reason is AMQP.Connection.Close and the reply code was AMQP.REPLY_SUCCESS (200) and the text equals "OK".
isOpen() - Method in interface org.springframework.amqp.rabbit.connection.Connection: Flag to indicate the status of the connection.
isOpen() - Method in class org.springframework.amqp.rabbit.connection.SimpleConnection
isOpen() - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
isPassiveDeclarationChannelClose(ShutdownSignalException) - Static method in class org.springframework.amqp.rabbit.connection.RabbitUtils: Return true if the ShutdownSignalException reason is AMQP.Channel.Close and the operation that failed was exchangeDeclare or queueDeclare.
isPhysicalCloseRequired() - Static method in class org.springframework.amqp.rabbit.connection.RabbitUtils: Gets and removes a ThreadLocal indicating the channel MUST be physically closed.
isPublisherConfirms() - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory
isPublisherConfirms() - Method in interface org.springframework.amqp.rabbit.connection.PublisherCallbackChannelConnectionFactory
isPublisherReturns() - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory
isPublisherReturns() - Method in interface org.springframework.amqp.rabbit.connection.PublisherCallbackChannelConnectionFactory
isRedelivered() - Method in class org.springframework.amqp.core.MessageProperties
isReleaseAfterCompletion() - Method in class org.springframework.amqp.rabbit.connection.RabbitResourceHolder: Whether the resources should be released after transaction completion.
isReturnListener() - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
isReturnListener() - Method in interface org.springframework.amqp.rabbit.support.PublisherCallbackChannel.Listener
isRunning() - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory
isRunning() - Method in class org.springframework.amqp.rabbit.core.AsyncRabbitTemplate
isRunning() - Method in class org.springframework.amqp.rabbit.core.BatchingRabbitTemplate
isRunning() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer: Determine whether this container is currently running, that is, whether it has been started and not stopped yet.
isRunning() - Method in class org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistry
isSingleton() - Method in class org.springframework.amqp.rabbit.config.AbstractRetryOperationsInterceptorFactoryBean
isSingleton() - Method in class org.springframework.amqp.rabbit.config.BindingFactoryBean
isSingleton() - Method in class org.springframework.amqp.rabbit.config.StatefulRetryOperationsInterceptorFactoryBean
isSingleton() - Method in class org.springframework.amqp.rabbit.config.StatelessRetryOperationsInterceptorFactoryBean
isSingleton() - Method in class org.springframework.amqp.remoting.client.AmqpProxyFactoryBean
isSynchedLocalTransactionAllowed() - Method in interface org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils.ResourceFactory: Return whether to allow for a local RabbitMQ transaction that is synchronized with a Spring-managed transaction (where the main transaction might be a JDBC-based one for a specific DataSource, for example), with the RabbitMQ transaction committing right after the main transaction.
isTransactional() - Method in interface org.springframework.amqp.rabbit.connection.ChannelProxy: Return whether this channel has transactions enabled txSelect().
isTransactionAllowed() - Method in enum org.springframework.amqp.core.AcknowledgeMode
isUseSSL() - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
isWritable(EvaluationContext) - Method in class org.springframework.amqp.rabbit.support.ValueExpression
isWritable(EvaluationContext, Object) - Method in class org.springframework.amqp.rabbit.support.ValueExpression
isWritable(Object) - Method in class org.springframework.amqp.rabbit.support.ValueExpression

J

Jackson2JavaTypeMapper - Interface in org.springframework.amqp.support.converter: Strategy for setting metadata on messages such that one can create the class that needs to be instantiated when receiving a message.
Jackson2JsonMessageConverter - Class in org.springframework.amqp.support.converter: JSON converter that uses the Jackson 2 Json library.
Jackson2JsonMessageConverter() - Constructor for class org.springframework.amqp.support.converter.Jackson2JsonMessageConverter
JavaTypeMapper - Interface in org.springframework.amqp.support.converter: Strategy for setting metadata on messages such that one can create the class that needs to be instantiated when receiving a message.
JsonMessageConverter - Class in org.springframework.amqp.support.converter: JSON converter that uses the Jackson Json library.
JsonMessageConverter() - Constructor for class org.springframework.amqp.support.converter.JsonMessageConverter

L

LambdaAnswer<T> - Class in org.springframework.amqp.rabbit.test.mockito: An Answer to optionally call the real method and allow returning a custom result.
LambdaAnswer(boolean, LambdaAnswer.ValueToReturn<T>) - Constructor for class org.springframework.amqp.rabbit.test.mockito.LambdaAnswer
LambdaAnswer.ValueToReturn<T> - Interface in org.springframework.amqp.rabbit.test.mockito
LatchCountDownAndCallRealMethodAnswer - Class in org.springframework.amqp.rabbit.test.mockito: An Answer for void returning methods that calls the real method and counts down a latch.
LatchCountDownAndCallRealMethodAnswer(int) - Constructor for class org.springframework.amqp.rabbit.test.mockito.LatchCountDownAndCallRealMethodAnswer
level - Variable in class org.springframework.amqp.support.postprocessor.AbstractDeflaterPostProcessor
ListenerContainerAware - Interface in org.springframework.amqp.rabbit.support: MessageListeners and ChannelAwareMessageListeners that also implement this interface can have configuration verified during initialization.
ListenerContainerConsumerFailedEvent - Class in org.springframework.amqp.rabbit.listener: Published when a listener consumer fails.
ListenerContainerConsumerFailedEvent(Object, String, Throwable, boolean) - Constructor for class org.springframework.amqp.rabbit.listener.ListenerContainerConsumerFailedEvent: Construct an instance with the provided arguments.
ListenerContainerIdleEvent - Class in org.springframework.amqp.rabbit.listener: An event that is emitted when a container is idle if the container is configured to do so.
ListenerContainerIdleEvent(SimpleMessageListenerContainer, long) - Constructor for class org.springframework.amqp.rabbit.listener.ListenerContainerIdleEvent
ListenerExecutionFailedException - Exception in org.springframework.amqp.rabbit.listener.exception: Exception to be thrown when the execution of a listener method failed.
ListenerExecutionFailedException(String, Throwable) - Constructor for exception org.springframework.amqp.rabbit.listener.exception.ListenerExecutionFailedException: Constructor for ListenerExecutionFailedException.
ListenerExecutionFailedException(String, Throwable, Message) - Constructor for exception org.springframework.amqp.rabbit.listener.exception.ListenerExecutionFailedException: Constructor for ListenerExecutionFailedException.
LocalizedQueueConnectionFactory - Class in org.springframework.amqp.rabbit.connection: A RoutingConnectionFactory that determines the node on which a queue is located and returns a factory that connects directly to that node.
LocalizedQueueConnectionFactory(ConnectionFactory, Map<String, String>, String[], String, String, String, boolean, Resource) - Constructor for class org.springframework.amqp.rabbit.connection.LocalizedQueueConnectionFactory
LocalizedQueueConnectionFactory(ConnectionFactory, Map<String, String>, String[], String, String, String, boolean, String, String, String, String) - Constructor for class org.springframework.amqp.rabbit.connection.LocalizedQueueConnectionFactory
LocalizedQueueConnectionFactory(ConnectionFactory, String[], String[], String[], String, String, String, boolean, Resource) - Constructor for class org.springframework.amqp.rabbit.connection.LocalizedQueueConnectionFactory
LocalizedQueueConnectionFactory(ConnectionFactory, String[], String[], String[], String, String, String, boolean, String, String, String, String) - Constructor for class org.springframework.amqp.rabbit.connection.LocalizedQueueConnectionFactory
log(Log, String, Throwable) - Method in interface org.springframework.amqp.support.ConditionalExceptionLogger: Log the event.
logger - Variable in class org.springframework.amqp.rabbit.config.AbstractRabbitListenerContainerFactory
logger - Variable in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
logger - Variable in class org.springframework.amqp.rabbit.connection.RabbitAccessor: Logger available to subclasses
logger - Variable in class org.springframework.amqp.rabbit.core.RabbitAdmin: Logger available to subclasses
logger - Variable in class org.springframework.amqp.rabbit.core.RabbitGatewaySupport: Logger available to subclasses
logger - Variable in class org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener: Logger available to subclasses
logger - Variable in class org.springframework.amqp.rabbit.listener.ConditionalRejectingErrorHandler
logger - Variable in class org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistry
logger - Variable in class org.springframework.amqp.rabbit.retry.RejectAndDontRequeueRecoverer

M

MarshallingMessageConverter - Class in org.springframework.amqp.support.converter: Spring Rabbit MessageConverter that uses a Marshaller and Unmarshaller.
MarshallingMessageConverter() - Constructor for class org.springframework.amqp.support.converter.MarshallingMessageConverter: Construct a new MarshallingMessageConverter with no Marshaller or Unmarshaller set.
MarshallingMessageConverter(Marshaller) - Constructor for class org.springframework.amqp.support.converter.MarshallingMessageConverter: Construct a new MarshallingMessageConverter with the given Marshaller set.
MarshallingMessageConverter(Marshaller, Unmarshaller) - Constructor for class org.springframework.amqp.support.converter.MarshallingMessageConverter: Construct a new MarshallingMessageConverter with the given Marshaller and Unmarshaller.
match() - Method in class org.springframework.amqp.core.BindingBuilder.HeadersExchangeMapConfigurer.HeadersExchangeMapBindingCreator
matches(Object) - Method in class org.springframework.amqp.core.BindingBuilder.HeadersExchangeMapConfigurer.HeadersExchangeSingleValueBindingCreator
matchHandlerMethod(Class<? extends Object>, InvocableHandlerMethod) - Method in class org.springframework.amqp.rabbit.listener.adapter.DelegatingInvocableHandler
maxAttempts(int) - Method in class org.springframework.amqp.rabbit.config.RetryInterceptorBuilder: Apply the max attempts - a SimpleRetryPolicy will be used.
maxAttempts(int) - Method in class org.springframework.amqp.rabbit.config.RetryInterceptorBuilder.StatefulRetryInterceptorBuilder
maybeDeclareExchange() - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender: Deprecated.
- use AmqpAppender.setUpExchangeDeclaration()
maybeDeclareExchange() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender: Deprecated.
- use AmqpAppender.setUpExchangeDeclaration()
Message - Class in org.springframework.amqp.core: The 0-8 and 0-9-1 AMQP specifications do not define an Message class or interface.
Message(byte[], MessageProperties) - Constructor for class org.springframework.amqp.core.Message
MESSAGE_COUNT - Static variable in class org.springframework.amqp.support.AmqpHeaders
MESSAGE_ID - Static variable in class org.springframework.amqp.support.AmqpHeaders
MessageBatch - Class in org.springframework.amqp.rabbit.core.support: An object encapsulating a Message containing the batch of messages, the exchange, and routing key.
MessageBatch(String, String, Message) - Constructor for class org.springframework.amqp.rabbit.core.support.MessageBatch
MessageBuilder - Class in org.springframework.amqp.core: Builds a Spring AMQP Message either from a byte[] body or another Message using a fluent API.
MessageBuilderSupport<T> - Class in org.springframework.amqp.core: Support class for building Message and MessageProperties fluent API.
MessageBuilderSupport() - Constructor for class org.springframework.amqp.core.MessageBuilderSupport
MessageBuilderSupport(MessageProperties) - Constructor for class org.springframework.amqp.core.MessageBuilderSupport
MessageConversionException - Exception in org.springframework.amqp.support.converter: Exception to be thrown by message converters if they encounter a problem with converting a message or object.
MessageConversionException(String, Throwable) - Constructor for exception org.springframework.amqp.support.converter.MessageConversionException
MessageConversionException(String) - Constructor for exception org.springframework.amqp.support.converter.MessageConversionException
MessageConverter - Interface in org.springframework.amqp.support.converter
messageCount(String) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
MessageDeliveryMode - Enum in org.springframework.amqp.core: Enumeration for the message delivery mode.
messageKeyGenerator(MessageKeyGenerator) - Method in class org.springframework.amqp.rabbit.config.RetryInterceptorBuilder.StatefulRetryInterceptorBuilder: Stateful retry requires messages to be identifiable.
MessageKeyGenerator - Interface in org.springframework.amqp.rabbit.retry
MessageListener - Interface in org.springframework.amqp.core: Listener interface to receive asynchronous delivery of Amqp Messages.
MessageListenerAdapter - Class in org.springframework.amqp.rabbit.listener.adapter: Message listener adapter that delegates the handling of messages to target listener methods via reflection, with flexible message type conversion.
MessageListenerAdapter() - Constructor for class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter: Create a new MessageListenerAdapter with default settings.
MessageListenerAdapter(Object) - Constructor for class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter: Create a new MessageListenerAdapter for the given delegate.
MessageListenerAdapter(Object, MessageConverter) - Constructor for class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter: Create a new MessageListenerAdapter for the given delegate.
MessageListenerAdapter(Object, String) - Constructor for class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter: Create a new MessageListenerAdapter for the given delegate while also declaring its POJO method.
MessageListenerContainer - Interface in org.springframework.amqp.rabbit.listener: Internal abstraction used by the framework representing a message listener container.
MessagePostProcessor - Interface in org.springframework.amqp.core: To be used with the send method of Amqp template classes (such as RabbitTemplate) that convert an object to a message.
MessagePostProcessorUtils - Class in org.springframework.amqp.support.postprocessor
MessageProperties - Class in org.springframework.amqp.core: Message Properties for an AMQP message.
MessageProperties() - Constructor for class org.springframework.amqp.core.MessageProperties
MessagePropertiesBuilder - Class in org.springframework.amqp.core: Builds a Spring AMQP MessageProperties object using a fluent API.
MessagePropertiesConverter - Interface in org.springframework.amqp.rabbit.support: Strategy interface for converting between Spring AMQP MessageProperties and RabbitMQ BasicProperties.
MessageRecoverer - Interface in org.springframework.amqp.rabbit.retry
MessageRejectedWhileStoppingException - Exception in org.springframework.amqp.rabbit.listener: Exception class that indicates a rejected message on shutdown.
MessageRejectedWhileStoppingException() - Constructor for exception org.springframework.amqp.rabbit.listener.MessageRejectedWhileStoppingException
MessagingMessageConverter - Class in org.springframework.amqp.support.converter: Convert a Message from the messaging abstraction to and from a Message using an underlying MessageConverter for the payload and a AmqpHeaderMapper to map the AMQP headers to and from standard message headers.
MessagingMessageConverter() - Constructor for class org.springframework.amqp.support.converter.MessagingMessageConverter: Create an instance with a default payload converter for an inbound handler.
MessagingMessageConverter(MessageConverter, AmqpHeaderMapper) - Constructor for class org.springframework.amqp.support.converter.MessagingMessageConverter: Create an instance with the specified payload converter and header mapper.
MessagingMessageListenerAdapter - Class in org.springframework.amqp.rabbit.listener.adapter: A MessageListener adapter that invokes a configurable HandlerAdapter.
MessagingMessageListenerAdapter() - Constructor for class org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter
MethodRabbitListenerEndpoint - Class in org.springframework.amqp.rabbit.listener: A RabbitListenerEndpoint providing the method to invoke to process an incoming message for this endpoint.
MethodRabbitListenerEndpoint() - Constructor for class org.springframework.amqp.rabbit.listener.MethodRabbitListenerEndpoint
MissingMessageIdAdvice - Class in org.springframework.amqp.rabbit.retry: Advice that can be placed in the listener delegate's advice chain to enhance the message with an ID if not present.
MissingMessageIdAdvice(RetryContextCache) - Constructor for class org.springframework.amqp.rabbit.retry.MissingMessageIdAdvice
MultiMethodRabbitListenerEndpoint - Class in org.springframework.amqp.rabbit.listener
MultiMethodRabbitListenerEndpoint(List<Method>, Object) - Constructor for class org.springframework.amqp.rabbit.listener.MultiMethodRabbitListenerEndpoint

N

name - Variable in class org.springframework.amqp.core.BindingBuilder.DestinationConfigurer
NamespaceUtils - Class in org.springframework.amqp.rabbit.config: Shared utility methods for namespace parsers.
NamespaceUtils() - Constructor for class org.springframework.amqp.rabbit.config.NamespaceUtils
newInstance() - Static method in class org.springframework.amqp.core.MessagePropertiesBuilder: Returns a builder with an initial set of properties.
newMessageIdentifier(NewMessageIdentifier) - Method in class org.springframework.amqp.rabbit.config.RetryInterceptorBuilder.StatefulRetryInterceptorBuilder: Apply a custom new message identifier.
NewMessageIdentifier - Interface in org.springframework.amqp.rabbit.retry: An optimization for stateful retry of message processing.
nextMessage() - Method in class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer: Main application-side API: wait for the next message delivery and return it.
nextMessage(long) - Method in class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer: Main application-side API: wait for the next message delivery and return it.
nextRelease() - Method in interface org.springframework.amqp.rabbit.core.support.BatchingStrategy
nextRelease() - Method in class org.springframework.amqp.rabbit.core.support.SimpleBatchingStrategy
noargs() - Method in class org.springframework.amqp.core.BindingBuilder.GenericArgumentsConfigurer
notifyListeners() - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl

O

onApplicationEvent(ContextClosedEvent) - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory
onClose(Connection) - Method in class org.springframework.amqp.rabbit.connection.CompositeConnectionListener
onClose(Connection) - Method in interface org.springframework.amqp.rabbit.connection.ConnectionListener
onClose(Connection) - Method in class org.springframework.amqp.rabbit.support.DeclareExchangeConnectionListener
onCreate(Channel, boolean) - Method in interface org.springframework.amqp.rabbit.connection.ChannelListener
onCreate(Channel, boolean) - Method in class org.springframework.amqp.rabbit.connection.CompositeChannelListener
onCreate(Connection) - Method in class org.springframework.amqp.rabbit.connection.CompositeConnectionListener
onCreate(Connection) - Method in interface org.springframework.amqp.rabbit.connection.ConnectionListener
onCreate(Connection) - Method in class org.springframework.amqp.rabbit.support.DeclareExchangeConnectionListener
onMessage(Message) - Method in interface org.springframework.amqp.core.MessageListener
onMessage(Message) - Method in class org.springframework.amqp.rabbit.core.AsyncRabbitTemplate
onMessage(Message, Channel) - Method in interface org.springframework.amqp.rabbit.core.ChannelAwareMessageListener: Callback for processing a received Rabbit message.
onMessage(Message) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
onMessage(Message) - Method in class org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener: Rabbit MessageListener entry point.
onMessage(Message, Channel) - Method in class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter: Spring ChannelAwareMessageListener entry point.
onMessage(Message, Channel) - Method in class org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter
onMessage(Message) - Method in class org.springframework.amqp.remoting.service.AmqpInvokerServiceExporter
org.springframework.amqp - package org.springframework.amqp: Base package for Spring AMQP.
org.springframework.amqp.core - package org.springframework.amqp.core: Provides core classes for the spring AMQP abstraction.
org.springframework.amqp.event - package org.springframework.amqp.event: Classes related to application events
org.springframework.amqp.rabbit.annotation - package org.springframework.amqp.rabbit.annotation: Annotations and supporting classes for declarative Rabbit listener endpoint
org.springframework.amqp.rabbit.config - package org.springframework.amqp.rabbit.config: Provides classes supporting the Rabbit XML namespace.
org.springframework.amqp.rabbit.connection - package org.springframework.amqp.rabbit.connection: Provides classes related to connections.
org.springframework.amqp.rabbit.core - package org.springframework.amqp.rabbit.core: Provides core classes for Spring Rabbit.
org.springframework.amqp.rabbit.core.support - package org.springframework.amqp.rabbit.core.support: Provides core support classes for Spring Rabbit.
org.springframework.amqp.rabbit.listener - package org.springframework.amqp.rabbit.listener: Provides classes for message listener containers.
org.springframework.amqp.rabbit.listener.adapter - package org.springframework.amqp.rabbit.listener.adapter: Provides classes for adapting listeners.
org.springframework.amqp.rabbit.listener.exception - package org.springframework.amqp.rabbit.listener.exception: Provides classes for listener exceptions.
org.springframework.amqp.rabbit.log4j - package org.springframework.amqp.rabbit.log4j: Provides classes supporting Log4J appenders.
org.springframework.amqp.rabbit.log4j2 - package org.springframework.amqp.rabbit.log4j2: Provides classes supporting Log4j 2 appenders.
org.springframework.amqp.rabbit.logback - package org.springframework.amqp.rabbit.logback: Provides classes supporting Logback appenders.
org.springframework.amqp.rabbit.retry - package org.springframework.amqp.rabbit.retry: Provides classes supporting retries.
org.springframework.amqp.rabbit.support - package org.springframework.amqp.rabbit.support: Provides support classes for Spring Rabbit.
org.springframework.amqp.rabbit.test - package org.springframework.amqp.rabbit.test: Classes for testing Spring AMQP applications.
org.springframework.amqp.rabbit.test.mockito - package org.springframework.amqp.rabbit.test.mockito: Mockito extensions for testing Spring AMQP applications.
org.springframework.amqp.rabbit.transaction - package org.springframework.amqp.rabbit.transaction: Provides classes supporting transactions in Spring Rabbit.
org.springframework.amqp.remoting.client - package org.springframework.amqp.remoting.client: Provides classes for the client side of Spring Remoting over AMQP.
org.springframework.amqp.remoting.service - package org.springframework.amqp.remoting.service: Provides classes for the service side of Spring Remoting over AMQP.
org.springframework.amqp.support - package org.springframework.amqp.support: Package for Spring AMQP support classes.
org.springframework.amqp.support.converter - package org.springframework.amqp.support.converter: Provides classes for supporting message conversion.
org.springframework.amqp.support.postprocessor - package org.springframework.amqp.support.postprocessor: Package for Spring AMQP message post processors.
org.springframework.amqp.utils - package org.springframework.amqp.utils: Provides utility classes to support Spring AMQP.
org.springframework.amqp.utils.test - package org.springframework.amqp.utils.test
ORIGINAL_DEFAULT_LISTENER_METHOD - Static variable in class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter: Out-of-the-box value for the default listener method: "handleMessage".

P

parseBinding(String, Element, ParserContext) - Method in class org.springframework.amqp.rabbit.config.AbstractExchangeParser
parseBinding(String, Element, ParserContext) - Method in class org.springframework.amqp.rabbit.config.DirectExchangeParser
parseBinding(String, Element, ParserContext) - Method in class org.springframework.amqp.rabbit.config.FanoutExchangeParser
parseBinding(String, Element, ParserContext) - Method in class org.springframework.amqp.rabbit.config.HeadersExchangeParser
parseBinding(String, Element, ParserContext) - Method in class org.springframework.amqp.rabbit.config.TopicExchangeParser
parseBindings(Element, ParserContext, BeanDefinitionBuilder, String) - Method in class org.springframework.amqp.rabbit.config.AbstractExchangeParser
parseContainer(Element, ParserContext) - Static method in class org.springframework.amqp.rabbit.config.RabbitNamespaceUtils
parseDeclarationControls(Element, BeanDefinitionBuilder) - Static method in class org.springframework.amqp.rabbit.config.NamespaceUtils: Parses 'auto-declare' and 'declared-by' attributes.
parseDestination(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.amqp.rabbit.config.AbstractExchangeParser
parseInnerBeanDefinition(Element, ParserContext) - Static method in class org.springframework.amqp.rabbit.config.NamespaceUtils
PendingConfirm - Class in org.springframework.amqp.rabbit.support: Instances of this object track pending publisher confirms.
PendingConfirm(CorrelationData, long) - Constructor for class org.springframework.amqp.rabbit.support.PendingConfirm
postProcessAfterInitialization(Object, String) - Method in class org.springframework.amqp.rabbit.annotation.RabbitListenerAnnotationBeanPostProcessor
postProcessBeforeInitialization(Object, String) - Method in class org.springframework.amqp.rabbit.annotation.RabbitListenerAnnotationBeanPostProcessor
postProcessChannel(Channel, Message) - Method in class org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener: Post-process the given message before sending the response.
postProcessMessage(Message) - Method in interface org.springframework.amqp.core.MessagePostProcessor
postProcessMessage(Message) - Method in class org.springframework.amqp.support.postprocessor.AbstractCompressingPostProcessor
postProcessMessage(Message) - Method in class org.springframework.amqp.support.postprocessor.AbstractDecompressingPostProcessor
postProcessMessage(Message) - Method in class org.springframework.amqp.support.postprocessor.DelegatingDecompressingPostProcessor
postProcessMessageBeforeSend(Message, AmqpAppender.Event) - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender: Subclasses may modify the final message before sending.
postProcessMessageBeforeSend(Message, AmqpAppender.Event) - Method in class org.springframework.amqp.rabbit.log4j2.AmqpAppender: Subclasses may modify the final message before sending.
postProcessMessageBeforeSend(Message, AmqpAppender.Event) - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender: Subclasses may modify the final message before sending.
postProcessResponse(Message, Message) - Method in class org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener: Post-process the given response message before it will be sent.
PREFIX - Static variable in class org.springframework.amqp.support.AmqpHeaders: Prefix used for AMQP related headers in order to distinguish from user-defined headers and other internal headers (e.g.
PRIORITY - Static variable in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
processAmqpListener(RabbitListener, Method, Object, String) - Method in class org.springframework.amqp.rabbit.annotation.RabbitListenerAnnotationBeanPostProcessor
processListener(MethodRabbitListenerEndpoint, RabbitListener, Object, Object, String) - Method in class org.springframework.amqp.rabbit.annotation.RabbitListenerAnnotationBeanPostProcessor
processListener(MethodRabbitListenerEndpoint, RabbitListener, Object, Object, String) - Method in class org.springframework.amqp.rabbit.test.RabbitListenerTestHarness
PUBLISH_CONFIRM - Static variable in class org.springframework.amqp.support.AmqpHeaders
PUBLISH_CONFIRM_NACK_CAUSE - Static variable in class org.springframework.amqp.support.AmqpHeaders
PublisherCallbackChannel - Interface in org.springframework.amqp.rabbit.support: Instances of this interface support a single listener being registered for publisher confirms with multiple channels, by adding context to the callbacks.
PublisherCallbackChannel.Listener - Interface in org.springframework.amqp.rabbit.support: Listeners implementing this interface can participate in publisher confirms received from multiple channels, by invoking addListener on each channel.
PublisherCallbackChannelConnectionFactory - Interface in org.springframework.amqp.rabbit.connection: Connection factories implementing this interface return a connection that provides PublisherCallbackChannel channel instances when confirms or returns are enabled.
PublisherCallbackChannelImpl - Class in org.springframework.amqp.rabbit.support: Channel wrapper to allow a single listener able to handle confirms from multiple channels.
PublisherCallbackChannelImpl(Channel) - Constructor for class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
purgeQueue(String, boolean) - Method in interface org.springframework.amqp.core.AmqpAdmin: Purges the contents of the given queue.
purgeQueue(Queue) - Method in interface org.springframework.amqp.core.AmqpManagementOperations: Purge a queue in the default vhost ('/').
purgeQueue(String, Queue) - Method in interface org.springframework.amqp.core.AmqpManagementOperations: Purge a queue in the provided vhost.
purgeQueue(String, boolean) - Method in class org.springframework.amqp.rabbit.core.RabbitAdmin
purgeQueue(Queue) - Method in class org.springframework.amqp.rabbit.core.RabbitManagementTemplate
purgeQueue(String, Queue) - Method in class org.springframework.amqp.rabbit.core.RabbitManagementTemplate

Q

Queue - Class in org.springframework.amqp.core: Simple container collecting information to describe a queue.
Queue(String) - Constructor for class org.springframework.amqp.core.Queue: The queue is durable, non-exclusive and non auto-delete.
Queue(String, boolean) - Constructor for class org.springframework.amqp.core.Queue: Construct a new queue, given a name and durability flag.
Queue(String, boolean, boolean, boolean) - Constructor for class org.springframework.amqp.core.Queue: Construct a new queue, given a name, durability, exclusive and auto-delete flags.
Queue(String, boolean, boolean, boolean, Map<String, Object>) - Constructor for class org.springframework.amqp.core.Queue: Construct a new queue, given a name, durability flag, and auto-delete flag, and arguments.
Queue - Annotation Type in org.springframework.amqp.rabbit.annotation: A queue definition used within the bindings attribute of a QueueBinding.
QUEUE_CONSUMER_COUNT - Static variable in class org.springframework.amqp.rabbit.core.RabbitAdmin: Property key for the consumer count in the Properties returned by RabbitAdmin.getQueueProperties(String).
QUEUE_MESSAGE_COUNT - Static variable in class org.springframework.amqp.rabbit.core.RabbitAdmin: Property key for the message count in the Properties returned by RabbitAdmin.getQueueProperties(String).
QUEUE_NAME - Static variable in class org.springframework.amqp.rabbit.core.RabbitAdmin: Property key for the queue name in the Properties returned by RabbitAdmin.getQueueProperties(String).
queueBind(String, String, String) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
queueBind(String, String, String, Map<String, Object>) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
QueueBinding - Annotation Type in org.springframework.amqp.rabbit.annotation: Defines a queue, the exchange it is to be bound to, and an optional binding key; used with @RabbitListener.
queueBindNoWait(String, String, String, Map<String, Object>) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
queueDeclare() - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
queueDeclare(String, boolean, boolean, boolean, Map<String, Object>) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
queueDeclareNoWait(String, boolean, boolean, boolean, Map<String, Object>) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
queueDeclarePassive(String) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
queueDelete(String) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
queueDelete(String, boolean, boolean) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
queueDeleteNoWait(String, boolean, boolean) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
QueueParser - Class in org.springframework.amqp.rabbit.config
QueueParser() - Constructor for class org.springframework.amqp.rabbit.config.QueueParser
queuePurge(String) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
QueuesNotAvailableException - Exception in org.springframework.amqp.rabbit.listener: This exception indicates that a consumer could not be started because none of its queues are available for listening.
QueuesNotAvailableException(String, Throwable) - Constructor for exception org.springframework.amqp.rabbit.listener.QueuesNotAvailableException
queueUnbind(String, String, String) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
queueUnbind(String, String, String, Map<String, Object>) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl

R

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
RabbitAdminEvent - Class in org.springframework.amqp.rabbit.core: Base class for admin events.
RabbitAdminEvent(RabbitAdmin) - Constructor for class org.springframework.amqp.rabbit.core.RabbitAdminEvent
RabbitBootstrapConfiguration - Class in org.springframework.amqp.rabbit.annotation: @Configuration 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(String) - Constructor for class org.springframework.amqp.rabbit.core.AsyncRabbitTemplate.RabbitConverterFuture
RabbitExceptionTranslator - Class in org.springframework.amqp.rabbit.support: Translates Rabbit Exceptions to the AmqpException class hierarchy.
RabbitExceptionTranslator() - Constructor for class org.springframework.amqp.rabbit.support.RabbitExceptionTranslator
RabbitFuture(String) - Constructor for class org.springframework.amqp.rabbit.core.AsyncRabbitTemplate.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 Type 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 Type 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
rabbitListenerAnnotationProcessor() - Method in class org.springframework.amqp.rabbit.annotation.RabbitBootstrapConfiguration
rabbitListenerAnnotationProcessor() - Method in class org.springframework.amqp.rabbit.test.RabbitListenerTestBootstrap
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 MessageListenerContainer based on a RabbitListenerEndpoint definition.
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
RabbitListeners - Annotation Type in org.springframework.amqp.rabbit.annotation: Container annotation that aggregates several RabbitListener annotations.
RabbitListenerTest - Annotation Type 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
RabbitManagementTemplate - Class in org.springframework.amqp.rabbit.core: A convenience wrapper for the RabbitMQ Client providing convenient access to the REST methods using the familiar Spring AMQP domain objects for Queue, Exchange and Binding.
RabbitManagementTemplate() - Constructor for class org.springframework.amqp.rabbit.core.RabbitManagementTemplate: Construct a template using uri "localhost:15672/api/" and user guest/guest.
RabbitManagementTemplate(Client) - Constructor for class org.springframework.amqp.rabbit.core.RabbitManagementTemplate: Construct a template using the supplied client.
RabbitManagementTemplate(String, String, String) - Constructor for class org.springframework.amqp.rabbit.core.RabbitManagementTemplate: Construct a template using the supplied uri.
RabbitMessageFuture(String) - Constructor for class org.springframework.amqp.rabbit.core.AsyncRabbitTemplate.RabbitMessageFuture
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.
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.
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
RabbitNamespaceUtils() - Constructor for class org.springframework.amqp.rabbit.config.RabbitNamespaceUtils
RabbitOperations - Interface in org.springframework.amqp.rabbit.core: Rabbit specific methods for Amqp functionality.
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
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
RabbitTemplate.ReturnCallback - Interface in org.springframework.amqp.rabbit.core
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
receive() - Method in interface org.springframework.amqp.core.AmqpTemplate: Receive a message if there is one from a default queue.
receive(String) - Method in interface org.springframework.amqp.core.AmqpTemplate: Receive a message if there is one from a specific queue.
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(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() - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
receive(String) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
receive(long) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
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(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(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(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() - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
receiveAndConvert(String) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
receiveAndConvert(long) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
receiveAndConvert(String, long) - 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(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(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(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(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(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(ReceiveAndReplyCallback<R, S>) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
receiveAndReply(String, ReceiveAndReplyCallback<R, S>) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
receiveAndReply(ReceiveAndReplyCallback<R, S>, String, String) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
receiveAndReply(String, ReceiveAndReplyCallback<R, S>, String, String) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
receiveAndReply(ReceiveAndReplyCallback<R, S>, ReplyToAddressCallback<S>) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
receiveAndReply(String, 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_EXCHANGE - Static variable in class org.springframework.amqp.support.AmqpHeaders
RECEIVED_ROUTING_KEY - Static variable in class org.springframework.amqp.support.AmqpHeaders
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
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.
recoverer(MessageRecoverer) - Method in class org.springframework.amqp.rabbit.config.RetryInterceptorBuilder.StatefulRetryInterceptorBuilder
REDELIVERED - Static variable in class org.springframework.amqp.support.AmqpHeaders
registerAllEndpoints() - Method in class org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistrar
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, RabbitListenerContainerFactory<?>) - Method in class org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistrar: Register a new RabbitListenerEndpoint alongside the RabbitListenerContainerFactory to use to create the underlying container.
registerEndpoint(RabbitListenerEndpoint) - Method in class org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistrar: Register a new RabbitListenerEndpoint using the default RabbitListenerContainerFactory to create the underlying container.
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
release(T) - Method in class org.springframework.amqp.rabbit.listener.ActiveObjectCounter
releaseBatches() - Method in interface org.springframework.amqp.rabbit.core.support.BatchingStrategy: Release batch(es), perhaps due to a timeout.
releaseBatches() - Method in class org.springframework.amqp.rabbit.core.support.SimpleBatchingStrategy
releaseResources(RabbitResourceHolder) - Static method in class org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils
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
removeConfirmListener(ConfirmListener) - Method in class org.springframework.amqp.rabbit.support.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
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(ConnectionListener) - Method in class org.springframework.amqp.rabbit.connection.CompositeConnectionListener
removeDelegate(String) - Method in class org.springframework.amqp.support.converter.ContentTypeDelegatingMessageConverter
removeDelgate(String) - Method in class org.springframework.amqp.support.converter.ContentTypeDelegatingMessageConverter: Deprecated.
in favor of ContentTypeDelegatingMessageConverter.removeDelegate(String)
removeFlowListener(FlowListener) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
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.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.SimpleMessageListenerContainer: Remove queue(s) from this container's list of queues.
removeReturnListener(ReturnListener) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
removeShutdownListener(ShutdownListener) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
removeTargetConnectionFactory(Object) - Method in class org.springframework.amqp.rabbit.connection.AbstractRoutingConnectionFactory: Removes the ConnectionFactory associated with the given lookup key and returns it.
REPLY_TO - Static variable in class org.springframework.amqp.support.AmqpHeaders
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
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
RepublishMessageRecoverer(AmqpTemplate, String) - Constructor for class org.springframework.amqp.rabbit.retry.RepublishMessageRecoverer
RepublishMessageRecoverer(AmqpTemplate, String, String) - Constructor for class org.springframework.amqp.rabbit.retry.RepublishMessageRecoverer
requiresLayout() - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender
reset(List<ChannelProxy>, List<ChannelProxy>) - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory
reset() - Method in class org.springframework.amqp.rabbit.listener.ActiveObjectCounter
resetConnection() - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory: Close the connection(s).
retrieveHeader(MessageProperties, String) - Method in class org.springframework.amqp.support.converter.AbstractJavaTypeMapper
RetryInterceptorBuilder<T extends org.aopalliance.intercept.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.StatefulRetryInterceptorBuilder - Class in org.springframework.amqp.rabbit.config
RetryInterceptorBuilder.StatelessRetryInterceptorBuilder - Class in org.springframework.amqp.rabbit.config
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.
retryOperations(RetryOperations) - Method in class org.springframework.amqp.rabbit.config.RetryInterceptorBuilder.StatefulRetryInterceptorBuilder
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.
retryPolicy(RetryPolicy) - Method in class org.springframework.amqp.rabbit.config.RetryInterceptorBuilder.StatefulRetryInterceptorBuilder
RETURN_CORRELATION_KEY - Static variable in interface org.springframework.amqp.rabbit.support.PublisherCallbackChannel
RETURN_EXCHANGE - Static variable in class org.springframework.amqp.support.AmqpHeaders
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
returnedMessage(Message, int, String, String, String) - Method in class org.springframework.amqp.rabbit.core.AsyncRabbitTemplate
returnedMessage(Message, int, String, String, String) - Method in interface org.springframework.amqp.rabbit.core.RabbitTemplate.ReturnCallback: Returned message callback.
revoke(Channel) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
revoke(Channel) - Method in interface org.springframework.amqp.rabbit.support.PublisherCallbackChannel.Listener: When called, this listener should remove all references to the channel - it will no longer be invoked by the channel.
rollbackAll() - Method in class org.springframework.amqp.rabbit.connection.RabbitResourceHolder
rollbackIfNecessary(Channel) - Static method in class org.springframework.amqp.rabbit.connection.RabbitUtils
rollbackOnExceptionIfNecessary(Throwable) - 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.support.PublisherCallbackChannelImpl
run() - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender.EventSender
run() - Method in class org.springframework.amqp.rabbit.log4j2.AmqpAppender.EventSender
run() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender.EventSender

S

send(Message) - Method in interface org.springframework.amqp.core.AmqpTemplate: Send a message to a default exchange with a default routing key.
send(String, Message) - Method in interface org.springframework.amqp.core.AmqpTemplate: Send a message to a default exchange with a specific routing key.
send(String, String, Message) - Method in interface org.springframework.amqp.core.AmqpTemplate: Send a message to a specific exchange with a specific routing key.
send(String, String, Message, CorrelationData) - Method in class org.springframework.amqp.rabbit.core.BatchingRabbitTemplate
send(String, String, Message<?>) - Method in interface org.springframework.amqp.rabbit.core.RabbitMessageOperations: Send a message to a specific exchange with a specific routing key.
send(String, String, Message<?>) - Method in class org.springframework.amqp.rabbit.core.RabbitMessagingTemplate
send(Message) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
send(String, Message) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
send(String, String, Message) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
send(String, String, Message, CorrelationData) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
sendAndReceive(Message) - Method in interface org.springframework.amqp.core.AmqpTemplate: Basic RPC pattern.
sendAndReceive(String, Message) - Method in interface org.springframework.amqp.core.AmqpTemplate: Basic RPC pattern.
sendAndReceive(String, String, Message) - Method in interface org.springframework.amqp.core.AmqpTemplate: Basic RPC pattern.
sendAndReceive(Message) - Method in class org.springframework.amqp.rabbit.core.AsyncRabbitTemplate: Send a message to the default exchange with the default routing key.
sendAndReceive(String, Message) - Method in class org.springframework.amqp.rabbit.core.AsyncRabbitTemplate: Send a message to the default exchange with the supplied routing key.
sendAndReceive(String, String, Message) - Method in class org.springframework.amqp.rabbit.core.AsyncRabbitTemplate: Send a message to the supplied exchange and routing key.
sendAndReceive(String, String, Message<?>) - Method in interface org.springframework.amqp.rabbit.core.RabbitMessageOperations: Send a request message to a specific exchange with a specific routing key and wait for the reply
sendAndReceive(String, String, Message<?>) - Method in class org.springframework.amqp.rabbit.core.RabbitMessagingTemplate
sendAndReceive(Message) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
sendAndReceive(Message, CorrelationData) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
sendAndReceive(String, Message) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
sendAndReceive(String, Message, CorrelationData) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
sendAndReceive(String, String, Message) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
sendAndReceive(String, String, Message, CorrelationData) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
sendResponse(Channel, Address, Message) - Method in class org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener: Send the given response message to the given destination.
SerializationUtils - Class in org.springframework.amqp.utils: Static utility to help with serialization.
SerializationUtils() - Constructor for class org.springframework.amqp.utils.SerializationUtils
serialize(Object) - Static method in class org.springframework.amqp.utils.SerializationUtils: Serialize the object provided.
SerializerMessageConverter - Class in org.springframework.amqp.support.converter: Implementation of MessageConverter that can work with Strings or native objects of any kind via the Serializer and Deserializer abstractions in Spring.
SerializerMessageConverter() - Constructor for class org.springframework.amqp.support.converter.SerializerMessageConverter
setAbbreviation(int) - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
setAcknowledgeMode(AcknowledgeMode) - Method in class org.springframework.amqp.rabbit.config.AbstractRabbitListenerContainerFactory
setAcknowledgeMode(AcknowledgeMode) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer: Flag controlling the behaviour of the container with respect to message acknowledgement.
setAddresses(String) - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory: Set addresses for clustering.
setAdmin(RabbitAdmin) - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint: Set the RabbitAdmin instance to use.
setAdminsThatShouldDeclare(Object...) - Method in class org.springframework.amqp.core.AbstractDeclarable: The AmqpAdmins that should declare this object; default is all admins.
setAdminsThatShouldDeclare(AmqpAdmin...) - Method in class org.springframework.amqp.rabbit.config.BindingFactoryBean
setAdviceChain(Advice...) - Method in class org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory
setAdviceChain(Advice[]) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer: Public setter for the Advice to apply to listener executions.
setAfterReceivePostProcessor(MessagePostProcessor...) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate: Deprecated.
use RabbitTemplate.setAfterReceivePostProcessors(MessagePostProcessor...)
setAfterReceivePostProcessors(MessagePostProcessor...) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate: Set a MessagePostProcessor that will be invoked immediately after a Channel#basicGet() and before any message conversion is performed.
setAfterReceivePostProcessors(MessagePostProcessor...) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer: Set MessagePostProcessors that will be applied after message reception, before invoking the MessageListener.
setAmqpMessageConverter(MessageConverter) - Method in class org.springframework.amqp.rabbit.core.RabbitMessagingTemplate: Set the MessageConverter to use to convert a Message from the messaging to and from a Message.
setAmqpTemplate(AmqpTemplate) - Method in class org.springframework.amqp.remoting.client.AmqpClientInterceptor: The AMQP template to be used for sending messages and receiving results.
setAmqpTemplate(AmqpTemplate) - Method in class org.springframework.amqp.remoting.service.AmqpInvokerServiceExporter: The AMQP template to use for sending the return value.
setAppId(String) - Method in class org.springframework.amqp.core.MessageBuilderSupport
setAppId(String) - Method in class org.springframework.amqp.core.MessageProperties
setAppIdIfAbsent(String) - Method in class org.springframework.amqp.core.MessageBuilderSupport
setApplicationContext(ApplicationContext) - Method in class org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory
setApplicationContext(ApplicationContext) - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory
setApplicationContext(ApplicationContext) - Method in class org.springframework.amqp.rabbit.core.RabbitAdmin
setApplicationContext(ApplicationContext) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
setApplicationContext(ApplicationContext) - Method in class org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistry
setApplicationEventPublisher(ApplicationEventPublisher) - Method in class org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory
setApplicationEventPublisher(ApplicationEventPublisher) - Method in class org.springframework.amqp.rabbit.core.RabbitAdmin
setApplicationEventPublisher(ApplicationEventPublisher) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer
setApplicationId(String) - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender
setApplicationId(String) - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
setArguments(Map<String, Object>) - Method in class org.springframework.amqp.rabbit.config.BindingFactoryBean
setAutoDeclare(boolean) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer
setAutoDelete(boolean) - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender
setAutoDelete(boolean) - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
setAutoStartup(Boolean) - Method in class org.springframework.amqp.rabbit.config.AbstractRabbitListenerContainerFactory
setAutoStartup(boolean) - Method in class org.springframework.amqp.rabbit.core.AsyncRabbitTemplate
setAutoStartup(boolean) - Method in class org.springframework.amqp.rabbit.core.RabbitAdmin
setAutoStartup(boolean) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer: Set whether to automatically start the container after initialization.
setBackOffExecution(BackOffExecution) - Method in class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer: Set the BackOffExecution to use for the recovery in the SimpleMessageListenerContainer.
setBean(Object) - Method in class org.springframework.amqp.rabbit.listener.MethodRabbitListenerEndpoint: Set the object instance that should manage this endpoint.
setBeanClassLoader(ClassLoader) - Method in class org.springframework.amqp.support.converter.SimpleMessageConverter
setBeanFactory(BeanFactory) - Method in class org.springframework.amqp.rabbit.annotation.RabbitListenerAnnotationBeanPostProcessor: Making a BeanFactory available is optional; if not set, RabbitListenerConfigurer beans won't get autodetected and an endpoint registry has to be explicitly configured.
setBeanFactory(BeanFactory) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
setBeanFactory(BeanFactory) - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint
setBeanFactory(BeanFactory) - Method in class org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistrar: A BeanFactory only needs to be available in conjunction with RabbitListenerEndpointRegistrar.setContainerFactoryBeanName(java.lang.String).
setBeanName(String) - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
setBeanName(String) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
setBeforePublishPostProcessors(MessagePostProcessor...) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate: Set MessagePostProcessors that will be invoked immediately before invoking Channel#basicPublish(), after all other processing, except creating the AMQP.BasicProperties from MessageProperties.
setCacheMode(CachingConnectionFactory.CacheMode) - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory
setCause(String) - Method in class org.springframework.amqp.rabbit.support.PendingConfirm: When the confirmation is nacked, set the cause when available.
setChannelCacheSize(int) - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory: The number of channels to maintain in the cache.
setChannelCheckoutTimeout(long) - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory: Sets the channel checkout timeout.
setChannelListeners(List<? extends ChannelListener>) - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
setChannelTransacted(Boolean) - Method in class org.springframework.amqp.rabbit.config.AbstractRabbitListenerContainerFactory
setChannelTransacted(boolean) - Method in class org.springframework.amqp.rabbit.connection.RabbitAccessor: Flag to indicate that channels created by this component will be transactional.
setCharset(Charset) - Method in class org.springframework.amqp.rabbit.core.AsyncRabbitTemplate: Set the charset to be used when converting byte[] to/from String for correlation Ids.
setCharset(String) - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender
setCharset(String) - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
setClassMapper(ClassMapper) - Method in class org.springframework.amqp.support.converter.AbstractJsonMessageConverter
setClientProperties(Map<String, Object>) - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
setCloseExceptionLogger(ConditionalExceptionLogger) - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory: Set the strategy for logging close exceptions; by default, if a channel is closed due to a failed passive queue declaration, it is logged at debug level.
setCloseTimeout(int) - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory: How long to wait (milliseconds) for a response to a connection close operation from the broker; default 30000 (30 seconds).
setClusterId(String) - Method in class org.springframework.amqp.core.MessageBuilderSupport
setClusterId(String) - Method in class org.springframework.amqp.core.MessageProperties
setClusterIdIfAbsent(String) - Method in class org.springframework.amqp.core.MessageBuilderSupport
setCodebaseUrl(String) - Method in class org.springframework.amqp.support.converter.SimpleMessageConverter: Set the codebase URL to download classes from if not found locally.
setConcurrentConsumers(Integer) - Method in class org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory
setConcurrentConsumers(int) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer: Specify the number of concurrent consumers to create.
setConfirmCallback(RabbitTemplate.ConfirmCallback) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
setConnectionCacheSize(int) - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory
setConnectionFactory(ConnectionFactory) - Method in class org.springframework.amqp.rabbit.config.AbstractRabbitListenerContainerFactory
setConnectionFactory(ConnectionFactory) - Method in class org.springframework.amqp.rabbit.connection.RabbitAccessor: Set the ConnectionFactory to use for obtaining RabbitMQ Connections.
setConnectionFactory(ConnectionFactory) - Method in class org.springframework.amqp.rabbit.core.RabbitGatewaySupport: Set the Rabbit connection factory to be used by the gateway.
setConnectionFactory(ConnectionFactory) - Method in class org.springframework.amqp.rabbit.transaction.RabbitTransactionManager
setConnectionListeners(List<? extends ConnectionListener>) - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
setConnectionListeners(List<? extends ConnectionListener>) - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory
setConnectionThreadFactory(ThreadFactory) - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory: Set the ThreadFactory on the underlying rabbit connection factory.
setConnectionTimeout(int) - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
setConnectionTimeout(int) - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
setConsecutiveActiveTrigger(Integer) - Method in class org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory
setConsecutiveActiveTrigger(int) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer: If SimpleMessageListenerContainer.maxConcurrentConsumers is greater then SimpleMessageListenerContainer.concurrentConsumers, and SimpleMessageListenerContainer.maxConcurrentConsumers has not been reached, specifies the number of consecutive cycles when a single consumer was active, in order to consider starting a new consumer.
setConsecutiveIdleTrigger(Integer) - Method in class org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory
setConsecutiveIdleTrigger(int) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer: If SimpleMessageListenerContainer.maxConcurrentConsumers is greater then SimpleMessageListenerContainer.concurrentConsumers, and the number of consumers exceeds SimpleMessageListenerContainer.concurrentConsumers, specifies the number of consecutive receive attempts that return no data; after which we consider stopping a consumer.
setConsumerArguments(Map<String, Object>) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer
setConsumerQueue(String) - Method in class org.springframework.amqp.core.MessageProperties
setConsumerTag(String) - Method in class org.springframework.amqp.core.MessageProperties
setConsumerTagStrategy(ConsumerTagStrategy) - Method in class org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory
setConsumerTagStrategy(ConsumerTagStrategy) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer: Set the implementation of ConsumerTagStrategy to generate consumer tags.
setContainerFactory(RabbitListenerContainerFactory<?>) - Method in class org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistrar: Set the RabbitListenerContainerFactory to use in case a RabbitListenerEndpoint is registered with a null container factory.
setContainerFactoryBeanName(String) - Method in class org.springframework.amqp.rabbit.annotation.RabbitListenerAnnotationBeanPostProcessor: Set the name of the RabbitListenerContainerFactory to use by default.
setContainerFactoryBeanName(String) - Method in class org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistrar: Set the bean name of the RabbitListenerContainerFactory to use in case a RabbitListenerEndpoint is registered with a null container factory.
setContentEncoding(String) - Method in class org.springframework.amqp.core.MessageBuilderSupport
setContentEncoding(String) - Method in class org.springframework.amqp.core.MessageProperties
setContentEncoding(String) - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender
setContentEncoding(String) - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
setContentEncodingIfAbsent(String) - Method in class org.springframework.amqp.core.MessageBuilderSupport
setContentLength(long) - Method in class org.springframework.amqp.core.MessageBuilderSupport
setContentLength(long) - Method in class org.springframework.amqp.core.MessageProperties
setContentLengthIfAbsent(long) - Method in class org.springframework.amqp.core.MessageBuilderSupport
setContentType(String) - Method in class org.springframework.amqp.core.MessageBuilderSupport
setContentType(String) - Method in class org.springframework.amqp.core.MessageProperties
setContentType(String) - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender
setContentType(String) - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
setContentType(String) - Method in class org.springframework.amqp.support.converter.MarshallingMessageConverter: Set the contentType to be used by this message converter.
setContentTypeIfAbsentOrDefault(String) - Method in class org.springframework.amqp.core.MessageBuilderSupport
setCorrelationId(byte[]) - Method in class org.springframework.amqp.core.MessageBuilderSupport
setCorrelationId(byte[]) - Method in class org.springframework.amqp.core.MessageProperties
setCorrelationIdAsString(DefaultMessagePropertiesConverter.CorrelationIdPolicy) - Method in class org.springframework.amqp.rabbit.support.DefaultMessagePropertiesConverter: For inbound, determine whether correlationId, correlationIdString or both are populated.
setCorrelationIdIfAbsent(byte[]) - Method in class org.springframework.amqp.core.MessageBuilderSupport
setCorrelationIdString(String) - Method in class org.springframework.amqp.core.MessageProperties
setCorrelationKey(String) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate: If set to 'correlationId' (default) the correlationId property will be used; otherwise the supplied key will be used.
setCreateMessageIds(boolean) - Method in class org.springframework.amqp.support.converter.AbstractMessageConverter: Flag to indicate that new messages should have unique identifiers added to their properties before sending.
setDeBatchingEnabled(boolean) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer: Determine whether or not the container should de-batch batched messages (true) or call the listener with the batch (false).
setDeclarationRetries(int) - Method in class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer: Set the number of retries after passive queue declaration fails.
setDeclarationRetries(int) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer: Set the number of retries after passive queue declaration fails.
setDeclareExchange(boolean) - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender
setDeclareExchange(boolean) - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
setDecompressors(Map<String, MessagePostProcessor>) - Method in class org.springframework.amqp.support.postprocessor.DelegatingDecompressingPostProcessor: Replace all the decompressors.
setDefaultCharset(String) - Method in class org.springframework.amqp.support.converter.AbstractJsonMessageConverter: Specify the default charset to use when converting to or from text-based Message body content.
setDefaultCharset(String) - Method in class org.springframework.amqp.support.converter.SerializerMessageConverter: Specify the default charset to use when converting to or from text-based Message body content.
setDefaultCharset(String) - Method in class org.springframework.amqp.support.converter.SimpleMessageConverter: Specify the default charset to use when converting to or from text-based Message body content.
setDefaultConsumer(Consumer) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
setDefaultHashtableClass(Class<?>) - Method in class org.springframework.amqp.support.converter.DefaultClassMapper
setDefaultListenerMethod(String) - Method in class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter: Specify the name of the default listener method to delegate to, for the case where no specific listener method has been determined.
setDefaultRequeueRejected(Boolean) - Method in class org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory
setDefaultRequeueRejected(boolean) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer: Determines the default behavior when a message is rejected, for example because the listener threw an exception.
setDefaultTargetConnectionFactory(ConnectionFactory) - Method in class org.springframework.amqp.rabbit.connection.AbstractRoutingConnectionFactory: Specify the default target ConnectionFactory, if any.
setDefaultType(Class<?>) - Method in class org.springframework.amqp.support.converter.DefaultClassMapper: The type returned by DefaultClassMapper.toClass(MessageProperties) if no type information is found in the message properties.
setDelay(Integer) - Method in class org.springframework.amqp.core.MessageProperties: Set the x-delay header.
setDelayed(boolean) - Method in class org.springframework.amqp.core.AbstractExchange
setDelegate(Object) - Method in class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter: Set a target object to delegate message listening to.
setDelegates(List<? extends ChannelListener>) - Method in class org.springframework.amqp.rabbit.connection.CompositeChannelListener
setDelegates(List<? extends ConnectionListener>) - Method in class org.springframework.amqp.rabbit.connection.CompositeConnectionListener
setDelegates(Map<String, MessageConverter>) - Method in class org.springframework.amqp.support.converter.ContentTypeDelegatingMessageConverter
setDeliveryMode(MessageDeliveryMode) - Method in class org.springframework.amqp.core.MessageBuilderSupport
setDeliveryMode(MessageDeliveryMode) - Method in class org.springframework.amqp.core.MessageProperties
setDeliveryMode(String) - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender
setDeliveryMode(String) - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
setDeliveryModeIfAbsentOrDefault(MessageDeliveryMode) - Method in class org.springframework.amqp.core.MessageBuilderSupport
setDeliveryTag(Long) - Method in class org.springframework.amqp.core.MessageBuilderSupport
setDeliveryTag(long) - Method in class org.springframework.amqp.core.MessageProperties
setDeliveryTagIfAbsent(Long) - Method in class org.springframework.amqp.core.MessageBuilderSupport
setDeserializer(Deserializer<Object>) - Method in class org.springframework.amqp.support.converter.SerializerMessageConverter: The deserializer to use for converting from message body to Java object.
setDestinationExchange(Exchange) - Method in class org.springframework.amqp.rabbit.config.BindingFactoryBean
setDestinationQueue(Queue) - Method in class org.springframework.amqp.rabbit.config.BindingFactoryBean
setDurable(boolean) - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender
setDurable(boolean) - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
setEnableConfirms(boolean) - Method in class org.springframework.amqp.rabbit.core.AsyncRabbitTemplate: Set to true to enable publisher confirms.
setEncoding(String) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate: The encoding to use when inter-converting between byte arrays and Strings in message properties.
setEncoding(String) - Method in class org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener: The encoding to use when inter-converting between byte arrays and Strings in message properties.
setEndpointRegistry(RabbitListenerEndpointRegistry) - Method in class org.springframework.amqp.rabbit.annotation.RabbitListenerAnnotationBeanPostProcessor: Set the RabbitListenerEndpointRegistry that will hold the created endpoint and manage the lifecycle of the related listener container.
setEndpointRegistry(RabbitListenerEndpointRegistry) - Method in class org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistrar: Set the RabbitListenerEndpointRegistry instance to use.
setErrorHandler(ErrorHandler) - Method in class org.springframework.amqp.rabbit.config.AbstractRabbitListenerContainerFactory
setErrorHandler(ErrorHandler) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer: Set an ErrorHandler to be invoked in case of any uncaught exceptions thrown while processing a Message.
setErrorRoutingKeyPrefix(String) - Method in class org.springframework.amqp.rabbit.retry.RepublishMessageRecoverer
setExceptionHandler(ExceptionHandler) - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
setExchange(String) - Method in class org.springframework.amqp.rabbit.config.BindingFactoryBean
setExchange(String) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate: The name of the default exchange to use for send operations when none is specified.
setExchangeName(String) - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender
setExchangeName(String) - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
setExchangeType(String) - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender
setExchangeType(String) - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
setExclusive(boolean) - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint: Set if a single consumer in the container will have exclusive use of the queues, preventing other consumers from receiving messages from the queue(s).
setExclusive(boolean) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer: Set to true for an exclusive consumer - if true, the concurrency must be 1.
setExclusiveConsumerExceptionLogger(ConditionalExceptionLogger) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer: Set a ConditionalExceptionLogger for logging exclusive consumer failures.
setExecutor(Executor) - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory: Provide an Executor for use by the Rabbit ConnectionFactory when creating connections.
setExpiration(String) - Method in class org.springframework.amqp.core.MessageBuilderSupport
setExpiration(String) - Method in class org.springframework.amqp.core.MessageProperties
setExpirationIfAbsent(String) - Method in class org.springframework.amqp.core.MessageBuilderSupport
setExposeListenerChannel(boolean) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer: Set whether to expose the listener Rabbit Channel to a registered ChannelAwareMessageListener as well as to RabbitTemplate calls.
setFailedDeclarationRetryInterval(long) - Method in class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer: Set the interval between passive queue declaration attempts in milliseconds.
setFailedDeclarationRetryInterval(long) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer: Set the interval between passive queue declaration attempts in milliseconds.
setGenerateId(boolean) - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender
setGenerateId(boolean) - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
setGroup(String) - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint: Set the group for the corresponding listener container.
setHandlerMethod(HandlerAdapter) - Method in class org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter: Set the HandlerAdapter to use to invoke the method processing an incoming Message.
setHeader(String, Object) - Method in class org.springframework.amqp.core.MessageBuilderSupport
setHeader(String, Object) - Method in class org.springframework.amqp.core.MessageProperties
setHeaderIfAbsent(String, Object) - Method in class org.springframework.amqp.core.MessageBuilderSupport
setHeaderMapper(AmqpHeaderMapper) - Method in class org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter: Set the AmqpHeaderMapper implementation to use to map the standard AMQP headers.
setHeaderMapper(AmqpHeaderMapper) - Method in class org.springframework.amqp.support.converter.MessagingMessageConverter: Set the AmqpHeaderMapper to use to map AMQP headers to and from standard message headers.
setHost(String) - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
setHost(String) - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
setHost(String) - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender
setHost(String) - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
setId(String) - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint
setId(String) - Method in class org.springframework.amqp.rabbit.support.CorrelationData: Set the correlation id.
setIdClassMapping(Map<String, Class<?>>) - Method in class org.springframework.amqp.support.converter.AbstractJavaTypeMapper
setIdClassMapping(Map<String, Class<?>>) - Method in class org.springframework.amqp.support.converter.DefaultClassMapper
setIdleEventInterval(Long) - Method in class org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory: How often to publish idle container events.
setIdleEventInterval(long) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer: How often to emit ListenerContainerIdleEvents in milliseconds.
setIgnoreContentType(boolean) - Method in class org.springframework.amqp.support.converter.SerializerMessageConverter: Flag to signal that the content type should be ignored and the deserializer used irrespective if it is a text message.
setIgnoreDeclarationExceptions(boolean) - Method in class org.springframework.amqp.rabbit.core.RabbitAdmin
setImportMetadata(AnnotationMetadata) - Method in class org.springframework.amqp.rabbit.test.RabbitListenerTestBootstrap
setJavaTypeMapper(Jackson2JavaTypeMapper) - Method in class org.springframework.amqp.support.converter.Jackson2JsonMessageConverter
setJavaTypeMapper(JavaTypeMapper) - Method in class org.springframework.amqp.support.converter.JsonMessageConverter
setJsonObjectMapper(ObjectMapper) - Method in class org.springframework.amqp.support.converter.Jackson2JsonMessageConverter: The ObjectMapper to use instead of using the default.
setJsonObjectMapper(ObjectMapper) - Method in class org.springframework.amqp.support.converter.JsonMessageConverter: The ObjectMapper to use instead of using the default.
setKeyStore(String) - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean: Set the key store resource (e.g.
setKeyStorePassphrase(String) - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean: Set the key store pass phrase - overrides the property in RabbitConnectionFactoryBean.setSslPropertiesLocation(Resource).
setLayout(Layout<ILoggingEvent>) - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
setLenientFallback(boolean) - Method in class org.springframework.amqp.rabbit.connection.AbstractRoutingConnectionFactory: Specify whether to apply a lenient fallback to the default ConnectionFactory if no specific ConnectionFactory could be found for the current lookup key.
setLevel(int) - Method in class org.springframework.amqp.support.postprocessor.AbstractDeflaterPostProcessor: Set the deflater compression level.
setListenerId(String) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
setMandatory(boolean) - Method in class org.springframework.amqp.rabbit.core.AsyncRabbitTemplate: Set to true to enable the receipt of returned messages that cannot be delivered in the form of a AmqpMessageReturnedException.
setMandatory(boolean) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
setMandatoryExpression(Expression) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
setMandatoryPublish(boolean) - Method in class org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener
setMarshaller(Marshaller) - Method in class org.springframework.amqp.support.converter.MarshallingMessageConverter: Set the Marshaller to be used by this message converter.
setMaxConcurrentConsumers(Integer) - Method in class org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory
setMaxConcurrentConsumers(int) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer: Sets an upper limit to the number of consumers; defaults to 'concurrentConsumers'.
setMaxSenderRetries(int) - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender
setMaxSenderRetries(int) - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
setMessageConverter(MessageConverter) - Method in class org.springframework.amqp.rabbit.config.AbstractRabbitListenerContainerFactory
setMessageConverter(MessageConverter) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate: Set the message converter for this template.
setMessageConverter(MessageConverter) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer: Set the MessageConverter strategy for converting AMQP Messages.
setMessageConverter(MessageConverter) - Method in class org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener: Set the converter that will convert incoming Rabbit messages to listener method arguments, and objects returned from listener methods back to Rabbit messages.
setMessageConverter(MessageConverter) - Method in class org.springframework.amqp.remoting.service.AmqpInvokerServiceExporter: Set the message converter for this remote service.
setMessageCount(Integer) - Method in class org.springframework.amqp.core.MessageBuilderSupport
setMessageCount(Integer) - Method in class org.springframework.amqp.core.MessageProperties
setMessageCountIfAbsent(Integer) - Method in class org.springframework.amqp.core.MessageBuilderSupport
setMessageHandlerMethodFactory(MessageHandlerMethodFactory) - Method in class org.springframework.amqp.rabbit.annotation.RabbitListenerAnnotationBeanPostProcessor: Set the MessageHandlerMethodFactory to use to configure the message listener responsible to serve an endpoint detected by this processor.
setMessageHandlerMethodFactory(MessageHandlerMethodFactory) - Method in class org.springframework.amqp.rabbit.listener.MethodRabbitListenerEndpoint: Set the MessageHandlerMethodFactory to use to build the InvocableHandlerMethod responsible to manage the invocation of this endpoint.
setMessageHandlerMethodFactory(MessageHandlerMethodFactory) - Method in class org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistrar: Set the MessageHandlerMethodFactory to use to configure the message listener responsible to serve an endpoint detected by this processor.
setMessageId(String) - Method in class org.springframework.amqp.core.MessageBuilderSupport
setMessageId(String) - Method in class org.springframework.amqp.core.MessageProperties
setMessageIdIfAbsent(String) - Method in class org.springframework.amqp.core.MessageBuilderSupport
setMessageKeyGenerator(MessageKeyGenerator) - Method in class org.springframework.amqp.rabbit.config.StatefulRetryOperationsInterceptorFactoryBean
setMessageListener(MessageListener) - Method in class org.springframework.amqp.rabbit.config.SimpleRabbitListenerEndpoint: Set the MessageListener to invoke when a message matching the endpoint is received.
setMessageListener(Object) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer: Set the message listener implementation to register.
setMessagePropertiesConverter(MessagePropertiesConverter) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate: Set the MessagePropertiesConverter for this template.
setMessagePropertiesConverter(MessagePropertiesConverter) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer: Set the MessagePropertiesConverter for this listener container.
setMessageRecoverer(MessageRecoverer) - Method in class org.springframework.amqp.rabbit.config.AbstractRetryOperationsInterceptorFactoryBean
setMethod(Method) - Method in class org.springframework.amqp.rabbit.listener.MethodRabbitListenerEndpoint: Set the method to invoke to process a message managed by this endpoint.
setMismatchedQueuesFatal(Boolean) - Method in class org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory
setMismatchedQueuesFatal(boolean) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer: Prevent the container from starting if any of the queues defined in the context have mismatched arguments (TTL etc).
setMissingQueuesFatal(Boolean) - Method in class org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory
setMissingQueuesFatal(boolean) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer: If all of the configured queue(s) are not available on the broker, this setting determines whether the condition is fatal (default true).
setNewMessageIdentifier(NewMessageIdentifier) - Method in class org.springframework.amqp.rabbit.config.StatefulRetryOperationsInterceptorFactoryBean
setOrder(int) - Method in class org.springframework.amqp.support.postprocessor.AbstractCompressingPostProcessor
setOrder(int) - Method in class org.springframework.amqp.support.postprocessor.AbstractDecompressingPostProcessor
setOrder(int) - Method in class org.springframework.amqp.support.postprocessor.DelegatingDecompressingPostProcessor
setParserConfiguration(SpelParserConfiguration) - Method in class org.springframework.amqp.rabbit.support.ExpressionFactoryBean
setPassword(String) - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
setPassword(String) - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
setPassword(String) - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender
setPassword(String) - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
setPayloadConverter(MessageConverter) - Method in class org.springframework.amqp.support.converter.MessagingMessageConverter: Set the MessageConverter to use to convert the payload.
setPhase(int) - Method in class org.springframework.amqp.rabbit.config.AbstractRabbitListenerContainerFactory
setPhase(int) - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory: Defaults to phase - 1000 so the factory is stopped in a very late phase, allowing other beans to use the connection to clean up.
setPhase(int) - Method in class org.springframework.amqp.rabbit.core.AsyncRabbitTemplate
setPhase(int) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer: Specify the phase in which this container should be started and stopped.
setPhysicalCloseRequired(boolean) - Static method in class org.springframework.amqp.rabbit.connection.RabbitUtils: Sets a ThreadLocal indicating the channel MUST be physically closed.
setPort(int) - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
setPort(int) - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
setPort(int) - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender
setPort(int) - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
setPrefetchCount(Integer) - Method in class org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory
setPrefetchCount(int) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer: Tells the broker how many messages to send to each consumer in a single request.
setPriority(Integer) - Method in class org.springframework.amqp.core.MessageBuilderSupport
setPriority(Integer) - Method in class org.springframework.amqp.core.MessageProperties
setPriority(Integer) - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint: Set the priority of this endpoint.
setPriorityIfAbsentOrDefault(Integer) - Method in class org.springframework.amqp.core.MessageBuilderSupport
setProperties(MessageProperties) - Method in class org.springframework.amqp.core.MessageBuilderSupport
setPublisherConfirms(boolean) - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory
setPublisherReturns(boolean) - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory
setQueue(String) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate: The name of the default queue to receive messages from when none is specified explicitly.
setQueueNames(String...) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer: Set the name of the queue(s) to receive messages from.
setQueueNames(String...) - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint: Set the queue names to use.
setQueueNames(String...) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer
setQueueOrTagToMethodName(Map<String, String>) - Method in class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter: Set the mapping of queue name or consumer tag to method name.
setQueues(Queue...) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer: Set the name of the queue(s) to receive messages from.
setQueues(Queue...) - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint: Set the queues to use.
setQueues(Queue...) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer
setQuiesce(long) - Method in class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer: Deprecated.
as redundant option in favor of BlockingQueueConsumer.basicCancel().
setRabbitAdmin(RabbitAdmin) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer: Set the RabbitAdmin, used to declare any auto-delete queues, bindings etc when the container is started.
setRabbitTemplate(RabbitTemplate) - Method in class org.springframework.amqp.rabbit.core.RabbitGatewaySupport: Set the RabbitTemplate for the gateway.
setRabbitTemplate(RabbitTemplate) - Method in class org.springframework.amqp.rabbit.core.RabbitMessagingTemplate: Set the RabbitTemplate to use.
setReceiveConnectionFactorySelectorExpression(Expression) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate: A SpEL Expression to evaluate against each receive queueName, if the provided RabbitAccessor.getConnectionFactory() is an instance of AbstractRoutingConnectionFactory.
setReceivedDelay(Integer) - Method in class org.springframework.amqp.core.MessageProperties: When a delayed message exchange is used the x-delay header on a received message contains the delay.
setReceivedExchange(String) - Method in class org.springframework.amqp.core.MessageBuilderSupport
setReceivedExchange(String) - Method in class org.springframework.amqp.core.MessageProperties
setReceivedExchangeIfAbsent(String) - Method in class org.springframework.amqp.core.MessageBuilderSupport
setReceivedRoutingKey(String) - Method in class org.springframework.amqp.core.MessageBuilderSupport
setReceivedRoutingKey(String) - Method in class org.springframework.amqp.core.MessageProperties
setReceivedRoutingKeyIfAbsent(String) - Method in class org.springframework.amqp.core.MessageBuilderSupport
setReceiveTimeout(Long) - Method in class org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory
setReceiveTimeout(long) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate: Specify the receive timeout in milliseconds when using receive() methods (for sendAndReceive() methods, refer to replyTimeout.
setReceiveTimeout(long) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer: The time (in milliseconds) that a consumer should wait for data.
setRecoveryBackOff(BackOff) - Method in class org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory
setRecoveryBackOff(BackOff) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer: Specify the BackOff for interval between recovery attempts.
setRecoveryCallback(RecoveryCallback<?>) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate: Add a RecoveryCallback which is used for the retryTemplate.execute.
setRecoveryInterval(Long) - Method in class org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory
setRecoveryInterval(long) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer: Specify the interval between recovery attempts, in milliseconds.
setRedelivered(Boolean) - Method in class org.springframework.amqp.core.MessageBuilderSupport
setRedelivered(Boolean) - Method in class org.springframework.amqp.core.MessageProperties
setRedeliveredIfAbsent(Boolean) - Method in class org.springframework.amqp.core.MessageBuilderSupport
setReferenceIfAttributeDefined(BeanDefinitionBuilder, Element, String, String) - Static method in class org.springframework.amqp.rabbit.config.NamespaceUtils: Populates the specified bean definition property with the reference to a bean.
setReferenceIfAttributeDefined(BeanDefinitionBuilder, Element, String) - Static method in class org.springframework.amqp.rabbit.config.NamespaceUtils: Populates the bean definition property corresponding to the specified attributeName with the reference to a bean identified by the value of that attribute if the attribute is defined in the given element.
setRemoteInvocationFactory(RemoteInvocationFactory) - Method in class org.springframework.amqp.remoting.client.AmqpClientInterceptor: Set the RemoteInvocationFactory to use for this accessor.
setReplyAddress(String) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate: An address for replies; if not provided, a temporary exclusive, auto-delete queue will be used for each reply, unless RabbitMQ supports 'amq.rabbitmq.reply-to' - see http://www.rabbitmq.com/direct-reply-to.html
setReplyPostProcessor(MessagePostProcessor) - Method in class org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener: Set a post processor to process the reply immediately before Channel#basicPublish().
setReplyQueue(Queue) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate: Deprecated.
- use #setReplyAddress(String replyAddress)
setReplyTimeout(long) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate: Specify the timeout in milliseconds to be used when waiting for a reply Message when using one of the sendAndReceive methods.
setReplyTo(String) - Method in class org.springframework.amqp.core.MessageBuilderSupport
setReplyTo(String) - Method in class org.springframework.amqp.core.MessageProperties
setReplyToAddress(Address) - Method in class org.springframework.amqp.core.MessageBuilderSupport
setReplyToAddress(Address) - Method in class org.springframework.amqp.core.MessageProperties
setReplyToAddressIfAbsent(Address) - Method in class org.springframework.amqp.core.MessageBuilderSupport
setReplyToIfAbsent(String) - Method in class org.springframework.amqp.core.MessageBuilderSupport
setRequestedChannelMax(int) - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
setRequestedFrameMax(int) - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
setRequestedHeartBeat(int) - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
setRequestedHeartbeat(int) - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
setResponseExchange(String) - Method in class org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener: Set the exchange to use when sending response messages.
setResponseRoutingKey(String) - Method in class org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener: Set the routing key to use when sending response messages.
setRetryDeclarationInterval(long) - Method in class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer: When consuming multiple queues, set the interval between declaration attempts when only a subset of the queues were available (milliseconds).
setRetryDeclarationInterval(long) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer: When consuming multiple queues, set the interval between declaration attempts when only a subset of the queues were available (milliseconds).
setRetryOperations(RetryOperations) - Method in class org.springframework.amqp.rabbit.config.AbstractRetryOperationsInterceptorFactoryBean
setRetryTemplate(RetryTemplate) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate: Add a RetryTemplate which will be used for all rabbit operations.
setReturnCallback(RabbitTemplate.ReturnCallback) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
setRoutingKey(String) - Method in class org.springframework.amqp.rabbit.config.BindingFactoryBean
setRoutingKey(String) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate: The value of a default routing key to use for send operations when none is specified.
setRoutingKey(String) - Method in class org.springframework.amqp.remoting.client.AmqpClientInterceptor: The routing key to send calls to the service with.
setRoutingKeyPattern(String) - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender
setRoutingKeyPattern(String) - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
setSaslConfig(SaslConfig) - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
setSendConnectionFactorySelectorExpression(Expression) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate: A SpEL Expression to evaluate against each request message, if the provided RabbitAccessor.getConnectionFactory() is an instance of AbstractRoutingConnectionFactory.
setSenderPoolSize(int) - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender
setSenderPoolSize(int) - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
setSerializer(Serializer<Object>) - Method in class org.springframework.amqp.support.converter.SerializerMessageConverter: The serializer to use for converting Java objects to message bodies.
setSharedExecutor(ExecutorService) - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
setShouldDeclare(boolean) - Method in class org.springframework.amqp.core.AbstractDeclarable: Whether or not this object should be automatically declared by any AmqpAdmin.
setShouldDeclare(boolean) - Method in class org.springframework.amqp.rabbit.config.BindingFactoryBean
setShutdownTimeout(long) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer: The time to wait for workers in milliseconds after the container is stopped, and before the connection is forced closed.
setSocketConfigurator(SocketConfigurator) - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
setSocketFactory(SocketFactory) - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
setSslAlgorithm(String) - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean: Set the algorithm to use; default TLSv1.1.
setSslPropertiesLocation(Resource) - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean: When RabbitConnectionFactoryBean.setUseSSL(boolean) is true, the SSL properties to use (optional).
setStartConsumerMinInterval(Long) - Method in class org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory
setStartConsumerMinInterval(long) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer: If SimpleMessageListenerContainer.maxConcurrentConsumers is greater then SimpleMessageListenerContainer.concurrentConsumers, and SimpleMessageListenerContainer.maxConcurrentConsumers has not been reached, specifies the minimum time (milliseconds) between starting new consumers on demand.
setStopConsumerMinInterval(Long) - Method in class org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory
setStopConsumerMinInterval(long) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer: If SimpleMessageListenerContainer.maxConcurrentConsumers is greater then SimpleMessageListenerContainer.concurrentConsumers, and the number of consumers exceeds SimpleMessageListenerContainer.concurrentConsumers, specifies the minimum time (milliseconds) between stopping idle consumers.
setTagStrategy(ConsumerTagStrategy) - Method in class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer: Set the ConsumerTagStrategy to use when generating consumer tags.
setTargetConnectionFactories(Map<Object, ConnectionFactory>) - Method in class org.springframework.amqp.rabbit.connection.AbstractRoutingConnectionFactory: Specify the map of target ConnectionFactories, with the lookup key as key.
setTaskExecutor(Executor) - Method in class org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory
setTaskExecutor(Executor) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer
setThreadFactory(ThreadFactory) - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
setTimestamp(Date) - Method in class org.springframework.amqp.core.MessageBuilderSupport
setTimestamp(Date) - Method in class org.springframework.amqp.core.MessageProperties
setTimestampIfAbsent(Date) - Method in class org.springframework.amqp.core.MessageBuilderSupport
setTransactionAttribute(TransactionAttribute) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer
setTransactionManager(PlatformTransactionManager) - Method in class org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory
setTransactionManager(PlatformTransactionManager) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer
setTrustStore(String) - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean: Set the key store resource (e.g.
setTrustStorePassphrase(String) - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean: Set the trust store pass phrase - overrides the property in RabbitConnectionFactoryBean.setSslPropertiesLocation(Resource).
setTxSize(Integer) - Method in class org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory
setTxSize(int) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer: Tells the container how many messages to process in a single transaction (if the channel is transactional).
setType(String) - Method in class org.springframework.amqp.core.MessageBuilderSupport
setType(String) - Method in class org.springframework.amqp.core.MessageProperties
setTypeIfAbsent(String) - Method in class org.springframework.amqp.core.MessageBuilderSupport
setUnmarshaller(Unmarshaller) - Method in class org.springframework.amqp.support.converter.MarshallingMessageConverter: Set the Unmarshaller to be used by this message converter.
setUpExchangeDeclaration() - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender
setUpExchangeDeclaration() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
setupListenerContainer(MessageListenerContainer) - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint
setupListenerContainer(MessageListenerContainer) - Method in interface org.springframework.amqp.rabbit.listener.RabbitListenerEndpoint: Setup the specified message listener container with the model defined by this endpoint.
setupMessageListener(Object) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
setupMessageListener(Object) - Method in interface org.springframework.amqp.rabbit.listener.MessageListenerContainer: Setup the message listener to use.
setUpSSL() - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean: Override this method to take complete control over the SSL setup.
setUri(URI) - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
setUri(String) - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
setUri(URI) - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
setUri(String) - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
setUserId(String) - Method in class org.springframework.amqp.core.MessageBuilderSupport
setUserId(String) - Method in class org.springframework.amqp.core.MessageProperties
setUserIdIfAbsent(String) - Method in class org.springframework.amqp.core.MessageBuilderSupport
setUsername(String) - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
setUsername(String) - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
setUsername(String) - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender
setUsername(String) - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
setUseSSL(boolean) - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean: Whether or not the factory should be configured to use SSL.
setUseTemporaryReplyQueues(boolean) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate: By default, when the broker supports it and no replyAddress is provided, send/receive methods will use Direct reply-to (https://www.rabbitmq.com/direct-reply-to.html).
setValue(EvaluationContext, Object) - Method in class org.springframework.amqp.rabbit.support.ValueExpression
setValue(Object, Object) - Method in class org.springframework.amqp.rabbit.support.ValueExpression
setValue(EvaluationContext, Object, Object) - Method in class org.springframework.amqp.rabbit.support.ValueExpression
setValueIfAttributeDefined(BeanDefinitionBuilder, Element, String, String) - Static method in class org.springframework.amqp.rabbit.config.NamespaceUtils: Populates the specified bean definition property with the value of the attribute whose name is provided if that attribute is defined in the given element.
setValueIfAttributeDefined(BeanDefinitionBuilder, Element, String) - Static method in class org.springframework.amqp.rabbit.config.NamespaceUtils: Populates the bean definition property corresponding to the specified attributeName with the value of that attribute if it is defined in the given element.
setVirtualHost(String) - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
setVirtualHost(String) - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
setVirtualHost(String) - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender
setVirtualHost(String) - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
sharedConnectionEnabled() - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer: Always use a shared Rabbit Connection.
SharedConnectionNotInitializedException(String) - Constructor for exception org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.SharedConnectionNotInitializedException: Create a new SharedConnectionNotInitializedException.
shouldDeclare() - Method in class org.springframework.amqp.core.AbstractDeclarable
shouldDeclare() - Method in interface org.springframework.amqp.core.Declarable: Whether or not this object should be automatically declared by any AmqpAdmin.
shouldGenerateIdAsFallback() - Method in class org.springframework.amqp.rabbit.config.AbstractExchangeParser
shouldGenerateIdAsFallback() - Method in class org.springframework.amqp.rabbit.config.QueueParser
shutdown() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer: Stop the shared Connection, call AbstractMessageListenerContainer.doShutdown(), and close this container.
shutdownCompleted(ShutdownSignalException) - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory
shutdownCompleted(ShutdownSignalException) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
SimpleAmqpHeaderMapper - Class in org.springframework.amqp.support: Simple implementation of AmqpHeaderMapper.
SimpleAmqpHeaderMapper() - Constructor for class org.springframework.amqp.support.SimpleAmqpHeaderMapper
SimpleBatchingStrategy - Class in org.springframework.amqp.rabbit.core.support: A simple batching strategy that supports only one exchange/routingKey; includes a batch size, a batched message size limit and a timeout.
SimpleBatchingStrategy(int, int, long) - Constructor for class org.springframework.amqp.rabbit.core.support.SimpleBatchingStrategy
SimpleConnection - Class in org.springframework.amqp.rabbit.connection: Simply a Connection.
SimpleConnection(Connection, int) - Constructor for class org.springframework.amqp.rabbit.connection.SimpleConnection
SimpleMessageConverter - Class in org.springframework.amqp.support.converter: Implementation of MessageConverter that can work with Strings, Serializable instances, or byte arrays.
SimpleMessageConverter() - Constructor for class org.springframework.amqp.support.converter.SimpleMessageConverter
SimpleMessageListenerContainer - Class in org.springframework.amqp.rabbit.listener
SimpleMessageListenerContainer() - Constructor for class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer: Default constructor for convenient dependency injection via setters.
SimpleMessageListenerContainer(ConnectionFactory) - Constructor for class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer: Create a listener container from the connection factory (mandatory).
SimpleMessageListenerContainer.ContainerDelegate - Interface in org.springframework.amqp.rabbit.listener
SimpleRabbitListenerContainerFactory - Class in org.springframework.amqp.rabbit.config: A RabbitListenerContainerFactory implementation to build a regular SimpleMessageListenerContainer.
SimpleRabbitListenerContainerFactory() - Constructor for class org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory
SimpleRabbitListenerEndpoint - Class in org.springframework.amqp.rabbit.config: A RabbitListenerEndpoint simply providing the MessageListener to invoke to process an incoming message for this endpoint.
SimpleRabbitListenerEndpoint() - Constructor for class org.springframework.amqp.rabbit.config.SimpleRabbitListenerEndpoint
SimpleResourceHolder - Class in org.springframework.amqp.rabbit.connection: Central helper that manages resources per thread to be used by resource management code.
SimpleRoutingConnectionFactory - Class in org.springframework.amqp.rabbit.connection: An AbstractRoutingConnectionFactory implementation which gets a lookupKey for current ConnectionFactory from thread-bound resource by key of the instance of this ConnectionFactory.
SimpleRoutingConnectionFactory() - Constructor for class org.springframework.amqp.rabbit.connection.SimpleRoutingConnectionFactory
sort(Collection<MessagePostProcessor>) - Static method in class org.springframework.amqp.support.postprocessor.MessagePostProcessorUtils
SPRING_AUTO_DECOMPRESS - Static variable in class org.springframework.amqp.core.MessageProperties
SPRING_BATCH_FORMAT - Static variable in class org.springframework.amqp.core.MessageProperties
SPRING_REPLY_CORRELATION - Static variable in class org.springframework.amqp.support.AmqpHeaders
SPRING_REPLY_TO_STACK - Static variable in class org.springframework.amqp.support.AmqpHeaders
start() - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory
start() - Method in class org.springframework.amqp.rabbit.core.AsyncRabbitTemplate
start() - Method in class org.springframework.amqp.rabbit.core.BatchingRabbitTemplate
start() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer: Start this container.
start() - Method in class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer
start() - Method in class org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistry
start() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
startSenders() - Method in class org.springframework.amqp.rabbit.log4j.AmqpAppender: Submit the required number of senders into the pool.
stateful() - Static method in class org.springframework.amqp.rabbit.config.RetryInterceptorBuilder: Create a builder for a stateful retry interceptor.
StatefulRetryOperationsInterceptorFactoryBean - Class in org.springframework.amqp.rabbit.config: Convenient factory bean for creating a stateful retry interceptor for use in a message listener container, giving you a large amount of control over the behaviour of a container when a listener fails.
StatefulRetryOperationsInterceptorFactoryBean() - Constructor for class org.springframework.amqp.rabbit.config.StatefulRetryOperationsInterceptorFactoryBean
stateless() - Static method in class org.springframework.amqp.rabbit.config.RetryInterceptorBuilder: Create a builder for a stateless retry interceptor.
StatelessRetryOperationsInterceptorFactoryBean - Class in org.springframework.amqp.rabbit.config: Convenient factory bean for creating a stateless retry interceptor for use in a message listener container, giving you a large amount of control over the behaviour of a container when a listener fails.
StatelessRetryOperationsInterceptorFactoryBean() - Constructor for class org.springframework.amqp.rabbit.config.StatelessRetryOperationsInterceptorFactoryBean
stop() - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory: Stop the connection factory to prevent its connection from being used.
stop(Runnable) - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory
stop() - Method in class org.springframework.amqp.rabbit.core.AsyncRabbitTemplate
stop(Runnable) - Method in class org.springframework.amqp.rabbit.core.AsyncRabbitTemplate
stop() - Method in class org.springframework.amqp.rabbit.core.BatchingRabbitTemplate
stop() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer: Stop this container.
stop(Runnable) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
stop() - Method in class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer
stop() - Method in class org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistry
stop(Runnable) - Method in class org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistry
stop() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
SYSTEM - Static variable in class org.springframework.amqp.core.ExchangeTypes

T

TestUtils - Class in org.springframework.amqp.utils.test: See Spring Integration TestUtils.
TestUtils() - Constructor for class org.springframework.amqp.utils.test.TestUtils
TIMESTAMP - Static variable in class org.springframework.amqp.support.AmqpHeaders
to(FanoutExchange) - Method in class org.springframework.amqp.core.BindingBuilder.DestinationConfigurer
to(HeadersExchange) - Method in class org.springframework.amqp.core.BindingBuilder.DestinationConfigurer
to(DirectExchange) - Method in class org.springframework.amqp.core.BindingBuilder.DestinationConfigurer
to(TopicExchange) - Method in class org.springframework.amqp.core.BindingBuilder.DestinationConfigurer
to(Exchange) - Method in class org.springframework.amqp.core.BindingBuilder.DestinationConfigurer
toClass(MessageProperties) - Method in interface org.springframework.amqp.support.converter.ClassMapper
toClass(MessageProperties) - Method in class org.springframework.amqp.support.converter.DefaultClassMapper
toClass(MessageProperties) - Method in class org.springframework.amqp.support.converter.DefaultJackson2JavaTypeMapper
toClass(MessageProperties) - Method in class org.springframework.amqp.support.converter.DefaultJavaTypeMapper
toHeaders(MessageProperties) - Method in class org.springframework.amqp.support.SimpleAmqpHeaderMapper
toInt(MessageDeliveryMode) - Static method in enum org.springframework.amqp.core.MessageDeliveryMode
toJavaType(MessageProperties) - Method in class org.springframework.amqp.support.converter.DefaultJackson2JavaTypeMapper
toJavaType(MessageProperties) - Method in class org.springframework.amqp.support.converter.DefaultJavaTypeMapper
toJavaType(MessageProperties) - Method in interface org.springframework.amqp.support.converter.Jackson2JavaTypeMapper
toJavaType(MessageProperties) - Method in interface org.springframework.amqp.support.converter.JavaTypeMapper
toMessage(Object, MessageProperties) - Method in class org.springframework.amqp.support.converter.AbstractMessageConverter
toMessage(Object, MessageProperties) - Method in class org.springframework.amqp.support.converter.ContentTypeDelegatingMessageConverter
toMessage(Object, MessageProperties) - Method in interface org.springframework.amqp.support.converter.MessageConverter: Convert a Java object to a Message.
toMessage(Object, MessageProperties) - Method in class org.springframework.amqp.support.converter.MessagingMessageConverter
toMessageProperties(AMQP.BasicProperties, Envelope, String) - Method in class org.springframework.amqp.rabbit.support.DefaultMessagePropertiesConverter
toMessageProperties(AMQP.BasicProperties, Envelope, String) - Method in interface org.springframework.amqp.rabbit.support.MessagePropertiesConverter
toMessagingMessage(Message) - Method in class org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter
TOPIC - Static variable in class org.springframework.amqp.core.ExchangeTypes
TopicExchange - Class in org.springframework.amqp.core: Simple container collecting information to describe a topic exchange.
TopicExchange(String) - Constructor for class org.springframework.amqp.core.TopicExchange
TopicExchange(String, boolean, boolean) - Constructor for class org.springframework.amqp.core.TopicExchange
TopicExchange(String, boolean, boolean, Map<String, Object>) - Constructor for class org.springframework.amqp.core.TopicExchange
TopicExchangeParser - Class in org.springframework.amqp.rabbit.config
TopicExchangeParser() - Constructor for class org.springframework.amqp.rabbit.config.TopicExchangeParser
toString() - Method in class org.springframework.amqp.core.AbstractExchange
toString() - Method in class org.springframework.amqp.core.Address
toString() - Method in exception org.springframework.amqp.core.AmqpMessageReturnedException
toString() - Method in class org.springframework.amqp.core.Binding
toString() - Method in class org.springframework.amqp.core.Message
toString() - Method in class org.springframework.amqp.core.MessageProperties
toString() - Method in class org.springframework.amqp.core.Queue
toString() - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
toString() - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory
toString() - Method in class org.springframework.amqp.rabbit.connection.SimpleConnection
toString() - Method in class org.springframework.amqp.rabbit.core.DeclarationExceptionEvent
toString() - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint
toString() - Method in class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer
toString() - Method in class org.springframework.amqp.rabbit.listener.ListenerContainerConsumerFailedEvent
toString() - Method in class org.springframework.amqp.rabbit.listener.ListenerContainerIdleEvent
toString() - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer
toString() - Method in class org.springframework.amqp.rabbit.support.CorrelationData
toString() - Method in class org.springframework.amqp.rabbit.support.PendingConfirm
toString() - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
txCommit() - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
txRollback() - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
txSelect() - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
type - Variable in class org.springframework.amqp.core.BindingBuilder.DestinationConfigurer
TYPE - Static variable in class org.springframework.amqp.support.AmqpHeaders

U

unbind(Object) - Static method in class org.springframework.amqp.rabbit.connection.SimpleResourceHolder: Unbind a resource for the given key from the current thread.
unbindIfPossible(Object) - Static method in class org.springframework.amqp.rabbit.connection.SimpleResourceHolder: Unbind a resource for the given key from the current thread.
UncategorizedAmqpException - Exception in org.springframework.amqp: A "catch-all" exception type within the AmqpException hierarchy when no more specific cause is known.
UncategorizedAmqpException(Throwable) - Constructor for exception org.springframework.amqp.UncategorizedAmqpException
UncategorizedAmqpException(String, Throwable) - Constructor for exception org.springframework.amqp.UncategorizedAmqpException
UniquelyNamedQueue - Class in org.springframework.amqp.core: Create a queue with a unique name.
UniquelyNamedQueue() - Constructor for class org.springframework.amqp.core.UniquelyNamedQueue: Create a uniquely named queue.
UniquelyNamedQueue(String) - Constructor for class org.springframework.amqp.core.UniquelyNamedQueue: Create a uniquely named queue with a fixed prefix.
unRegisterConsumerChannel() - Static method in class org.springframework.amqp.rabbit.connection.ConsumerChannelRegistry: See registerConsumerChannel.
UnzipPostProcessor - Class in org.springframework.amqp.support.postprocessor: A post processor that uses a ZipInputStream to decompress the message body.
UnzipPostProcessor() - Constructor for class org.springframework.amqp.support.postprocessor.UnzipPostProcessor
UnzipPostProcessor(boolean) - Constructor for class org.springframework.amqp.support.postprocessor.UnzipPostProcessor
useDirectReplyTo() - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate: Override this method use some other criteria to decide whether or not to use direct reply-to (https://www.rabbitmq.com/direct-reply-to.html).
USER_ID - Static variable in class org.springframework.amqp.support.AmqpHeaders

V

validateConfiguration() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer: Validate the configuration of this container.
validateConfiguration() - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer: Avoid the possibility of not configuring the CachingConnectionFactory in sync with the number of concurrent consumers.
ValueExpression<V> - Class in org.springframework.amqp.rabbit.support: A very simple hardcoded implementation of the Expression interface that represents an immutable value.
ValueExpression(V) - Constructor for class org.springframework.amqp.rabbit.support.ValueExpression
valueOf(String) - Static method in enum org.springframework.amqp.core.AcknowledgeMode: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.springframework.amqp.core.Binding.DestinationType: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.springframework.amqp.core.MessageDeliveryMode: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.springframework.amqp.rabbit.connection.CachingConnectionFactory.CacheMode: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.springframework.amqp.rabbit.support.DefaultMessagePropertiesConverter.CorrelationIdPolicy: Returns the enum constant of this type with the specified name.
values() - Static method in enum org.springframework.amqp.core.AcknowledgeMode: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.springframework.amqp.core.Binding.DestinationType: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.springframework.amqp.core.MessageDeliveryMode: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.springframework.amqp.rabbit.connection.CachingConnectionFactory.CacheMode: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.springframework.amqp.rabbit.support.DefaultMessagePropertiesConverter.CorrelationIdPolicy: Returns an array containing the constants of this enum type, in the order they are declared.
verifyType(String, Object) - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor

W

waitForConfirms() - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
waitForConfirms(long) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
waitForConfirmsOrDie() - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
waitForConfirmsOrDie(long) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
where(String) - Method in class org.springframework.amqp.core.BindingBuilder.HeadersExchangeMapConfigurer
whereAll(String...) - Method in class org.springframework.amqp.core.BindingBuilder.HeadersExchangeMapConfigurer
whereAll(Map<String, Object>) - Method in class org.springframework.amqp.core.BindingBuilder.HeadersExchangeMapConfigurer
whereAny(String...) - Method in class org.springframework.amqp.core.BindingBuilder.HeadersExchangeMapConfigurer
whereAny(Map<String, Object>) - Method in class org.springframework.amqp.core.BindingBuilder.HeadersExchangeMapConfigurer
with(String) - Method in class org.springframework.amqp.core.BindingBuilder.DirectExchangeRoutingKeyConfigurer
with(Enum<?>) - Method in class org.springframework.amqp.core.BindingBuilder.DirectExchangeRoutingKeyConfigurer
with(String) - Method in class org.springframework.amqp.core.BindingBuilder.GenericExchangeRoutingKeyConfigurer
with(Enum<?>) - Method in class org.springframework.amqp.core.BindingBuilder.GenericExchangeRoutingKeyConfigurer
with(String) - Method in class org.springframework.amqp.core.BindingBuilder.TopicExchangeRoutingKeyConfigurer
with(Enum<?>) - Method in class org.springframework.amqp.core.BindingBuilder.TopicExchangeRoutingKeyConfigurer
withBody(byte[]) - Static method in class org.springframework.amqp.core.MessageBuilder: The final message body will be a direct reference to 'body'.
withBody(byte[], int, int) - Static method in class org.springframework.amqp.core.MessageBuilder: The final message body will be a new array containing the byte range from 'body'.
withClonedBody(byte[]) - Static method in class org.springframework.amqp.core.MessageBuilder: The final message body will be a copy of 'body' in a new array.
withQueueName() - Method in class org.springframework.amqp.core.BindingBuilder.DirectExchangeRoutingKeyConfigurer
wrap(Message<?>) - Static method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor: Create a AmqpMessageHeaderAccessor from the headers of an existing message.
wrapToListenerExecutionFailedExceptionIfNeeded(Exception, Message) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer

X

X_DELAY - Static variable in class org.springframework.amqp.core.MessageProperties
X_EXCEPTION_MESSAGE - Static variable in class org.springframework.amqp.rabbit.retry.RepublishMessageRecoverer
X_EXCEPTION_STACKTRACE - Static variable in class org.springframework.amqp.rabbit.retry.RepublishMessageRecoverer
X_ORIGINAL_EXCHANGE - Static variable in class org.springframework.amqp.rabbit.retry.RepublishMessageRecoverer
X_ORIGINAL_ROUTING_KEY - Static variable in class org.springframework.amqp.rabbit.retry.RepublishMessageRecoverer

Z

ZipPostProcessor - Class in org.springframework.amqp.support.postprocessor: A post processor that uses a ZipOutputStream to compress the message body.
ZipPostProcessor() - Constructor for class org.springframework.amqp.support.postprocessor.ZipPostProcessor
ZipPostProcessor(boolean) - Constructor for class org.springframework.amqp.support.postprocessor.ZipPostProcessor

A B C D E F G H I J L M N O P Q R S T U V W X Z