- 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
-
- AbstractDeclarable(Map<String, Object>) - Constructor for class org.springframework.amqp.core.AbstractDeclarable
-
Construct an instance with the supplied arguments, or an empty map if null.
- 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.
- AbstractJackson2MessageConverter - Class in org.springframework.amqp.support.converter
-
Abstract Jackson2 message converter.
- AbstractJackson2MessageConverter(ObjectMapper, MimeType, String...) - Constructor for class org.springframework.amqp.support.converter.AbstractJackson2MessageConverter
-
Construct with the provided ObjectMapper instance.
- AbstractJavaTypeMapper - Class in org.springframework.amqp.support.converter
-
Abstract type mapper.
- AbstractJavaTypeMapper() - Constructor for class org.springframework.amqp.support.converter.AbstractJavaTypeMapper
-
- AbstractMessageConverter - Class in org.springframework.amqp.support.converter
-
- AbstractMessageConverter() - Constructor for class org.springframework.amqp.support.converter.AbstractMessageConverter
-
- acceptIfCondition(boolean, T, Consumer<T>) - Method in class org.springframework.amqp.utils.JavaUtils
-
Invoke Consumer.accept(Object) with the value if the condition is true.
- acceptIfCondition(boolean, T1, T2, BiConsumer<T1, T2>) - Method in class org.springframework.amqp.utils.JavaUtils
-
Invoke BiConsumer.accept(Object, Object) with the arguments if the
condition is true.
- acceptIfHasText(String, Consumer<String>) - Method in class org.springframework.amqp.utils.JavaUtils
-
Invoke Consumer.accept(Object) with the value if it is not null or empty.
- acceptIfHasText(T, String, BiConsumer<T, String>) - Method in class org.springframework.amqp.utils.JavaUtils
-
Invoke BiConsumer.accept(Object, Object) with the arguments if the value
argument is not null or empty.
- acceptIfNotNull(T, Consumer<T>) - Method in class org.springframework.amqp.utils.JavaUtils
-
Invoke Consumer.accept(Object) with the value if it is not null.
- acceptIfNotNull(T1, T2, BiConsumer<T1, T2>) - Method in class org.springframework.amqp.utils.JavaUtils
-
Invoke BiConsumer.accept(Object, Object) with the arguments if the t2
argument is not null.
- AcknowledgeMode - Enum in org.springframework.amqp.core
-
Acknowledgment modes supported by the listener container.
- addAllowedListPatterns(String...) - Static method in class org.springframework.amqp.core.Message
-
Add patterns to the allowed list of permissible package/class name patterns for
deserialization in
Message.toString().
- addAllowedListPatterns(String...) - Method in class org.springframework.amqp.support.converter.AllowedListDeserializingMessageConverter
-
Add package/class patterns to the allowed list.
- addArgument(String, Object) - Method in class org.springframework.amqp.core.AbstractDeclarable
-
- addArgument(String, Object) - Method in interface org.springframework.amqp.core.Declarable
-
Add an argument to the declarable.
- 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.
- addHeader(MessageProperties, String, Class<?>) - Method in class org.springframework.amqp.support.converter.AbstractJavaTypeMapper
-
- 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.
- ADDRESS - Static variable in class org.springframework.amqp.support.SendRetryContextAccessor
-
Key for the Address we tried to send to.
- addTrustedPackages(String...) - Method in class org.springframework.amqp.support.converter.DefaultJackson2JavaTypeMapper
-
- addTrustedPackages(String...) - Method in interface org.springframework.amqp.support.converter.Jackson2JavaTypeMapper
-
Add trusted packages.
- admins(Object...) - Method in class org.springframework.amqp.core.ExchangeBuilder
-
Admin instances, or admin bean names that should declare this exchange.
- 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
-
- AllowedListDeserializingMessageConverter - Class in org.springframework.amqp.support.converter
-
MessageConverters that potentially use Java deserialization.
- AllowedListDeserializingMessageConverter() - Constructor for class org.springframework.amqp.support.converter.AllowedListDeserializingMessageConverter
-
- alternate(String) - Method in class org.springframework.amqp.core.ExchangeBuilder
-
- 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.
- 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 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
-
Deprecated.
- AmqpMessageReturnedException(String, ReturnedMessage) - 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) - Constructor for exception org.springframework.amqp.AmqpRejectAndDontRequeueException
-
Construct an instance with the supplied argument.
- AmqpRejectAndDontRequeueException(Throwable) - Constructor for exception org.springframework.amqp.AmqpRejectAndDontRequeueException
-
Construct an instance with the supplied argument.
- AmqpRejectAndDontRequeueException(String, Throwable) - Constructor for exception org.springframework.amqp.AmqpRejectAndDontRequeueException
-
Construct an instance with the supplied arguments.
- AmqpRejectAndDontRequeueException(String, boolean, Throwable) - Constructor for exception org.springframework.amqp.AmqpRejectAndDontRequeueException
-
Construct an instance with the supplied arguments.
- 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
-
- AmqpResourceNotAvailableException - Exception in org.springframework.amqp
-
- AmqpResourceNotAvailableException(String) - Constructor for exception org.springframework.amqp.AmqpResourceNotAvailableException
-
- AmqpResourceNotAvailableException(Throwable) - Constructor for exception org.springframework.amqp.AmqpResourceNotAvailableException
-
- AmqpResourceNotAvailableException(String, Throwable) - Constructor for exception org.springframework.amqp.AmqpResourceNotAvailableException
-
- 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(NamingStrategy) - Constructor for class org.springframework.amqp.core.AnonymousQueue
-
Construct a queue with a name provided by the supplied naming strategy.
- 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.
- 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
-
- checkAllowedList(Class<?>) - Method in class org.springframework.amqp.support.converter.AllowedListDeserializingMessageConverter
-
- checkAllowedList(Class<?>, Set<String>) - Static method in class org.springframework.amqp.utils.SerializationUtils
-
Verify that the class is in the allowed list.
- 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.
- clone() - Method in class org.springframework.amqp.core.Queue
-
- 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.
- containerAckMode(AcknowledgeMode) - Method in interface org.springframework.amqp.core.MessageListener
-
Called by the container to inform the listener of its acknowledgement
mode.
- 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_CONVERTER_WINS - Static variable in class org.springframework.amqp.support.AmqpHeaders
-
- 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.
- convert(Message, Type) - Method in class org.springframework.amqp.support.converter.ProjectingMessageConverter
-
- 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.core
-
A marker interface for data used to correlate information about sent messages.
- 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.AbstractJackson2MessageConverter
-
- createMessage(Object, MessageProperties, Type) - Method in class org.springframework.amqp.support.converter.AbstractJackson2MessageConverter
-
- createMessage(Object, MessageProperties, Type) - 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.AbstractMessageConverter
-
Crate a message from the payload object and message properties provided.
- 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.Base64UrlNamingStrategy
-
- generateName() - Method in interface org.springframework.amqp.core.NamingStrategy
-
- generateName() - Method in class org.springframework.amqp.core.UUIDNamingStrategy
-
- GenericArgumentsConfigurer(BindingBuilder.GenericExchangeRoutingKeyConfigurer, String) - Constructor for class org.springframework.amqp.core.BindingBuilder.GenericArgumentsConfigurer
-
- get() - Method in class org.springframework.amqp.utils.MapBuilder
-
- getActualName() - Method in class org.springframework.amqp.core.Queue
-
Return the name provided to the constructor or the broker-generated name
if that name is an empty String.
- getAddress(RetryContext) - Static method in class org.springframework.amqp.support.SendRetryContextAccessor
-
Retrieve the
Address from the context.
- 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.AbstractDeclarable
-
- getArguments() - Method in interface org.springframework.amqp.core.Exchange
-
A map of arguments used to declare the exchange.
- 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.AbstractJackson2MessageConverter
-
- getClassLoader() - Method in class org.springframework.amqp.support.converter.AbstractJavaTypeMapper
-
- getClassMapper() - Method in class org.springframework.amqp.support.converter.AbstractJackson2MessageConverter
-
- 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.DeflaterPostProcessor
-
- getCompressorStream(OutputStream) - Method in class org.springframework.amqp.support.postprocessor.GZipPostProcessor
-
- getCompressorStream(OutputStream) - Method in class org.springframework.amqp.support.postprocessor.ZipPostProcessor
-
- getConsumerCount() - Method in class org.springframework.amqp.core.QueueInformation
-
- 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
-
- getDeclarables() - Method in class org.springframework.amqp.core.Declarables
-
- getDeclarablesByType(Class<T>) - Method in class org.springframework.amqp.core.Declarables
-
Return the elements that are instances of the provided class.
- 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.InflaterPostProcessor
-
- getDecompressorStream(InputStream) - Method in class org.springframework.amqp.support.postprocessor.UnzipPostProcessor
-
- getDefaultCharset() - Method in class org.springframework.amqp.support.converter.AbstractJackson2MessageConverter
-
- 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.DeflaterPostProcessor
-
- 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.InflaterPostProcessor
-
- getEncoding() - Method in class org.springframework.amqp.support.postprocessor.UnzipPostProcessor
-
- getEncoding() - Method in class org.springframework.amqp.support.postprocessor.ZipPostProcessor
-
- getExchange() - Method in exception org.springframework.amqp.core.AmqpMessageReturnedException
-
- getExchange() - Method in class org.springframework.amqp.core.Binding
-
- getExchange() - Method in class org.springframework.amqp.core.ReturnedMessage
-
Get the exchange.
- getExchangeName() - Method in class org.springframework.amqp.core.Address
-
- getExpiration() - Method in class org.springframework.amqp.core.MessageProperties
-
- getExpiration() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
-
- getHeader(String) - Method in class org.springframework.amqp.core.MessageProperties
-
Typed getter for a header.
- getHeaderMapper() - Method in class org.springframework.amqp.support.converter.MessagingMessageConverter
-
- 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.
- getInferredType(MessageProperties) - Method in class org.springframework.amqp.support.converter.DefaultJackson2JavaTypeMapper
-
- getInferredType(MessageProperties) - Method in interface org.springframework.amqp.support.converter.Jackson2JavaTypeMapper
-
Return the inferred type, if the type precedence is inferred and the
header is present.
- getJavaTypeMapper() - Method in class org.springframework.amqp.support.converter.AbstractJackson2MessageConverter
-
- getKeyClassIdFieldName() - Method in class org.springframework.amqp.support.converter.AbstractJavaTypeMapper
-
- getLevel() - Method in class org.springframework.amqp.support.postprocessor.AbstractDeflaterPostProcessor
-
Get the deflater compression level.
- getMessage() - Method in class org.springframework.amqp.core.ReturnedMessage
-
Get the message.
- getMessage(RetryContext) - Static method in class org.springframework.amqp.support.SendRetryContextAccessor
-
Retrieve the
Message from the context.
- 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.core.QueueInformation
-
- 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
-
Return the name provided in the constructor.
- getName() - Method in class org.springframework.amqp.core.QueueInformation
-
- 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
-
- getPublishSequenceNumber() - Method in class org.springframework.amqp.core.MessageProperties
-
Return the publish sequence number if publisher confirms are enabled; set by the template.
- getQueueInfo(String) - Method in interface org.springframework.amqp.core.AmqpAdmin
-
Returns information about the queue, if it exists.
- getQueueProperties(String) - Method in interface org.springframework.amqp.core.AmqpAdmin
-
Returns an implementation-specific Map of properties if the queue exists.
- 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
-
- getReplyCode() - Method in class org.springframework.amqp.core.ReturnedMessage
-
Get the reply code.
- getReplyText() - Method in exception org.springframework.amqp.core.AmqpMessageReturnedException
-
- getReplyText() - Method in class org.springframework.amqp.core.ReturnedMessage
-
Get the reply text.
- 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
-
- getReturned() - Method in exception org.springframework.amqp.core.AmqpMessageReturnedException
-
- 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.core.ReturnedMessage
-
Get the routing key.
- 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 @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.AbstractJackson2MessageConverter
-
Return the type precedence.
- getTypePrecedence() - Method in class org.springframework.amqp.support.converter.DefaultJackson2JavaTypeMapper
-
Return the precedence.
- getTypePrecedence() - Method in interface org.springframework.amqp.support.converter.Jackson2JavaTypeMapper
-
Get the type precedence.
- getUserId() - Method in class org.springframework.amqp.core.MessageProperties
-
- getUserId() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
-
- getValue() - Method in enum org.springframework.amqp.core.QueueBuilder.MasterLocator
-
- getValue() - Method in enum org.springframework.amqp.core.QueueBuilder.Overflow
-
- getXDeathHeader() - Method in class org.springframework.amqp.core.MessageProperties
-
Return the x-death header.
- 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
-
- ignoreDeclarationExceptions() - Method in class org.springframework.amqp.core.ExchangeBuilder
-
Switch on ignore exceptions such as mismatched properties when declaring.
- 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
-
- ImmediateRequeueAmqpException - Exception in org.springframework.amqp
-
- ImmediateRequeueAmqpException(String) - Constructor for exception org.springframework.amqp.ImmediateRequeueAmqpException
-
- ImmediateRequeueAmqpException(Throwable) - Constructor for exception org.springframework.amqp.ImmediateRequeueAmqpException
-
- ImmediateRequeueAmqpException(String, Throwable) - Constructor for exception org.springframework.amqp.ImmediateRequeueAmqpException
-
- InflaterPostProcessor - Class in org.springframework.amqp.support.postprocessor
-
A post processor that uses a InflaterInputStream to decompress the
message body.
- InflaterPostProcessor() - Constructor for class org.springframework.amqp.support.postprocessor.InflaterPostProcessor
-
- InflaterPostProcessor(boolean) - Constructor for class org.springframework.amqp.support.postprocessor.InflaterPostProcessor
-
- initialize() - Method in interface org.springframework.amqp.core.AmqpAdmin
-
Initialize the admin.
- INSTANCE - Static variable in class org.springframework.amqp.utils.JavaUtils
-
The singleton instance of this utility class.
- internal() - Method in class org.springframework.amqp.core.ExchangeBuilder
-
Set the internal flag.
- 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.
- isFinalRetryForMessageWithNoId() - Method in class org.springframework.amqp.core.MessageProperties
-
- 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.
- isLastInBatch() - Method in class org.springframework.amqp.core.MessageProperties
-
When true; the message having these properties is the last message from a batch.
- isManual() - Method in enum org.springframework.amqp.core.AcknowledgeMode
-
- isRedelivered() - Method in class org.springframework.amqp.core.MessageProperties
-
- isRejectManual() - Method in exception org.springframework.amqp.AmqpRejectAndDontRequeueException
-
True if the container should reject the message, even with manual acks.
- isSingleton() - Method in class org.springframework.amqp.remoting.client.AmqpProxyFactoryBean
-
- isTransactionAllowed() - Method in enum org.springframework.amqp.core.AcknowledgeMode
-
- isTypeMapperSet() - Method in class org.springframework.amqp.support.converter.AbstractJackson2MessageConverter
-
Whether or not an explicit java type mapper has been provided.
- isUseProjectionForInterfaces() - Method in class org.springframework.amqp.support.converter.AbstractJackson2MessageConverter
-
- 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.
- masterLocator(QueueBuilder.MasterLocator) - Method in class org.springframework.amqp.core.QueueBuilder
-
Set the master locator mode which determines which node a queue master will be
located on a cluster of nodes.
- match() - Method in class org.springframework.amqp.core.BindingBuilder.HeadersExchangeMapConfigurer.HeadersExchangeMapBindingCreator
-
- matches(Object) - Method in class org.springframework.amqp.core.BindingBuilder.HeadersExchangeMapConfigurer.HeadersExchangeSingleValueBindingCreator
-
- maxLength(int) - Method in class org.springframework.amqp.core.QueueBuilder
-
Set the number of (ready) messages allowed in the queue before it starts to drop
them.
- maxLengthBytes(int) - Method in class org.springframework.amqp.core.QueueBuilder
-
Set the total aggregate body size allowed in the queue before it starts to drop
them.
- maxPriority(int) - Method in class org.springframework.amqp.core.QueueBuilder
-
Set the maximum number if priority levels for the queue to support; if not set, the
queue will not support message priorities.
- 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 - Static variable in class org.springframework.amqp.support.SendRetryContextAccessor
-
Key for the message we tried to send.
- 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
-
Used in several places in the framework, such as
AmqpTemplate#convertAndSend(Object, MessagePostProcessor) where it can be used
to add/modify headers or properties after the message conversion has been performed.
- 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
-
- removeArgument(String) - Method in class org.springframework.amqp.core.AbstractDeclarable
-
- removeArgument(String) - Method in interface org.springframework.amqp.core.Declarable
-
Remove an argument from the declarable.
- 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
-
- ReturnedMessage - Class in org.springframework.amqp.core
-
Returned message and its metadata.
- ReturnedMessage(Message, int, String, String, String) - Constructor for class org.springframework.amqp.core.ReturnedMessage
-
- 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.
- SendRetryContextAccessor - Class in org.springframework.amqp.support
-
Type safe accessor for retried message sending.
- 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
-
- setActualName(String) - Method in class org.springframework.amqp.core.Queue
-
Set the name from the DeclareOk.
- setAdminsThatShouldDeclare(Object...) - Method in class org.springframework.amqp.core.AbstractDeclarable
-
- setAdminsThatShouldDeclare(Object...) - Method in interface org.springframework.amqp.core.Declarable
-
The AmqpAdmins that should declare this object; default is
all admins.
- setAllowedListPatterns(List<String>) - Method in class org.springframework.amqp.support.converter.AllowedListDeserializingMessageConverter
-
Set simple patterns for allowable packages/classes for deserialization.
- setAlwaysConvertToInferredType(boolean) - Method in class org.springframework.amqp.support.converter.AbstractJackson2MessageConverter
-
When false (default), fall back to type id headers if the type (or contents of a container
type) is abstract.
- 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
-
- setAssumeSupportedContentType(boolean) - Method in class org.springframework.amqp.support.converter.AbstractJackson2MessageConverter
-
By default the supported content type is assumed when there is no contentType
property or it is set to the default ('application/octet-stream').
- setBeanClassLoader(ClassLoader) - Method in class org.springframework.amqp.support.converter.AbstractJackson2MessageConverter
-
- setBeanClassLoader(ClassLoader) - Method in class org.springframework.amqp.support.converter.AbstractJavaTypeMapper
-
- 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.AbstractJackson2MessageConverter
-
- 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
-
- 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
-
- setCopyProperties(boolean) - Method in class org.springframework.amqp.support.postprocessor.AbstractCompressingPostProcessor
-
Flag to indicate if
MessageProperties should be used as is or cloned for new message
after compression.
- 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
-
- 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.AbstractJackson2MessageConverter
-
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.
- setDefaultEncoding(String) - Static method in class org.springframework.amqp.core.Message
-
- 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.AbstractJackson2MessageConverter
-
- setLastInBatch(boolean) - Method in class org.springframework.amqp.core.MessageProperties
-
Set to true to indicate these properties are for the last message in a batch.
- 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.
- setMasterLocator(String) - Method in class org.springframework.amqp.core.Queue
-
Set the master locator strategy argument for this queue.
- 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
-
- setPublishSequenceNumber(long) - Method in class org.springframework.amqp.core.MessageProperties
-
Set the publish sequence number, if publisher confirms are enabled; set by the template.
- 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 @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.AbstractJackson2MessageConverter
-
Set the precedence for evaluating type information in message properties.
- setTypePrecedence(Jackson2JavaTypeMapper.TypePrecedence) - Method in class org.springframework.amqp.support.converter.DefaultJackson2JavaTypeMapper
-
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.
- setUseProjectionForInterfaces(boolean) - Method in class org.springframework.amqp.support.converter.AbstractJackson2MessageConverter
-
Set to true to use Spring Data projection to create the object if the inferred
parameter type is an interface.
- 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
-
- 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
-
- singleActiveConsumer() - Method in class org.springframework.amqp.core.QueueBuilder
-
Set the 'x-single-active-consumer' queue argument.
- 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
-
- suppressDeclaration() - Method in class org.springframework.amqp.core.ExchangeBuilder
-
Switch to disable declaration of the exchange by any admin.
- SYSTEM - Static variable in class org.springframework.amqp.core.ExchangeTypes
-
System exchange.
- 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.core.QueueBuilder.MasterLocator
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum org.springframework.amqp.core.QueueBuilder.Overflow
-
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.core.QueueBuilder.MasterLocator
-
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.QueueBuilder.Overflow
-
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
-