Skip navigation links
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

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.
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 durable, non-auto-delete Exchange with the provided name.
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.
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
 
AcknowledgeMode - Enum in org.springframework.amqp.core
 
addArgument(String, Object) - Method in class org.springframework.amqp.core.AbstractExchange
Add an argument to the arguments.
addDecompressor(String, MessagePostProcessor) - Method in class org.springframework.amqp.support.postprocessor.DelegatingDecompressingPostProcessor
Add a message post processor to the map of decompressing MessageProcessors.
addDelegate(String, MessageConverter) - Method in class org.springframework.amqp.support.converter.ContentTypeDelegatingMessageConverter
 
addDelgate(String, MessageConverter) - Method in class org.springframework.amqp.support.converter.ContentTypeDelegatingMessageConverter
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.
addHeader(MessageProperties, String, Class<?>) - Method in class org.springframework.amqp.support.converter.AbstractJavaTypeMapper
 
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.
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.
afterPropertiesSet() - Method in class org.springframework.amqp.remoting.client.AmqpProxyFactoryBean
 
afterPropertiesSet() - Method in class org.springframework.amqp.support.converter.AbstractJavaTypeMapper
Deprecated.
- no longer necessary.
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
 
AMQ_RABBITMQ_REPLY_TO - Static variable in class org.springframework.amqp.core.Address
Use this value in RabbitTemplate#setReplyAddress(String) to explicitly indicate that direct reply-to is to be used.
AMQ_RABBITMQ_REPLY_TO - Static variable in class org.springframework.amqp.core.AddressUtils
Deprecated.
Use the constant in Address.AMQ_RABBITMQ_REPLY_TO.
AmqpAdmin - Interface in org.springframework.amqp.core
Specifies a basic set of portable AMQP administrative operations for AMQP > 0.8
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
 
AmqpReplyTimeoutException - Exception in org.springframework.amqp.core
Async reply timeout.
AmqpReplyTimeoutException(String, Message) - Constructor for exception org.springframework.amqp.core.AmqpReplyTimeoutException
 
AmqpTemplate - Interface in org.springframework.amqp.core
Specifies a basic set of AMQP operations.
AmqpTimeoutException - Exception in org.springframework.amqp
Exception thrown when some time-bound operation fails to execute in the desired time.
AmqpTimeoutException(String, Throwable) - Constructor for exception org.springframework.amqp.AmqpTimeoutException
 
AmqpTimeoutException(String) - Constructor for exception org.springframework.amqp.AmqpTimeoutException
 
AmqpTimeoutException(Throwable) - Constructor for exception org.springframework.amqp.AmqpTimeoutException
 
AmqpUnsupportedEncodingException - Exception in org.springframework.amqp
RuntimeException for unsupported encoding in an AMQP operation.
AmqpUnsupportedEncodingException(Throwable) - Constructor for exception org.springframework.amqp.AmqpUnsupportedEncodingException
 
and(Map<String, Object>) - Method in class org.springframework.amqp.core.BindingBuilder.GenericArgumentsConfigurer
 
andProperties(MessageProperties) - Method in class org.springframework.amqp.core.MessageBuilder
Makes this builder's properties builder use a reference to properties.
AnonymousQueue - Class in org.springframework.amqp.core
Represents an anonymous, non-durable, exclusive, auto-delete queue.
AnonymousQueue() - Constructor for class org.springframework.amqp.core.AnonymousQueue
Construct a queue with a UUID name.
AnonymousQueue(Map<String, Object>) - Constructor for class org.springframework.amqp.core.AnonymousQueue
Construct a queue with a UUID name with the supplied arguments.
AnonymousQueue(AnonymousQueue.NamingStrategy) - Constructor for class org.springframework.amqp.core.AnonymousQueue
Construct a queue with a name provided by the supplied naming strategy.
AnonymousQueue(AnonymousQueue.NamingStrategy, Map<String, Object>) - Constructor for class org.springframework.amqp.core.AnonymousQueue
Construct a queue with a name provided by the supplied naming strategy with the supplied arguments.
AnonymousQueue.Base64UrlNamingStrategy - Class in org.springframework.amqp.core
Generates names with the form <prefix><base64url> where 'prefix' is 'spring.gen-' by default; the 'base64url' String is generated from a UUID.
AnonymousQueue.NamingStrategy - Interface in org.springframework.amqp.core
A strategy to name anonymous queues
APP_ID - Static variable in class org.springframework.amqp.support.AmqpHeaders
 

