Skip navigation links
Spring AMQP
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
 
addDelgate(String, MessageConverter) - Method in class org.springframework.amqp.support.converter.ContentTypeDelegatingMessageConverter
 
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 and returns a reference to the pending confirms map for that listener's pending confirms, allowing the Listener to assess unconfirmed sends at any point in time.
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
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
 
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.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.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.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
 
AnonymousQueue() - Constructor for class org.springframework.amqp.core.AnonymousQueue
 
AnonymousQueue(Map<String, Object>) - Constructor for class org.springframework.amqp.core.AnonymousQueue
 
APP_ID - Static variable in class org.springframework.amqp.support.AmqpHeaders
 
append(LoggingEvent) - Method in class org.springframework.amqp.rabbit.log4j.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.logback.AmqpAppender
Key name for the application id (if there is one set via the appender config) in the message properties.
applyCommonSettings(AbstractRetryOperationsInterceptorFactoryBean) - Method in class org.springframework.amqp.rabbit.config.RetryInterceptorBuilder
 
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
 
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
 
basicRecoverAsync(boolean) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
Deprecated.
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
 
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.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.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 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
 
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(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
 
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
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.
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.
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
 
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 as a DataInputStream when longer than 1024 bytes.
DefaultMessagePropertiesConverter(int) - Constructor for class org.springframework.amqp.rabbit.support.DefaultMessagePropertiesConverter
Construct an instance where LongStrings will be returned as a DataInputStream when longer than this limit.
defaultRabbitListenerEndpointRegistry() - Method in class org.springframework.amqp.rabbit.annotation.RabbitBootstrapConfiguration
 
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) - 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
 
determineShutdownReason(ShutdownSignalException) - Static method in class org.springframework.amqp.rabbit.connection.RabbitUtils
 
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
 
doReceive(String) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
Blocking receive with timeout.
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(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.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
 
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
 
flow(boolean) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
Deprecated.
- removed in the 3.3.x client
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

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
 
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
 
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
 
getCount() - Method in class org.springframework.amqp.rabbit.listener.ActiveObjectCounter
 
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
 
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.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.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
 
getFlow() - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
Deprecated.
- removed in the 3.3.x client
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
 
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
 
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.
getListenerContainers() - Method in class org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistry
 
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.
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
 
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.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.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
 
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
 
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.
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.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.listener.ListenerContainerConsumerFailedEvent
 
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
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.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.
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
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.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
 
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
 
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
 
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
 
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
 
isNormalShutdown(ShutdownSignalException) - Static method in class org.springframework.amqp.rabbit.connection.RabbitUtils
 
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
 
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.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

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.
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
Maybe declare the exchange.
maybeDeclareExchange() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
Maybe declare the exchange.
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
 
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
 
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
 
onMessage(Message) - Method in interface org.springframework.amqp.core.MessageListener
 
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.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.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.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
 
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
 
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
 
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
 
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
 
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
 
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.
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() - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
 
receive(String) - 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() - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
 
receiveAndConvert(String) - 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_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
 
removeDelgate(String) - Method in class org.springframework.amqp.support.converter.ContentTypeDelegatingMessageConverter
 
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
 
removeListener(PublisherCallbackChannel.Listener) - Method in interface org.springframework.amqp.rabbit.support.PublisherCallbackChannel
Gets a reference to the current listener, or null.
removeListener(PublisherCallbackChannel.Listener) - Method in class org.springframework.amqp.rabbit.support.PublisherCallbackChannelImpl
 
removePendingConfirmsReference(Channel, SortedMap<Long, PendingConfirm>) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
 
removePendingConfirmsReference(Channel, SortedMap<Long, PendingConfirm>) - Method in interface org.springframework.amqp.rabbit.support.PublisherCallbackChannel.Listener
When called, this listener must remove all references to the pending confirm map.
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 interface org.springframework.amqp.rabbit.core.RabbitTemplate.ReturnCallback
Returned message callback.
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.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(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
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.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.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.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
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(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
 
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
 
setCorrelationIdIfAbsent(byte[]) - Method in class org.springframework.amqp.core.MessageBuilderSupport
 
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.
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
 
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
 
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
 
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
 
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.
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.
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.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.
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.
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.
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
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.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.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.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.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
 
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.
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.
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_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 
Skip navigation links
Spring AMQP