- AbstractBuilder - Class in org.springframework.amqp.core
-
Base class for builders supporting arguments.
- AbstractBuilder() - Constructor for class org.springframework.amqp.core.AbstractBuilder
-
- 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
-
- AbstractCompressingPostProcessor(boolean) - Constructor for class org.springframework.amqp.support.postprocessor.AbstractCompressingPostProcessor
-
- AbstractDeclarable - Class in org.springframework.amqp.core
-
- AbstractDeclarable() - Constructor for class org.springframework.amqp.core.AbstractDeclarable
-
- AbstractDecompressingPostProcessor - Class in org.springframework.amqp.support.postprocessor
-
- AbstractDecompressingPostProcessor() - Constructor for class org.springframework.amqp.support.postprocessor.AbstractDecompressingPostProcessor
-
- AbstractDecompressingPostProcessor(boolean) - Constructor for class org.springframework.amqp.support.postprocessor.AbstractDecompressingPostProcessor
-
- 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
-
Abstract type mapper.
- AbstractJavaTypeMapper() - Constructor for class org.springframework.amqp.support.converter.AbstractJavaTypeMapper
-
- AbstractJsonMessageConverter - Class in org.springframework.amqp.support.converter
-
Abstract JSON message converter.
- AbstractJsonMessageConverter() - Constructor for class org.springframework.amqp.support.converter.AbstractJsonMessageConverter
-
- AbstractMessageConverter - Class in org.springframework.amqp.support.converter
-
- AbstractMessageConverter() - Constructor for class org.springframework.amqp.support.converter.AbstractMessageConverter
-
- AcknowledgeMode - Enum in org.springframework.amqp.core
-
Acknowledgment modes supported by the listener container.
- 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
-
Add a delegate converter for the content type.
- 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 with the form
(exchange)/(routingKey)
- Address(String, String) - Constructor for class org.springframework.amqp.core.Address
-
Create an Address given the exchange name and routing key.
- addWhiteListPatterns(String...) - Static method in class org.springframework.amqp.core.Message
-
Add patterns to the white list of permissable package/class name patterns for
deserialization in
Message.toString().
- addWhiteListPatterns(String...) - Method in class org.springframework.amqp.support.converter.WhiteListDeserializingMessageConverter
-
Add package/class patterns to the white list.
- afterPropertiesSet() - Method in class org.springframework.amqp.remoting.client.AmqpProxyFactoryBean
-
- 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.
- AmqpAdmin - Interface in org.springframework.amqp.core
-
Specifies a basic set of portable AMQP administrative operations for AMQP > 0.9.
- AmqpApplicationContextClosedException - Exception in org.springframework.amqp
-
Thrown when the connection factory has been destroyed during
context close; the factory can no longer open connections.
- AmqpApplicationContextClosedException(String) - Constructor for exception org.springframework.amqp.AmqpApplicationContextClosedException
-
- 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
-
Construct an instance with the supplied message and cause.
- AmqpConnectException(String, Throwable) - Constructor for exception org.springframework.amqp.AmqpConnectException
-
Construct an instance with the supplied message and cause.
- 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
-
Construct an instance with the provided cause.
- AmqpIOException(String, Throwable) - Constructor for exception org.springframework.amqp.AmqpIOException
-
Construct an instance with the provided message and cause.
- 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
-
- AmqpRemoteException - Exception in org.springframework.amqp
-
An exception that wraps an exception thrown by the server in a
request/reply scenario.
- AmqpRemoteException(Throwable) - Constructor for exception org.springframework.amqp.AmqpRemoteException
-
- 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 Base64-based name.
- AnonymousQueue(Map<String, Object>) - Constructor for class org.springframework.amqp.core.AnonymousQueue
-
Construct a queue with a Base64-based 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
(e.g.
- AnonymousQueue.NamingStrategy - Interface in org.springframework.amqp.core
-
A strategy to name anonymous queues.
- AnonymousQueue.UUIDNamingStrategy - Class in org.springframework.amqp.core
-
Generates names using UUID.randomUUID().
- APP_ID - Static variable in class org.springframework.amqp.support.AmqpHeaders
-
- AsyncAmqpTemplate - Interface in org.springframework.amqp.core
-
Classes implementing this interface can perform asynchronous send and
receive operations.
- autoDelete() - Method in class org.springframework.amqp.core.ExchangeBuilder
-
Set the auto delete flag.
- autoDelete() - Method in class org.springframework.amqp.core.QueueBuilder
-
The final queue will auto delete.
- 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
-
- ContentTypeDelegatingMessageConverter() - Constructor for class org.springframework.amqp.support.converter.ContentTypeDelegatingMessageConverter
-
- 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.
- convertSendAndReceive(Object) - Method in interface org.springframework.amqp.core.AsyncAmqpTemplate
-
Convert the object to a message and send it to the default exchange with the
default routing key.
- convertSendAndReceive(String, Object) - Method in interface org.springframework.amqp.core.AsyncAmqpTemplate
-
Convert the object to a message and send it to the default exchange with the
provided routing key.
- convertSendAndReceive(String, String, Object) - Method in interface org.springframework.amqp.core.AsyncAmqpTemplate
-
Convert the object to a message and send it to the provided exchange and
routing key.
- convertSendAndReceive(Object, MessagePostProcessor) - Method in interface org.springframework.amqp.core.AsyncAmqpTemplate
-
Convert the object to a message and send it to the default exchange with the
default routing key after invoking the
MessagePostProcessor.
- convertSendAndReceive(String, Object, MessagePostProcessor) - Method in interface org.springframework.amqp.core.AsyncAmqpTemplate
-
Convert the object to a message and send it to the default exchange with the
provided routing key after invoking the
MessagePostProcessor.
- convertSendAndReceive(String, String, Object, MessagePostProcessor) - Method in interface org.springframework.amqp.core.AsyncAmqpTemplate
-
Convert the object to a message and send it to the provided exchange and
routing key after invoking the
MessagePostProcessor.
- convertSendAndReceiveAsType(Object, ParameterizedTypeReference<T>) - Method in interface org.springframework.amqp.core.AmqpTemplate
-
Basic RPC pattern with conversion.
- convertSendAndReceiveAsType(String, Object, ParameterizedTypeReference<T>) - Method in interface org.springframework.amqp.core.AmqpTemplate
-
Basic RPC pattern with conversion.
- convertSendAndReceiveAsType(String, String, Object, ParameterizedTypeReference<T>) - Method in interface org.springframework.amqp.core.AmqpTemplate
-
Basic RPC pattern with conversion.
- convertSendAndReceiveAsType(Object, MessagePostProcessor, ParameterizedTypeReference<T>) - Method in interface org.springframework.amqp.core.AmqpTemplate
-
Basic RPC pattern with conversion.
- convertSendAndReceiveAsType(String, Object, MessagePostProcessor, ParameterizedTypeReference<T>) - Method in interface org.springframework.amqp.core.AmqpTemplate
-
Basic RPC pattern with conversion.
- convertSendAndReceiveAsType(String, String, Object, MessagePostProcessor, ParameterizedTypeReference<T>) - Method in interface org.springframework.amqp.core.AmqpTemplate
-
Basic RPC pattern with conversion.
- convertSendAndReceiveAsType(Object, ParameterizedTypeReference<C>) - Method in interface org.springframework.amqp.core.AsyncAmqpTemplate
-
Convert the object to a message and send it to the default exchange with the
default routing key.
- convertSendAndReceiveAsType(String, Object, ParameterizedTypeReference<C>) - Method in interface org.springframework.amqp.core.AsyncAmqpTemplate
-
Convert the object to a message and send it to the default exchange with the
provided routing key.
- convertSendAndReceiveAsType(String, String, Object, ParameterizedTypeReference<C>) - Method in interface org.springframework.amqp.core.AsyncAmqpTemplate
-
Convert the object to a message and send it to the provided exchange and
routing key.
- convertSendAndReceiveAsType(Object, MessagePostProcessor, ParameterizedTypeReference<C>) - Method in interface org.springframework.amqp.core.AsyncAmqpTemplate
-
Convert the object to a message and send it to the default exchange with the
default routing key after invoking the
MessagePostProcessor.
- convertSendAndReceiveAsType(String, Object, MessagePostProcessor, ParameterizedTypeReference<C>) - Method in interface org.springframework.amqp.core.AsyncAmqpTemplate
-
Convert the object to a message and send it to the default exchange with the
provided routing key after invoking the
MessagePostProcessor.
- convertSendAndReceiveAsType(String, String, Object, MessagePostProcessor, ParameterizedTypeReference<C>) - Method in interface org.springframework.amqp.core.AsyncAmqpTemplate
-
Convert the object to a message and send it to the provided exchange and
routing key after invoking the
MessagePostProcessor.
- 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 - Interface in org.springframework.amqp.support
-
A marker interface for data used to correlate information about sent messages.
- CORRELATION_ID - Static variable in class org.springframework.amqp.support.AmqpHeaders
-
- CorrelationAwareMessagePostProcessor - Interface in org.springframework.amqp.core
-
- 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.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
-
- generateName() - Method in class org.springframework.amqp.core.AnonymousQueue.Base64UrlNamingStrategy
-
- generateName() - Method in interface org.springframework.amqp.core.AnonymousQueue.NamingStrategy
-
- generateName() - Method in class org.springframework.amqp.core.AnonymousQueue.UUIDNamingStrategy
-
- GenericArgumentsConfigurer(BindingBuilder.GenericExchangeRoutingKeyConfigurer, String) - Constructor for class org.springframework.amqp.core.BindingBuilder.GenericArgumentsConfigurer
-
- get() - Method in class org.springframework.amqp.utils.MapBuilder
-
- 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.AbstractBuilder
-
- 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
-
The name of the header that contains the type id.
- getClassLoader() - Method in class org.springframework.amqp.support.converter.AbstractJavaTypeMapper
-
- getClassLoader() - Method in class org.springframework.amqp.support.converter.AbstractJsonMessageConverter
-
- 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
-
Get the stream.
- 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
-
Get the correlation id.
- getCorrelationId() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
-
- getCorrelationIdString() - Method in class org.springframework.amqp.core.MessageProperties
-
- getCorrelationIdString() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
-
- 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
-
Get the stream.
- 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
-
Get the encoding.
- getEncoding() - Method in class org.springframework.amqp.support.postprocessor.AbstractDecompressingPostProcessor
-
Get the encoding.
- 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.
- 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
-
- 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
-
Return the server's most recent estimate of the number of messages remaining on the queue.
- 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
-
- getOrCreateArguments() - Method in class org.springframework.amqp.core.AbstractBuilder
-
Return the arguments map, after creating one if necessary.
- 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
-
- getReceivedUserId() - Method in class org.springframework.amqp.core.MessageProperties
-
Return the user id from an incoming message.
- getReceivedUserId() - 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
-
Return the type precedence.
- 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
-
- MapBuilder<B extends MapBuilder<B,K,V>,K,V> - Class in org.springframework.amqp.utils
-
A Builder pattern implementation for a Map.
- MapBuilder() - Constructor for class org.springframework.amqp.utils.MapBuilder
-
- MarshallingMessageConverter - Class in org.springframework.amqp.support.converter
-
- 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
-
- 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
-
Message converter interface.
- 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
-
Utilities for message post processors.
- 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.
- RAW_MESSAGE - Static variable in class org.springframework.amqp.support.AmqpHeaders
-
The received raw message before conversion; this header usually only appears in
an ErrorMessage.
- receive() - Method in interface org.springframework.amqp.core.AmqpTemplate
-
Receive a message if there is one from a default queue.
- receive(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.
- receiveAndConvert(ParameterizedTypeReference<T>) - Method in interface org.springframework.amqp.core.AmqpTemplate
-
Receive a message if there is one from a default queue and convert it to a Java
object.
- receiveAndConvert(String, ParameterizedTypeReference<T>) - Method in interface org.springframework.amqp.core.AmqpTemplate
-
Receive a message if there is one from a specific queue and convert it to a Java
object.
- receiveAndConvert(long, ParameterizedTypeReference<T>) - Method in interface org.springframework.amqp.core.AmqpTemplate
-
Receive a message if there is one from a default queue and convert it to a Java
object.
- receiveAndConvert(String, long, ParameterizedTypeReference<T>) - Method in interface org.springframework.amqp.core.AmqpTemplate
-
Receive a message if there is one from a specific queue and convert it to a Java
object.
- 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
-
- receiveAndReply(String, ReceiveAndReplyCallback<R, S>, ReplyToAddressCallback<S>) - Method in interface org.springframework.amqp.core.AmqpTemplate
-
- 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
-
- RECEIVED_DELAY - Static variable in class org.springframework.amqp.support.AmqpHeaders
-
- RECEIVED_DELIVERY_MODE - Static variable in class org.springframework.amqp.support.AmqpHeaders
-
- RECEIVED_EXCHANGE - Static variable in class org.springframework.amqp.support.AmqpHeaders
-
- RECEIVED_ROUTING_KEY - Static variable in class org.springframework.amqp.support.AmqpHeaders
-
- RECEIVED_USER_ID - Static variable in class org.springframework.amqp.support.AmqpHeaders
-
- REDELIVERED - Static variable in class org.springframework.amqp.support.AmqpHeaders
-
- RemoteInvocationAwareMessageConverterAdapter - Class in org.springframework.amqp.support.converter
-
A delegating adapter that unwraps RemoteInvocationResult after invoking
the delegate to convert from a message.
- RemoteInvocationAwareMessageConverterAdapter() - Constructor for class org.springframework.amqp.support.converter.RemoteInvocationAwareMessageConverterAdapter
-
- RemoteInvocationAwareMessageConverterAdapter(MessageConverter) - Constructor for class org.springframework.amqp.support.converter.RemoteInvocationAwareMessageConverterAdapter
-
- 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
-
- removeDelegate(String) - Method in class org.springframework.amqp.support.converter.ContentTypeDelegatingMessageConverter
-
Remove the delegate for the content type.
- 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
-
- 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
-
- 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.
- sendAndReceive(Message) - Method in interface org.springframework.amqp.core.AsyncAmqpTemplate
-
Send a message to the default exchange with the default routing key.
- sendAndReceive(String, Message) - Method in interface org.springframework.amqp.core.AsyncAmqpTemplate
-
Send a message to the default exchange with the supplied routing key.
- sendAndReceive(String, String, Message) - Method in interface org.springframework.amqp.core.AsyncAmqpTemplate
-
Send a message to the supplied exchange and routing key.
- 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.AbstractJavaTypeMapper
-
- setBeanClassLoader(ClassLoader) - Method in class org.springframework.amqp.support.converter.AbstractJsonMessageConverter
-
- setBeanClassLoader(ClassLoader) - Method in class org.springframework.amqp.support.converter.Jackson2JsonMessageConverter
-
- setBeanClassLoader(ClassLoader) - Method in class org.springframework.amqp.support.converter.RemoteInvocationAwareMessageConverterAdapter
-
- 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(String) - Method in class org.springframework.amqp.core.MessageBuilderSupport
-
- setCorrelationId(String) - Method in class org.springframework.amqp.core.MessageProperties
-
Set the correlation id.
- setCorrelationIdIfAbsent(String) - Method in class org.springframework.amqp.core.MessageBuilderSupport
-
- setCorrelationIdString(String) - Method in class org.springframework.amqp.core.MessageBuilderSupport
-
- setCorrelationIdString(String) - Method in class org.springframework.amqp.core.MessageProperties
-
- setCorrelationIdStringIfAbsent(String) - Method in class org.springframework.amqp.core.MessageBuilderSupport
-
- 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
-
- setDefaultMapClass(Class<?>) - Method in class org.springframework.amqp.support.converter.DefaultClassMapper
-
Set the type of Map to use.
- setDefaultType(Class<?>) - Method in class org.springframework.amqp.support.converter.DefaultClassMapper
-
- 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
-
- setFinalRetryForMessageWithNoId(boolean) - Method in class org.springframework.amqp.core.MessageProperties
-
- 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
-
Set a map of type Ids (in the
"__TypeId__" header) to
classes.
- 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
-
- 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
-
Set the message count.
- 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
-
Set the order.
- setOrder(int) - Method in class org.springframework.amqp.support.postprocessor.AbstractDecompressingPostProcessor
-
Set the order.
- setOrder(int) - Method in class org.springframework.amqp.support.postprocessor.DelegatingDecompressingPostProcessor
-
Set the order.
- setPayloadConverter(MessageConverter) - Method in class org.springframework.amqp.support.converter.MessagingMessageConverter
-
- 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
-
- setReceivedUserId(String) - Method in class org.springframework.amqp.core.MessageProperties
-
- 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
-
- setTrustedPackages(String...) - Method in class org.springframework.amqp.support.converter.DefaultClassMapper
-
Specify a set of packages to trust during deserialization.
- setTrustedPackages(String...) - Method in class org.springframework.amqp.support.converter.DefaultJackson2JavaTypeMapper
-
Specify a set of packages to trust during deserialization.
- 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
-
- 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
-
- SmartMessageConverter - Interface in org.springframework.amqp.support.converter
-
- 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
-
System exchange.