B

Base64UrlNamingStrategy() - Constructor for class org.springframework.amqp.core.AnonymousQueue.Base64UrlNamingStrategy
Construct an instance using the default prefix spring.gen-.
Base64UrlNamingStrategy(String) - Constructor for class org.springframework.amqp.core.AnonymousQueue.Base64UrlNamingStrategy
Construct an instance using the supplied prefix.
BATCH_FORMAT_LENGTH_HEADER4 - Static variable in class org.springframework.amqp.core.MessageProperties
 
bind(Queue) - Static method in class org.springframework.amqp.core.BindingBuilder
 
bind(Exchange) - Static method in class org.springframework.amqp.core.BindingBuilder
 
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
 
BindingBuilder - Class in org.springframework.amqp.core
Basic builder class to create bindings for a more fluent API style in code based configuration.
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
 
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
 
buildProperties() - Method in class org.springframework.amqp.core.MessageBuilderSupport
 

C

CHANNEL - Static variable in class org.springframework.amqp.support.AmqpHeaders
 
checkWhiteList(Class<?>) - Method in class org.springframework.amqp.support.converter.WhiteListDeserializingMessageConverter
 
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.
CLUSTER_ID - Static variable in class org.springframework.amqp.support.AmqpHeaders
 
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.
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.
ConsumerTagStrategy - Interface in org.springframework.amqp.support
A strategy interface to determine the consumer tag to be used when issuing a basicConsume operation.
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.
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.
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.
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
 
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.
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.
createObjectInputStream(InputStream, String) - Method in class org.springframework.amqp.support.converter.SimpleMessageConverter
Create an ObjectInputStream for the given InputStream and codebase.
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.
declareExchange(Exchange) - Method in interface org.springframework.amqp.core.AmqpAdmin
Declare an exchange
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
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_CONTENT_CLASSID_FIELD_NAME - Static variable in class org.springframework.amqp.support.converter.AbstractJavaTypeMapper
 
DEFAULT_CONTENT_TYPE - Static variable in class org.springframework.amqp.core.MessageProperties
 
DEFAULT_DELIVERY_MODE - Static variable in class org.springframework.amqp.core.MessageProperties
 
DEFAULT_KEY_CLASSID_FIELD_NAME - Static variable in class org.springframework.amqp.support.converter.AbstractJavaTypeMapper
 
DEFAULT_PRIORITY - Static variable in class org.springframework.amqp.core.MessageProperties
 
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
 
DELAY - Static variable in class org.springframework.amqp.support.AmqpHeaders
 
DELAYED - Static variable in class org.springframework.amqp.core.ExchangeTypes
 
DelegatingDecompressingPostProcessor - Class in org.springframework.amqp.support.postprocessor
A MessagePostProcessor that delegates to one of its MessagePostProcessors depending on the content encoding.
DelegatingDecompressingPostProcessor() - Constructor for class org.springframework.amqp.support.postprocessor.DelegatingDecompressingPostProcessor
 
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.
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.
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
 
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
 

E

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
 
exchange - Variable in class org.springframework.amqp.core.BindingBuilder.HeadersExchangeMapConfigurer
 
Exchange - Interface in org.springframework.amqp.core
 
ExchangeTypes - Class in org.springframework.amqp.core
Constants for the standard Exchange type names.
ExchangeTypes() - Constructor for class org.springframework.amqp.core.ExchangeTypes
 
exist() - Method in class org.springframework.amqp.core.BindingBuilder.HeadersExchangeMapConfigurer.HeadersExchangeKeysBindingCreator
 
exists() - Method in class org.springframework.amqp.core.BindingBuilder.HeadersExchangeMapConfigurer.HeadersExchangeSingleValueBindingCreator
 
EXPIRATION - Static variable in class org.springframework.amqp.support.AmqpHeaders
 
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
 
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
 
fromInferredTypeHeader(MessageProperties) - Method in class org.springframework.amqp.support.converter.AbstractJavaTypeMapper
 
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.
fromProperties(MessageProperties) - Static method in class org.springframework.amqp.core.MessagePropertiesBuilder
Initializes the builder with the supplied properties; the same object will be returned by MessagePropertiesBuilder.build().

G

generateName() - Method in class org.springframework.amqp.core.AnonymousQueue.Base64UrlNamingStrategy
 
generateName() - Method in interface org.springframework.amqp.core.AnonymousQueue.NamingStrategy
 
GenericArgumentsConfigurer(BindingBuilder.GenericExchangeRoutingKeyConfigurer, String) - Constructor for class org.springframework.amqp.core.BindingBuilder.GenericArgumentsConfigurer
 
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
 
getArguments() - Method in class org.springframework.amqp.core.AbstractExchange
 
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
 
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.
getBindingsForExchange(String, String) - Method in interface org.springframework.amqp.core.AmqpManagementOperations
Get all bindings from the provided exchange in the provided vhost.
getBody() - Method in class org.springframework.amqp.core.Message
 
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
 
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
 
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.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.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.support.AmqpMessageHeaderAccessor
 
getConverterForContentType(String) - Method in class org.springframework.amqp.support.converter.ContentTypeDelegatingMessageConverter
 
getCorrelationId() - Method in class org.springframework.amqp.core.MessageProperties
 
getCorrelationId() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
 
getCorrelationIdString() - Method in class org.springframework.amqp.core.MessageProperties
 
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
 
getDelay() - Method in class org.springframework.amqp.core.MessageProperties
The x-delay header (outbound).
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.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
 
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
 
getExchangeName() - Method in class org.springframework.amqp.core.Address
 
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.
getExchangeType() - Method in class org.springframework.amqp.core.Address
Deprecated.
getExpiration() - Method in class org.springframework.amqp.core.MessageProperties
 
getExpiration() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
 
getHeaders() - Method in class org.springframework.amqp.core.MessageProperties
 
getIdClassMapping() - Method in class org.springframework.amqp.support.converter.AbstractJavaTypeMapper
 
getInferredArgumentType() - Method in class org.springframework.amqp.core.MessageProperties
The inferred target argument type when using a method-level @RabbitListener.
getJavaTypeMapper() - Method in class org.springframework.amqp.support.converter.Jackson2JsonMessageConverter
 
getJavaTypeMapper() - Method in class org.springframework.amqp.support.converter.JsonMessageConverter
 
getKeyClassIdFieldName() - Method in class org.springframework.amqp.support.converter.AbstractJavaTypeMapper
 
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
 
getMessageId() - Method in class org.springframework.amqp.core.MessageProperties
 
getMessageId() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
 
getMessageProperties() - Method in class org.springframework.amqp.core.Message
 
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
 
getObject() - Method in class org.springframework.amqp.remoting.client.AmqpProxyFactoryBean
 
getObjectType() - Method in class org.springframework.amqp.remoting.client.AmqpProxyFactoryBean
 
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
 
getPriority() - Method in class org.springframework.amqp.core.MessageProperties
 
getPriority() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
 
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.
getQueueProperties(String) - Method in interface org.springframework.amqp.core.AmqpAdmin
Returns an implementation-specific Map of properties if the queue exists.
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.
getReceivedDelay() - Method in class org.springframework.amqp.core.MessageProperties
When a delayed message exchange is used the x-delay header on a received message contains the delay.
getReceivedDeliveryMode() - Method in class org.springframework.amqp.core.MessageProperties
 
getReceivedDeliveryMode() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
 
getReceivedExchange() - Method in class org.springframework.amqp.core.MessageProperties
 
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
 
getRequestMessage() - Method in exception org.springframework.amqp.core.AmqpReplyTimeoutException
 
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.remoting.client.AmqpClientInterceptor
 
getTargetBean() - Method in class org.springframework.amqp.core.MessageProperties
The target bean when using @RabbitListener
getTargetMethod() - Method in class org.springframework.amqp.core.MessageProperties
The target method when using a method-level @RabbitListener.
getTimestamp() - Method in class org.springframework.amqp.core.MessageProperties
 
getTimestamp() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
 
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
 
getTypePrecedence() - Method in class org.springframework.amqp.support.converter.DefaultJackson2JavaTypeMapper
Return the precedence.
getTypePrecedence() - Method in interface org.springframework.amqp.support.converter.Jackson2JavaTypeMapper
 
getTypePrecedence() - Method in class org.springframework.amqp.support.converter.Jackson2JsonMessageConverter
 
getUserId() - Method in class org.springframework.amqp.core.MessageProperties
 
getUserId() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
 
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
 
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
 
hasInferredTypeHeader(MessageProperties) - Method in class org.springframework.amqp.support.converter.AbstractJavaTypeMapper
 
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
 

I

ignoreDeclarationExceptions - Variable in class org.springframework.amqp.core.AbstractDeclarable
 
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
 
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(MethodInvocation) - Method in class org.springframework.amqp.remoting.client.AmqpClientInterceptor
 
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).
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.
isDelayed() - Method in class org.springframework.amqp.core.AbstractExchange
 
isDelayed() - Method in interface org.springframework.amqp.core.Exchange
Is a delayed message exchange; currently requires a broker plugin.
isDeliveryTagSet() - Method in class org.springframework.amqp.core.MessageProperties
 
isDestinationQueue() - Method in class org.springframework.amqp.core.Binding
 
isDurable() - Method in class org.springframework.amqp.core.AbstractExchange
 
isDurable() - Method in interface org.springframework.amqp.core.Exchange
A durable exchange will survive a server restart
isDurable() - Method in class org.springframework.amqp.core.Queue
A durable queue will survive a server restart
isExclusive() - Method in class org.springframework.amqp.core.Queue
True if the server should only send messages to the declarer's connection.
isIgnoreDeclarationExceptions() - Method in class org.springframework.amqp.core.AbstractDeclarable
 
isIgnoreDeclarationExceptions() - Method in interface org.springframework.amqp.core.Declarable
Should ignore exceptions (such as mismatched args) when declaring.
isInternal() - Method in class org.springframework.amqp.core.AbstractExchange
 
isInternal() - Method in interface org.springframework.amqp.core.Exchange
Is an exchange internal; i.e.
isManual() - Method in enum org.springframework.amqp.core.AcknowledgeMode
 
isRedelivered() - Method in class org.springframework.amqp.core.MessageProperties
 
isSingleton() - Method in class org.springframework.amqp.remoting.client.AmqpProxyFactoryBean
 
isTransactionAllowed() - Method in enum org.springframework.amqp.core.AcknowledgeMode
 

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.
Jackson2JavaTypeMapper.TypePrecedence - Enum in org.springframework.amqp.support.converter
 
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
 
log(Log, String, Throwable) - Method in interface org.springframework.amqp.support.ConditionalExceptionLogger
Log the event.

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
 
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
 
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.
MessageListener - Interface in org.springframework.amqp.core
Listener interface to receive asynchronous delivery of Amqp Messages.
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.
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.

N

name - Variable in class org.springframework.amqp.core.BindingBuilder.DestinationConfigurer
 
newInstance() - Static method in class org.springframework.amqp.core.MessagePropertiesBuilder
Returns a builder with an initial set of properties.
noargs() - Method in class org.springframework.amqp.core.BindingBuilder.GenericArgumentsConfigurer
 

O

onMessage(Message) - Method in interface org.springframework.amqp.core.MessageListener
 
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.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
 

P

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
 
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
 
PUBLISH_CONFIRM - Static variable in class org.springframework.amqp.support.AmqpHeaders
 
PUBLISH_CONFIRM_NACK_CAUSE - Static variable in class org.springframework.amqp.support.AmqpHeaders
 
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.

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.

R

receive() - Method in interface org.springframework.amqp.core.AmqpTemplate
Receive a message if there is one from a default queue.
receive(String) - Method in interface org.springframework.amqp.core.AmqpTemplate
Receive a message if there is one from a specific queue.
receive(long) - Method in interface org.springframework.amqp.core.AmqpTemplate
Receive a message from a default queue, waiting up to the specified wait time if necessary for a message to become available.
receive(String, long) - Method in interface org.springframework.amqp.core.AmqpTemplate
Receive a message from a specific queue, waiting up to the specified wait time if necessary for a message to become available.
receiveAndConvert() - Method in interface org.springframework.amqp.core.AmqpTemplate
Receive a message if there is one from a default queue and convert it to a Java object.
receiveAndConvert(String) - Method in interface org.springframework.amqp.core.AmqpTemplate
Receive a message if there is one from a specific queue and convert it to a Java object.
receiveAndConvert(long) - Method in interface org.springframework.amqp.core.AmqpTemplate
Receive a message if there is one from a default queue and convert it to a Java object.
receiveAndConvert(String, long) - Method in interface org.springframework.amqp.core.AmqpTemplate
Receive a message if there is one from a specific queue and convert it to a Java object.
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.
ReceiveAndReplyCallback<R,S> - Interface in org.springframework.amqp.core
To be used with the receive-and-reply methods of AmqpTemplate as processor for inbound object and producer for outbound object.
ReceiveAndReplyMessageCallback - Interface in org.springframework.amqp.core
Message exchanging contract of ReceiveAndReplyCallback.
RECEIVED_DELAY - Static variable in class org.springframework.amqp.support.AmqpHeaders
 
RECEIVED_DELIVERY_MODE - Static variable in class org.springframework.amqp.support.AmqpHeaders
 
RECEIVED_EXCHANGE - Static variable in class org.springframework.amqp.support.AmqpHeaders
 
RECEIVED_ROUTING_KEY - Static variable in class org.springframework.amqp.support.AmqpHeaders
 
REDELIVERED - Static variable in class org.springframework.amqp.support.AmqpHeaders
 
removeBinding(Binding) - Method in interface org.springframework.amqp.core.AmqpAdmin
Remove a binding of a queue to an exchange.
removeDecompressor(String) - Method in class org.springframework.amqp.support.postprocessor.DelegatingDecompressingPostProcessor
Remove the decompressor for this encoding; content will not be decompressed even if the MessageProperties.SPRING_AUTO_DECOMPRESS header is true.
removeDelegate(String) - Method in class org.springframework.amqp.support.converter.ContentTypeDelegatingMessageConverter
 
removeDelgate(String) - Method in class org.springframework.amqp.support.converter.ContentTypeDelegatingMessageConverter
removeHeader(String) - Method in class org.springframework.amqp.core.MessageBuilderSupport
 
removeHeaders() - Method in class org.springframework.amqp.core.MessageBuilderSupport
 
REPLY_TO - Static variable in class org.springframework.amqp.support.AmqpHeaders
 
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.
retrieveHeader(MessageProperties, String) - Method in class org.springframework.amqp.support.converter.AbstractJavaTypeMapper
 
retrieveHeaderAsString(MessageProperties, String) - Method in class org.springframework.amqp.support.converter.AbstractJavaTypeMapper
 
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
 

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.
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.
SerializationUtils - Class in org.springframework.amqp.utils
Static utility to help with serialization.
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
 
setAdminsThatShouldDeclare(Object...) - Method in class org.springframework.amqp.core.AbstractDeclarable
The AmqpAdmins that should declare this object; default is all admins.
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
 
setBeanClassLoader(ClassLoader) - Method in class org.springframework.amqp.support.converter.SimpleMessageConverter
 
setClassMapper(ClassMapper) - Method in class org.springframework.amqp.support.converter.AbstractJsonMessageConverter
 
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.
setConsumerQueue(String) - Method in class org.springframework.amqp.core.MessageProperties
 
setConsumerTag(String) - Method in class org.springframework.amqp.core.MessageProperties
 
setContentEncoding(String) - Method in class org.springframework.amqp.core.MessageBuilderSupport
 
setContentEncoding(String) - Method in class org.springframework.amqp.core.MessageProperties
 
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.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
 
setCorrelationIdString(String) - Method in class org.springframework.amqp.core.MessageProperties
 
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.
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.
setDefaultHashtableClass(Class<?>) - Method in class org.springframework.amqp.support.converter.DefaultClassMapper
 
setDefaultType(Class<?>) - Method in class org.springframework.amqp.support.converter.DefaultClassMapper
The type returned by DefaultClassMapper.toClass(MessageProperties) if no type information is found in the message properties.
setDelay(Integer) - Method in class org.springframework.amqp.core.MessageProperties
Set the x-delay header.
setDelayed(boolean) - Method in class org.springframework.amqp.core.AbstractExchange
Set the delayed flag.
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
 
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.
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
 
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.support.converter.MessagingMessageConverter
Set the AmqpHeaderMapper to use to map AMQP headers to and from standard message headers.
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.core.AbstractDeclarable
Set to true to ignore exceptions such as mismatched properties when declaring.
setInferredArgumentType(Type) - Method in class org.springframework.amqp.core.MessageProperties
Set the inferred target argument type when using a method-level @RabbitListener
setInternal(boolean) - Method in class org.springframework.amqp.core.AbstractExchange
Set the internal flag.
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.
setLevel(int) - Method in class org.springframework.amqp.support.postprocessor.AbstractDeflaterPostProcessor
Set the deflater compression level.
setMarshaller(Marshaller) - Method in class org.springframework.amqp.support.converter.MarshallingMessageConverter
Set the Marshaller to be used by this message converter.
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
 
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
 
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
 
setPayloadConverter(MessageConverter) - Method in class org.springframework.amqp.support.converter.MessagingMessageConverter
Set the MessageConverter to use to convert the payload.
setPriority(Integer) - Method in class org.springframework.amqp.core.MessageBuilderSupport
 
setPriority(Integer) - Method in class org.springframework.amqp.core.MessageProperties
 
setPriorityIfAbsentOrDefault(Integer) - Method in class org.springframework.amqp.core.MessageBuilderSupport
 
setProperties(MessageProperties) - Method in class org.springframework.amqp.core.MessageBuilderSupport
 
setReceivedDelay(Integer) - Method in class org.springframework.amqp.core.MessageProperties
When a delayed message exchange is used the x-delay header on a received message contains the delay.
setReceivedDeliveryMode(MessageDeliveryMode) - Method in class org.springframework.amqp.core.MessageProperties
 
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
 
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
 
setRemoteInvocationFactory(RemoteInvocationFactory) - Method in class org.springframework.amqp.remoting.client.AmqpClientInterceptor
Set the RemoteInvocationFactory to use for this accessor.
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
 
setRoutingKey(String) - Method in class org.springframework.amqp.remoting.client.AmqpClientInterceptor
The routing key to send calls to the service with.
setSerializer(Serializer<Object>) - Method in class org.springframework.amqp.support.converter.SerializerMessageConverter
The serializer to use for converting Java objects to message bodies.
setShouldDeclare(boolean) - Method in class org.springframework.amqp.core.AbstractDeclarable
Whether or not this object should be automatically declared by any AmqpAdmin.
setTargetBean(Object) - Method in class org.springframework.amqp.core.MessageProperties
Set the target bean when using @RabbitListener
setTargetMethod(Method) - Method in class org.springframework.amqp.core.MessageProperties
Set the target method when using a method-level @RabbitListener.
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
 
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
 
setTypePrecedence(Jackson2JavaTypeMapper.TypePrecedence) - Method in class org.springframework.amqp.support.converter.DefaultJackson2JavaTypeMapper
Set the precedence for evaluating type information in message properties.
setTypePrecedence(Jackson2JavaTypeMapper.TypePrecedence) - Method in class org.springframework.amqp.support.converter.Jackson2JsonMessageConverter
Set the precedence for evaluating type information in message properties.
setUnmarshaller(Unmarshaller) - Method in class org.springframework.amqp.support.converter.MarshallingMessageConverter
Set the Unmarshaller to be used by this message converter.
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
 
setWhiteListPatterns(List<String>) - Method in class org.springframework.amqp.support.converter.WhiteListDeserializingMessageConverter
Set simple patterns for allowable packages/classes for deserialization.
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.
SimpleAmqpHeaderMapper - Class in org.springframework.amqp.support
Simple implementation of AmqpHeaderMapper.
SimpleAmqpHeaderMapper() - Constructor for class org.springframework.amqp.support.SimpleAmqpHeaderMapper
 
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
 
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
 
SYSTEM - Static variable in class org.springframework.amqp.core.ExchangeTypes
 

T

TestUtils - Class in org.springframework.amqp.utils.test
See Spring Integration 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
 
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
 
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 exception org.springframework.amqp.core.AmqpReplyTimeoutException
 
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
 
type - Variable in class org.springframework.amqp.core.BindingBuilder.DestinationConfigurer
 
TYPE - Static variable in class org.springframework.amqp.support.AmqpHeaders
 

U

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.
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

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.support.converter.Jackson2JavaTypeMapper.TypePrecedence
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.support.converter.Jackson2JavaTypeMapper.TypePrecedence
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

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
 
WhiteListDeserializingMessageConverter - Class in org.springframework.amqp.support.converter
MessageConverters that potentially use Java deserialization.
WhiteListDeserializingMessageConverter() - Constructor for class org.springframework.amqp.support.converter.WhiteListDeserializingMessageConverter
 
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.

X

X_DELAY - Static variable in class org.springframework.amqp.core.MessageProperties
 

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