A B C D E F G H I J K L M N O P Q R S T U V W X Z _
All Classes All Packages
All Classes All Packages
A
- abort() - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- abort(int, String) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- AbstractAdaptableMessageListener - Class in org.springframework.amqp.rabbit.listener.adapter
-
An abstract
MessageListener
adapter providing the necessary infrastructure to extract the payload of aMessage
. - AbstractAdaptableMessageListener() - Constructor for class org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener
- AbstractAdaptableMessageListener.ReplyExpressionRoot - Class in org.springframework.amqp.rabbit.listener.adapter
-
Root object for reply expression evaluation.
- 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
-
Construct a post processor that will include the
MessageProperties.SPRING_AUTO_DECOMPRESS
header set to 'true'. - AbstractCompressingPostProcessor(boolean) - Constructor for class org.springframework.amqp.support.postprocessor.AbstractCompressingPostProcessor
-
Construct a post processor that will include (or not include) the
MessageProperties.SPRING_AUTO_DECOMPRESS
header. - AbstractConnectionFactory - Class in org.springframework.amqp.rabbit.connection
- AbstractConnectionFactory(ConnectionFactory) - Constructor for class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
-
Create a new AbstractConnectionFactory for the given target ConnectionFactory, with no publisher connection factory.
- AbstractConnectionFactory.AddressShuffleMode - Enum in org.springframework.amqp.rabbit.connection
-
The mode used to shuffle the addresses.
- AbstractDeclarable - Class in org.springframework.amqp.core
-
Base class for
Declarable
classes. - 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
-
Base class for post processors that decompress the message body if the
MessageProperties.SPRING_AUTO_DECOMPRESS
header is true or to optionally always decompress if the content encoding matchesAbstractDecompressingPostProcessor.getEncoding()
, or starts withAbstractDecompressingPostProcessor.getEncoding()
+ ":", in which case the encoding following the colon becomes the final content encoding of the decompressed message. - AbstractDecompressingPostProcessor() - Constructor for class org.springframework.amqp.support.postprocessor.AbstractDecompressingPostProcessor
-
Construct a post processor that will decompress the supported content encoding only if
MessageProperties.SPRING_AUTO_DECOMPRESS
header is present and true. - AbstractDecompressingPostProcessor(boolean) - Constructor for class org.springframework.amqp.support.postprocessor.AbstractDecompressingPostProcessor
-
Construct a post processor that will decompress the supported content encoding if
MessageProperties.SPRING_AUTO_DECOMPRESS
header is present and true or if alwaysDecompress is true. - AbstractDeflaterPostProcessor - Class in org.springframework.amqp.support.postprocessor
-
Base class for post processors based on
Deflater
. - AbstractDeflaterPostProcessor() - Constructor for class org.springframework.amqp.support.postprocessor.AbstractDeflaterPostProcessor
- AbstractDeflaterPostProcessor(boolean) - Constructor for class org.springframework.amqp.support.postprocessor.AbstractDeflaterPostProcessor
- AbstractExchange - Class in org.springframework.amqp.core
-
Common properties that describe all exchange types.
- AbstractExchange(String) - Constructor for class org.springframework.amqp.core.AbstractExchange
-
Construct a new durable, non-auto-delete Exchange with the provided name.
- AbstractExchange(String, boolean, boolean) - Constructor for class org.springframework.amqp.core.AbstractExchange
-
Construct a new Exchange, given a name, durability flag, auto-delete flag.
- AbstractExchange(String, boolean, boolean, Map<String, Object>) - Constructor for class org.springframework.amqp.core.AbstractExchange
-
Construct a new Exchange, given a name, durability flag, and auto-delete flag, and arguments.
- AbstractExchangeParser - Class in org.springframework.amqp.rabbit.config
- AbstractExchangeParser() - Constructor for class org.springframework.amqp.rabbit.config.AbstractExchangeParser
- 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
-
Convenient base class for
MessageConverter
implementations. - AbstractMessageConverter() - Constructor for class org.springframework.amqp.support.converter.AbstractMessageConverter
- AbstractMessageListenerContainer - Class in org.springframework.amqp.rabbit.listener
- AbstractMessageListenerContainer() - Constructor for class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- AbstractMessageListenerContainer.JavaLangErrorHandler - Interface in org.springframework.amqp.rabbit.listener
-
A handler for
Error
on the container thread(s). - AbstractMessageListenerContainer.SharedConnectionNotInitializedException - Exception in org.springframework.amqp.rabbit.listener
-
Exception that indicates that the initial setup of this container's shared Rabbit Connection failed.
- AbstractMessageListenerContainer.WrappedTransactionException - Exception in org.springframework.amqp.rabbit.listener
-
A runtime exception to wrap a
Throwable
. - AbstractRabbitListenerContainerFactory<C extends AbstractMessageListenerContainer> - Class in org.springframework.amqp.rabbit.config
-
RabbitListenerContainerFactory
for Spring's base container implementation. - AbstractRabbitListenerContainerFactory() - Constructor for class org.springframework.amqp.rabbit.config.AbstractRabbitListenerContainerFactory
- AbstractRabbitListenerEndpoint - Class in org.springframework.amqp.rabbit.listener
-
Base model for a Rabbit listener endpoint.
- AbstractRabbitListenerEndpoint() - Constructor for class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint
- AbstractRetryOperationsInterceptorFactoryBean - Class in org.springframework.amqp.rabbit.config
-
Convenient base class for interceptor factories.
- AbstractRetryOperationsInterceptorFactoryBean() - Constructor for class org.springframework.amqp.rabbit.config.AbstractRetryOperationsInterceptorFactoryBean
- AbstractRoutingConnectionFactory - Class in org.springframework.amqp.rabbit.connection
-
Abstract
ConnectionFactory
implementation that routesAbstractRoutingConnectionFactory.createConnection()
calls to one of various target ConnectionFactories based on a lookup key. - AbstractRoutingConnectionFactory() - Constructor for class org.springframework.amqp.rabbit.connection.AbstractRoutingConnectionFactory
- 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. - 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. - 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(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. - acceptIfNotNull(T, Consumer<T>) - Method in class org.springframework.amqp.utils.JavaUtils
-
Invoke
Consumer.accept(Object)
with the value if it is not null. - ackMode() - Method in annotation type org.springframework.amqp.rabbit.annotation.RabbitListener
-
Override the container factory
AcknowledgeMode
property. - AcknowledgeMode - Enum in org.springframework.amqp.core
-
Acknowledgment modes supported by the listener container.
- ActiveObjectCounter<T> - Class in org.springframework.amqp.rabbit.support
-
A mechanism to keep track of active objects.
- ActiveObjectCounter() - Constructor for class org.springframework.amqp.rabbit.support.ActiveObjectCounter
- actualInvokeListener(Channel, Object) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
-
Invoke the specified listener: either as standard MessageListener or (preferably) as SessionAwareMessageListener.
- actualStart() - Method in class org.springframework.amqp.rabbit.listener.DirectMessageListenerContainer
- add(T) - Method in class org.springframework.amqp.rabbit.support.ActiveObjectCounter
- addAfterReceivePostProcessors(MessagePostProcessor...) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
-
Add
MessagePostProcessor
that will be invoked immediately after aChannel#basicGet()
and before any message conversion is performed. - addAfterReceivePostProcessors(MessagePostProcessor...) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
-
Add
MessagePostProcessor
s that will be applied after message reception, before invoking theMessageListener
. - addAllowedListPatterns(String...) - Static method in class org.springframework.amqp.core.Message
-
Deprecated.toString() no longer deserializes the body.
- addAllowedListPatterns(String...) - Method in class org.springframework.amqp.support.converter.AllowedListDeserializingMessageConverter
-
Add package/class patterns to the allowed list.
- addAndStartConsumers(int) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer
-
Start up to delta consumers, limited by
SimpleMessageListenerContainer.setMaxConcurrentConsumers(int)
. - 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.
- addBeforePublishPostProcessors(MessagePostProcessor...) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
-
Add
MessagePostProcessor
that will be invoked immediately before invokingChannel#basicPublish()
, after all other processing, except creating theAMQP.BasicProperties
fromMessageProperties
. - addBlockedListener(BlockedListener) - Method in interface org.springframework.amqp.rabbit.connection.Connection
-
Add a
BlockedListener
. - addBlockedListener(BlockedListener) - Method in class org.springframework.amqp.rabbit.connection.SimpleConnection
- addChannel(Channel) - Method in class org.springframework.amqp.rabbit.connection.RabbitResourceHolder
- addChannel(Channel, Connection) - Method in class org.springframework.amqp.rabbit.connection.RabbitResourceHolder
- addChannelListener(ChannelListener) - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
- addConfirmListener(ConfirmCallback, ConfirmCallback) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- addConfirmListener(ConfirmListener) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- addConnection(Connection) - Method in class org.springframework.amqp.rabbit.connection.RabbitResourceHolder
- addConnectionListener(ConnectionListener) - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
- addConnectionListener(ConnectionListener) - Method in class org.springframework.amqp.rabbit.connection.AbstractRoutingConnectionFactory
- addConnectionListener(ConnectionListener) - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory
- addConnectionListener(ConnectionListener) - Method in interface org.springframework.amqp.rabbit.connection.ConnectionFactory
- addConnectionListener(ConnectionListener) - Method in class org.springframework.amqp.rabbit.connection.LocalizedQueueConnectionFactory
- addConnectionListener(ConnectionListener) - Method in class org.springframework.amqp.rabbit.connection.PooledChannelConnectionFactory
- addConnectionListener(ConnectionListener) - Method in class org.springframework.amqp.rabbit.connection.ThreadChannelConnectionFactory
- addConstructorArgBooleanValueIfAttributeDefined(BeanDefinitionBuilder, Element, String, boolean) - Static method in class org.springframework.amqp.rabbit.config.NamespaceUtils
-
Populates the bean definition constructor argument with the boolean value of that attribute if it is defined in the given element or else uses the default provided.
- addConstructorArgParentRefIfAttributeDefined(BeanDefinitionBuilder, Element, String) - Static method in class org.springframework.amqp.rabbit.config.NamespaceUtils
-
Populates the bean definition constructor argument with a reference to a bean with parent id equal to the attribute if it is defined in the given element.
- addConstructorArgRefIfAttributeDefined(BeanDefinitionBuilder, Element, String) - Static method in class org.springframework.amqp.rabbit.config.NamespaceUtils
-
Populates the bean definition constructor argument with a reference to a bean with id equal to the attribute if it is defined in the given element.
- addConstructorArgValueIfAttributeDefined(BeanDefinitionBuilder, Element, String) - Static method in class org.springframework.amqp.rabbit.config.NamespaceUtils
-
Populates the bean definition constructor argument with the value of that attribute if it is defined in the given element.
- addDecompressor(String, MessagePostProcessor) - Method in class org.springframework.amqp.support.postprocessor.DelegatingDecompressingPostProcessor
-
Add a message post processor to the map of decompressing MessageProcessors.
- addDelegate(String, MessageConverter) - Method in class org.springframework.amqp.support.converter.ContentTypeDelegatingMessageConverter
-
Add a delegate converter for the content type.
- addDelegate(ChannelListener) - Method in class org.springframework.amqp.rabbit.connection.CompositeChannelListener
- addDelegate(ConnectionListener) - Method in class org.springframework.amqp.rabbit.connection.CompositeConnectionListener
- addDeliveryTag(Channel, long) - Method in class org.springframework.amqp.rabbit.connection.RabbitResourceHolder
- addHeader(MessageProperties, String, Class<?>) - Method in class org.springframework.amqp.support.converter.AbstractJavaTypeMapper
- additionalHeaders(Message, Throwable) - Method in class org.springframework.amqp.rabbit.retry.RepublishMessageRecoverer
-
Subclasses can override this method to add more headers to the republished message.
- addListener(Channel) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
-
Add this template as a confirms listener for the provided channel.
- addListener(PublisherCallbackChannel.Listener) - Method in interface org.springframework.amqp.rabbit.connection.PublisherCallbackChannel
- addListener(PublisherCallbackChannel.Listener) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
-
Add the listener and return the internal map of pending confirmations for that listener.
- addPendingConfirm(PublisherCallbackChannel.Listener, long, PendingConfirm) - Method in interface org.springframework.amqp.rabbit.connection.PublisherCallbackChannel
-
Adds a pending confirmation to this channel's map.
- addPendingConfirm(PublisherCallbackChannel.Listener, long, PendingConfirm) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- addQueueNames(String...) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
-
Add queue(s) to this container's list of queues.
- addQueueNames(String...) - Method in class org.springframework.amqp.rabbit.listener.DirectMessageListenerContainer
- addQueueNames(String...) - Method in class org.springframework.amqp.rabbit.listener.DirectReplyToMessageListenerContainer
- addQueueNames(String...) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer
-
Add queue(s) to this container's list of queues.
- addQueueOrTagToMethodName(String, String) - Method in class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter
-
Add the mapping of a queue name or consumer tag to a method name.
- addQueues(Queue...) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
-
Add queue(s) to this container's list of queues.
- addQueues(Queue...) - Method in class org.springframework.amqp.rabbit.listener.DirectMessageListenerContainer
- addQueues(Queue...) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer
-
Add queue(s) to this container's list of queues.
- addRecoveryListenerIfNecessary(Channel) - Static method in class org.springframework.amqp.rabbit.connection.ClosingRecoveryListener
-
Add a listener if necessary so we can immediately close an autorecovered channel if necessary since the actual consumer will no longer exist.
- 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
- 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.
- addReturnListener(ReturnCallback) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
-
Added to the 5.0.x client.
- addReturnListener(ReturnListener) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- addShutdownListener(ShutdownListener) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- addTargetConnectionFactory(Object, ConnectionFactory) - Method in class org.springframework.amqp.rabbit.connection.AbstractRoutingConnectionFactory
-
Adds the given
ConnectionFactory
and associates it with the given lookup key. - addToBatch(String, String, Message) - Method in interface org.springframework.amqp.rabbit.batch.BatchingStrategy
-
Add a message to the batch and optionally release the batch.
- addToBatch(String, String, Message) - Method in class org.springframework.amqp.rabbit.batch.SimpleBatchingStrategy
- 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.
- adjustConsumers(int) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer
-
Adjust consumers depending on delta.
- adjustLogLevels(String, List<Class<?>>, List<String>, Level) - Static method in class org.springframework.amqp.rabbit.junit.JUnitUtils
- admin() - Method in annotation type org.springframework.amqp.rabbit.annotation.RabbitListener
-
Reference to a
AmqpAdmin
. - admins() - Method in annotation type org.springframework.amqp.rabbit.annotation.Exchange
-
Return a list of admin bean names that should declare this component.
- admins() - Method in annotation type org.springframework.amqp.rabbit.annotation.Queue
-
Return a list of admin bean names that should declare this component.
- admins() - Method in annotation type org.springframework.amqp.rabbit.annotation.QueueBinding
-
Return a list of admin bean names that should declare this component.
- admins(Object...) - Method in class org.springframework.amqp.core.ExchangeBuilder
-
Admin instances, or admin bean names that should declare this exchange.
- afterAll(ExtensionContext) - Method in class org.springframework.amqp.rabbit.junit.LogLevelsCondition
- afterAll(ExtensionContext) - Method in class org.springframework.amqp.rabbit.junit.RabbitAvailableCondition
- AfterCompletionFailedException - Exception in org.springframework.amqp.rabbit.connection
-
Represents a failure to commit or rollback when performing afterCompletion after the primary transaction completes.
- AfterCompletionFailedException(int, Throwable) - Constructor for exception org.springframework.amqp.rabbit.connection.AfterCompletionFailedException
-
Construct an instance with the provided properties.
- afterEach(ExtensionContext) - Method in class org.springframework.amqp.rabbit.junit.LogLevelsCondition
- afterEach(ExtensionContext) - Method in class org.springframework.amqp.rabbit.junit.RabbitAvailableCondition
- afterPropertiesSet() - Method in class org.springframework.amqp.rabbit.connection.AbstractRoutingConnectionFactory
- afterPropertiesSet() - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory
- afterPropertiesSet() - Method in class org.springframework.amqp.rabbit.connection.RabbitAccessor
- afterPropertiesSet() - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
- afterPropertiesSet() - Method in class org.springframework.amqp.rabbit.core.RabbitAdmin
-
If
autoStartup
is set to true, registers a callback on theConnectionFactory
to declare all exchanges and queues in the enclosing application context. - afterPropertiesSet() - Method in class org.springframework.amqp.rabbit.core.RabbitGatewaySupport
- afterPropertiesSet() - Method in class org.springframework.amqp.rabbit.core.RabbitMessagingTemplate
- afterPropertiesSet() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- afterPropertiesSet() - Method in interface org.springframework.amqp.rabbit.listener.MessageListenerContainer
- afterPropertiesSet() - Method in class org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistrar
- afterPropertiesSet() - Method in class org.springframework.amqp.rabbit.transaction.RabbitTransactionManager
-
Make sure the ConnectionFactory has been set.
- afterPropertiesSet() - Method in class org.springframework.amqp.remoting.client.AmqpProxyFactoryBean
-
Deprecated.
- afterPropertiesSet() - Method in class org.springframework.amqp.support.converter.DefaultClassMapper
- afterPropertiesSet() - Method in class org.springframework.amqp.support.converter.MarshallingMessageConverter
- afterPropertiesSet() - Method in class org.springframework.amqp.support.converter.MessagingMessageConverter
- afterSingletonsInstantiated() - Method in class org.springframework.amqp.rabbit.annotation.RabbitListenerAnnotationBeanPostProcessor
- 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.
- AmqpAppender - Class in org.springframework.amqp.rabbit.log4j2
-
A Log4j 2 appender that publishes logging events to an AMQP Exchange.
- AmqpAppender - Class in org.springframework.amqp.rabbit.logback
-
A Logback appender that publishes logging events to an AMQP Exchange.
- AmqpAppender() - Constructor for class org.springframework.amqp.rabbit.logback.AmqpAppender
- AmqpAppender(String, Filter, Layout<? extends Serializable>, boolean, Property[], AmqpAppender.AmqpManager, BlockingQueue<AmqpAppender.Event>) - Constructor for class org.springframework.amqp.rabbit.log4j2.AmqpAppender
-
Construct an instance with the provided properties.
- AmqpAppender.AmqpManager - Class in org.springframework.amqp.rabbit.log4j2
-
Manager class for the appender.
- AmqpAppender.Builder - Class in org.springframework.amqp.rabbit.log4j2
- AmqpAppender.Event - Class in org.springframework.amqp.rabbit.log4j2
-
Helper class to encapsulate a LoggingEvent, its MDC properties, and the number of retries.
- AmqpAppender.Event - Class in org.springframework.amqp.rabbit.logback
-
Small helper class to encapsulate a LoggingEvent, its MDC properties, and the number of retries.
- AmqpAppender.EventSender - Class in org.springframework.amqp.rabbit.log4j2
-
Helper class to actually send LoggingEvents asynchronously.
- AmqpAppender.EventSender - Class in org.springframework.amqp.rabbit.logback
-
Helper class to actually send LoggingEvents asynchronously.
- 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
-
Deprecated.will be removed in 3.0.0.
- AmqpClientInterceptor() - Constructor for class org.springframework.amqp.remoting.client.AmqpClientInterceptor
-
Deprecated.
- 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(String, Throwable) - Constructor for exception org.springframework.amqp.AmqpException
- AmqpException(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
-
Deprecated.will be removed in 3.0.0.
- AmqpInvokerServiceExporter() - Constructor for class org.springframework.amqp.remoting.service.AmqpInvokerServiceExporter
-
Deprecated.
- 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.
- AmqpManager(LoggerContext, String) - Constructor for class org.springframework.amqp.rabbit.log4j2.AmqpAppender.AmqpManager
- 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
- AmqpNackReceivedException - Exception in org.springframework.amqp.rabbit.core
-
An exception thrown when a negative acknowledgement received after publishing a message.
- AmqpNackReceivedException(String, Message) - Constructor for exception org.springframework.amqp.rabbit.core.AmqpNackReceivedException
-
Create an instance with the provided message and failed message.
- AmqpProxyFactoryBean - Class in org.springframework.amqp.remoting.client
-
Deprecated.will be removed in 3.0.0.
- AmqpProxyFactoryBean() - Constructor for class org.springframework.amqp.remoting.client.AmqpProxyFactoryBean
-
Deprecated.
- 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(String, boolean, Throwable) - Constructor for exception org.springframework.amqp.AmqpRejectAndDontRequeueException
-
Construct an instance with the supplied arguments.
- AmqpRejectAndDontRequeueException(String, Throwable) - Constructor for exception org.springframework.amqp.AmqpRejectAndDontRequeueException
-
Construct an instance with the supplied arguments.
- AmqpRejectAndDontRequeueException(Throwable) - Constructor for exception org.springframework.amqp.AmqpRejectAndDontRequeueException
-
Construct an instance with the supplied argument.
- 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
-
The
AmqpException
thrown when some resource can't be accessed. - AmqpResourceNotAvailableException(String) - Constructor for exception org.springframework.amqp.AmqpResourceNotAvailableException
- AmqpResourceNotAvailableException(String, Throwable) - Constructor for exception org.springframework.amqp.AmqpResourceNotAvailableException
- AmqpResourceNotAvailableException(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) - Constructor for exception org.springframework.amqp.AmqpTimeoutException
- AmqpTimeoutException(String, Throwable) - 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.
- answer(InvocationOnMock) - Method in class org.springframework.amqp.rabbit.test.mockito.LambdaAnswer
- answer(InvocationOnMock) - Method in class org.springframework.amqp.rabbit.test.mockito.LatchCountDownAndCallRealMethodAnswer
- APP_ID - Static variable in class org.springframework.amqp.support.AmqpHeaders
- append(ILoggingEvent) - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
- append(LogEvent) - Method in class org.springframework.amqp.rabbit.log4j2.AmqpAppender
- APPLICATION_ID - Static variable in class org.springframework.amqp.rabbit.log4j2.AmqpAppender
-
Key name for the application id (if there is one set via the appender config) in the message properties.
- APPLICATION_ID - Static variable in class org.springframework.amqp.rabbit.logback.AmqpAppender
-
Key name for the application id (if there is one set via the appender config) in the message properties.
- apply(Statement, Description) - Method in class org.springframework.amqp.rabbit.junit.BrokerRunning
- apply(Statement, Description) - Method in class org.springframework.amqp.rabbit.junit.LongRunningIntegrationTest
- apply(Statement, FrameworkMethod, Object) - Method in class org.springframework.amqp.rabbit.junit.LogLevelAdjuster
- apply(InvocationOnMock, T) - Method in interface org.springframework.amqp.rabbit.test.mockito.LambdaAnswer.ValueToReturn
- applyCommonOverrides(RabbitListenerEndpoint, C) - Method in class org.springframework.amqp.rabbit.config.BaseRabbitListenerContainerFactory
- applyCommonSettings(AbstractRetryOperationsInterceptorFactoryBean) - Method in class org.springframework.amqp.rabbit.config.RetryInterceptorBuilder
- Argument - Annotation Type in org.springframework.amqp.rabbit.annotation
-
Represents an argument used when declaring queues etc within a
QueueBinding
. - ArgumentBuilder - Class in org.springframework.amqp.rabbit.support
-
A builder for argument maps.
- ArgumentBuilder() - Constructor for class org.springframework.amqp.rabbit.support.ArgumentBuilder
- arguments() - Method in annotation type org.springframework.amqp.rabbit.annotation.Exchange
- arguments() - Method in annotation type org.springframework.amqp.rabbit.annotation.Queue
- arguments() - Method in annotation type org.springframework.amqp.rabbit.annotation.QueueBinding
- assertBeanFactory() - Method in class org.springframework.amqp.rabbit.annotation.RabbitListenerAnnotationBeanPostProcessor
- AsyncAmqpTemplate - Interface in org.springframework.amqp.core
-
Classes implementing this interface can perform asynchronous send and receive operations.
- asyncCompletableRpc(Method) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
-
Added to the 5.0.x client.
- AsyncConsumerRestartedEvent - Class in org.springframework.amqp.rabbit.listener
-
An event that is published whenever a consumer is restarted.
- AsyncConsumerRestartedEvent(Object, Object, Object) - Constructor for class org.springframework.amqp.rabbit.listener.AsyncConsumerRestartedEvent
- AsyncConsumerStartedEvent - Class in org.springframework.amqp.rabbit.listener
-
An event that is published whenever a new consumer is started.
- AsyncConsumerStartedEvent(Object, Object) - Constructor for class org.springframework.amqp.rabbit.listener.AsyncConsumerStartedEvent
- AsyncConsumerStoppedEvent - Class in org.springframework.amqp.rabbit.listener
-
An event that is published whenever a consumer is stopped (and not restarted).
- AsyncConsumerStoppedEvent(Object, Object) - Constructor for class org.springframework.amqp.rabbit.listener.AsyncConsumerStoppedEvent
- AsyncRabbitTemplate - Class in org.springframework.amqp.rabbit
-
Provides asynchronous send and receive operations returning a
ListenableFuture
allowing the caller to obtain the reply later, usingget()
or a callback. - AsyncRabbitTemplate(ConnectionFactory, String, String) - Constructor for class org.springframework.amqp.rabbit.AsyncRabbitTemplate
-
Construct an instance using the provided arguments.
- AsyncRabbitTemplate(ConnectionFactory, String, String, String) - Constructor for class org.springframework.amqp.rabbit.AsyncRabbitTemplate
-
Construct an instance using the provided arguments.
- AsyncRabbitTemplate(ConnectionFactory, String, String, String, String) - Constructor for class org.springframework.amqp.rabbit.AsyncRabbitTemplate
-
Construct an instance using the provided arguments.
- AsyncRabbitTemplate(RabbitTemplate) - Constructor for class org.springframework.amqp.rabbit.AsyncRabbitTemplate
-
Construct an instance using the provided arguments.
- AsyncRabbitTemplate(RabbitTemplate, AbstractMessageListenerContainer) - Constructor for class org.springframework.amqp.rabbit.AsyncRabbitTemplate
-
Construct an instance using the provided arguments.
- AsyncRabbitTemplate(RabbitTemplate, AbstractMessageListenerContainer, String) - Constructor for class org.springframework.amqp.rabbit.AsyncRabbitTemplate
-
Construct an instance using the provided arguments.
- AsyncRabbitTemplate.RabbitConverterFuture<C> - Class in org.springframework.amqp.rabbit
-
A
AsyncRabbitTemplate.RabbitFuture
with a return type of the template's generic parameter. - AsyncRabbitTemplate.RabbitFuture<T> - Class in org.springframework.amqp.rabbit
-
Base class for
ListenableFuture
s returned byAsyncRabbitTemplate
. - AsyncRabbitTemplate.RabbitMessageFuture - Class in org.springframework.amqp.rabbit
-
A
AsyncRabbitTemplate.RabbitFuture
with a return type ofMessage
. - asyncRpc(Method) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- AUTO - org.springframework.amqp.core.AcknowledgeMode
-
Auto - the container will issue the ack/nack based on whether the listener returns normally, or throws an exception.
- 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.
- autoDelete() - Method in annotation type org.springframework.amqp.rabbit.annotation.Exchange
- autoDelete() - Method in annotation type org.springframework.amqp.rabbit.annotation.Queue
-
Specifies if this queue should be auto deleted when not used.
- AutoRecoverConnectionNotCurrentlyOpenException - Exception in org.springframework.amqp.rabbit.connection
-
An exception thrown if the connection is an auto recover connection that is not currently open and is in the process of being recovered.
- autoStartup() - Method in annotation type org.springframework.amqp.rabbit.annotation.RabbitListener
-
Set to true or false, to override the default setting in the container factory.
- await(int) - Method in class org.springframework.amqp.rabbit.test.mockito.LatchCountDownAndCallRealMethodAnswer
-
Wait for the latch to count down.
- await(long, TimeUnit) - Method in class org.springframework.amqp.rabbit.support.ActiveObjectCounter
B
- backOffOptions(long, double, long) - Method in class org.springframework.amqp.rabbit.config.RetryInterceptorBuilder
-
Apply the backoff options.
- backOffPolicy(BackOffPolicy) - Method in class org.springframework.amqp.rabbit.config.RetryInterceptorBuilder
-
Apply the back off policy.
- BASE_PACKAGE - Static variable in class org.springframework.amqp.rabbit.config.NamespaceUtils
- Base64UrlNamingStrategy - Class in org.springframework.amqp.core
-
Generates names with the form
<prefix><base64url>
where 'prefix' is 'spring.gen-' by default (e.g. - Base64UrlNamingStrategy() - Constructor for class org.springframework.amqp.core.Base64UrlNamingStrategy
-
Construct an instance using the default prefix
spring.gen-
. - Base64UrlNamingStrategy(String) - Constructor for class org.springframework.amqp.core.Base64UrlNamingStrategy
-
Construct an instance using the supplied prefix.
- BaseRabbitListenerContainerFactory<C extends MessageListenerContainer> - Class in org.springframework.amqp.rabbit.config
-
Base abstract class for listener container factories.
- BaseRabbitListenerContainerFactory() - Constructor for class org.springframework.amqp.rabbit.config.BaseRabbitListenerContainerFactory
- BASIC_CLASS_ID_60 - Static variable in class org.springframework.amqp.rabbit.connection.RabbitUtils
-
AMQP basic class id.
- basicAck(long, boolean) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- basicCancel() - Method in class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer
- basicCancel(boolean) - Method in class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer
- basicCancel(String) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- basicConsume(String, boolean, Consumer) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- basicConsume(String, boolean, DeliverCallback, CancelCallback) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
-
Added to the 5.0.x client.
- basicConsume(String, boolean, DeliverCallback, CancelCallback, ConsumerShutdownSignalCallback) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
-
Added to the 5.0.x client.
- basicConsume(String, boolean, DeliverCallback, ConsumerShutdownSignalCallback) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
-
Added to the 5.0.x client.
- basicConsume(String, boolean, String, boolean, boolean, Map<String, Object>, Consumer) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- basicConsume(String, boolean, String, boolean, boolean, Map<String, Object>, DeliverCallback, CancelCallback) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
-
Added to the 5.0.x client.
- basicConsume(String, boolean, String, boolean, boolean, Map<String, Object>, DeliverCallback, CancelCallback, ConsumerShutdownSignalCallback) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
-
Added to the 5.0.x client.
- basicConsume(String, boolean, String, boolean, boolean, Map<String, Object>, DeliverCallback, ConsumerShutdownSignalCallback) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
-
Added to the 5.0.x client.
- basicConsume(String, boolean, String, Consumer) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- basicConsume(String, boolean, String, DeliverCallback, CancelCallback) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
-
Added to the 5.0.x client.
- basicConsume(String, boolean, String, DeliverCallback, CancelCallback, ConsumerShutdownSignalCallback) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
-
Added to the 5.0.x client.
- basicConsume(String, boolean, String, DeliverCallback, ConsumerShutdownSignalCallback) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
-
Added to the 5.0.x client.
- basicConsume(String, boolean, Map<String, Object>, Consumer) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
-
Added to the 3.3.x client.
- basicConsume(String, boolean, Map<String, Object>, DeliverCallback, CancelCallback) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
-
Added to the 5.0.x client.
- basicConsume(String, boolean, Map<String, Object>, DeliverCallback, CancelCallback, ConsumerShutdownSignalCallback) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
-
Added to the 5.0.x client.
- basicConsume(String, boolean, Map<String, Object>, DeliverCallback, ConsumerShutdownSignalCallback) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
-
Added to the 5.0.x client.
- basicConsume(String, Consumer) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- basicConsume(String, DeliverCallback, CancelCallback) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
-
Added to the 5.0.x client.
- basicConsume(String, DeliverCallback, CancelCallback, ConsumerShutdownSignalCallback) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
-
Added to the 5.0.x client.
- basicConsume(String, DeliverCallback, ConsumerShutdownSignalCallback) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
-
Added to the 5.0.x client.
- basicGet(String, boolean) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- basicNack(long, boolean, boolean) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- basicPublish(String, String, boolean, boolean, AMQP.BasicProperties, byte[]) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- basicPublish(String, String, boolean, AMQP.BasicProperties, byte[]) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- basicPublish(String, String, AMQP.BasicProperties, byte[]) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- basicQos(int) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- basicQos(int, boolean) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
-
Added to the 3.3.x client.
- basicQos(int, int, boolean) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- basicRecover() - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- basicRecover(boolean) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- basicReject(long, boolean) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- BATCH_FORMAT_LENGTH_HEADER4 - Static variable in class org.springframework.amqp.core.MessageProperties
- BATCH_SIZE - Static variable in class org.springframework.amqp.support.AmqpHeaders
-
The number of fragments in a batch message.
- BatchingRabbitTemplate - Class in org.springframework.amqp.rabbit.core
-
A
RabbitTemplate
that permits batching individual messages into a larger message. - BatchingRabbitTemplate(BatchingStrategy, TaskScheduler) - Constructor for class org.springframework.amqp.rabbit.core.BatchingRabbitTemplate
-
Create an instance with the supplied parameters.
- BatchingRabbitTemplate(ConnectionFactory, BatchingStrategy, TaskScheduler) - Constructor for class org.springframework.amqp.rabbit.core.BatchingRabbitTemplate
-
Create an instance with the supplied parameters.
- BatchingStrategy - Interface in org.springframework.amqp.rabbit.batch
-
Strategy for batching messages.
- BatchMessageListener - Interface in org.springframework.amqp.core
-
Used to receive a batch of messages if the container supports it.
- BatchMessagingMessageListenerAdapter - Class in org.springframework.amqp.rabbit.listener.adapter
-
A listener adapter for batch listeners.
- BatchMessagingMessageListenerAdapter(Object, Method, boolean, RabbitListenerErrorHandler, BatchingStrategy) - Constructor for class org.springframework.amqp.rabbit.listener.adapter.BatchMessagingMessageListenerAdapter
- beforeAll(ExtensionContext) - Method in class org.springframework.amqp.rabbit.junit.LogLevelsCondition
- beforeEach(ExtensionContext) - Method in class org.springframework.amqp.rabbit.junit.LogLevelsCondition
- bind(Object, Object) - Static method in class org.springframework.amqp.rabbit.connection.SimpleResourceHolder
-
Bind the given resource for the given key to the current thread.
- bind(Exchange) - Static method in class org.springframework.amqp.core.BindingBuilder
- bind(Queue) - Static method in class org.springframework.amqp.core.BindingBuilder
- Binding - Class in org.springframework.amqp.core
-
Simple container collecting information to describe a binding.
- Binding(String, Binding.DestinationType, String, String, Map<String, Object>) - Constructor for class org.springframework.amqp.core.Binding
- BINDING_ARGUMENTS - Static variable in class org.springframework.amqp.rabbit.config.AbstractExchangeParser
- BINDING_EXCHANGE_ATTR - Static variable in class org.springframework.amqp.rabbit.config.AbstractExchangeParser
- BINDING_QUEUE_ATTR - Static variable in class org.springframework.amqp.rabbit.config.AbstractExchangeParser
- Binding.DestinationType - Enum in org.springframework.amqp.core
-
The binding destination.
- BindingBuilder - Class in org.springframework.amqp.core
-
Basic builder class to create bindings for a more fluent API style in code based configuration.
- BindingBuilder.DestinationConfigurer - Class in org.springframework.amqp.core
-
General destination configurer.
- BindingBuilder.DirectExchangeRoutingKeyConfigurer - Class in org.springframework.amqp.core
-
Direct exchange routing key configurer.
- BindingBuilder.GenericArgumentsConfigurer - Class in org.springframework.amqp.core
-
Generic argument configurer.
- BindingBuilder.GenericExchangeRoutingKeyConfigurer - Class in org.springframework.amqp.core
-
Generic exchange routing key configurer.
- BindingBuilder.HeadersExchangeMapConfigurer - Class in org.springframework.amqp.core
-
Headers exchange configurer.
- BindingBuilder.HeadersExchangeMapConfigurer.HeadersExchangeKeysBindingCreator - Class in org.springframework.amqp.core
-
Headers exchange keys binding creator.
- BindingBuilder.HeadersExchangeMapConfigurer.HeadersExchangeMapBindingCreator - Class in org.springframework.amqp.core
-
Headers exchange map binding creator.
- BindingBuilder.HeadersExchangeMapConfigurer.HeadersExchangeSingleValueBindingCreator - Class in org.springframework.amqp.core
-
Headers exchange single value binding creator.
- BindingBuilder.TopicExchangeRoutingKeyConfigurer - Class in org.springframework.amqp.core
-
Topic exchange routing key configurer.
- BindingFactoryBean - Class in org.springframework.amqp.rabbit.config
- BindingFactoryBean() - Constructor for class org.springframework.amqp.rabbit.config.BindingFactoryBean
- bindings() - Method in annotation type org.springframework.amqp.rabbit.annotation.RabbitListener
-
Array of
QueueBinding
s providing the listener's queue names, together with the exchange and optional binding information. - bindResourceToTransaction(RabbitResourceHolder, ConnectionFactory, boolean) - Static method in class org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils
- BlockingQueueConsumer - Class in org.springframework.amqp.rabbit.listener
-
Specialized consumer encapsulating knowledge of the broker connections and having its own lifecycle (start and stop).
- BlockingQueueConsumer(ConnectionFactory, MessagePropertiesConverter, ActiveObjectCounter<BlockingQueueConsumer>, AcknowledgeMode, boolean, int, boolean, String...) - Constructor for class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer
-
Create a consumer.
- BlockingQueueConsumer(ConnectionFactory, MessagePropertiesConverter, ActiveObjectCounter<BlockingQueueConsumer>, AcknowledgeMode, boolean, int, boolean, Map<String, Object>, boolean, boolean, String...) - Constructor for class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer
-
Create a consumer.
- BlockingQueueConsumer(ConnectionFactory, MessagePropertiesConverter, ActiveObjectCounter<BlockingQueueConsumer>, AcknowledgeMode, boolean, int, boolean, Map<String, Object>, boolean, String...) - Constructor for class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer
-
Create a consumer.
- BlockingQueueConsumer(ConnectionFactory, MessagePropertiesConverter, ActiveObjectCounter<BlockingQueueConsumer>, AcknowledgeMode, boolean, int, boolean, Map<String, Object>, String...) - Constructor for class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer
-
Create a consumer.
- BlockingQueueConsumer(ConnectionFactory, MessagePropertiesConverter, ActiveObjectCounter<BlockingQueueConsumer>, AcknowledgeMode, boolean, int, String...) - Constructor for class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer
-
Create a consumer.
- BROKER_ADMIN_PW - Static variable in class org.springframework.amqp.rabbit.junit.BrokerRunningSupport
- BROKER_ADMIN_URI - Static variable in class org.springframework.amqp.rabbit.junit.BrokerRunningSupport
- BROKER_ADMIN_USER - Static variable in class org.springframework.amqp.rabbit.junit.BrokerRunningSupport
- BROKER_HOSTNAME - Static variable in class org.springframework.amqp.rabbit.junit.BrokerRunningSupport
- BROKER_PORT - Static variable in class org.springframework.amqp.rabbit.junit.BrokerRunningSupport
- BROKER_PW - Static variable in class org.springframework.amqp.rabbit.junit.BrokerRunningSupport
- BROKER_REQUIRED - Static variable in class org.springframework.amqp.rabbit.junit.BrokerRunningSupport
- BROKER_USER - Static variable in class org.springframework.amqp.rabbit.junit.BrokerRunningSupport
- BrokerEvent - Class in org.springframework.amqp.rabbit.core
-
Represents a broker event generated by the Event Exchange Plugin (https://www.rabbitmq.com/event-exchange.html).
- BrokerEvent(Object, MessageProperties) - Constructor for class org.springframework.amqp.rabbit.core.BrokerEvent
-
Create an instance with the provided source and properties.
- BrokerEventListener - Class in org.springframework.amqp.rabbit.core
-
When the event-exchange-plugin is enabled (see https://www.rabbitmq.com/event-exchange.html), if an object of this type is declared as a bean, selected events will be published as
BrokerEvent
s. - BrokerEventListener(ConnectionFactory, String...) - Constructor for class org.springframework.amqp.rabbit.core.BrokerEventListener
-
Construct an instance using the supplied connection factory and event keys.
- BrokerEventListener(AbstractMessageListenerContainer, String...) - Constructor for class org.springframework.amqp.rabbit.core.BrokerEventListener
-
Construct an instance using the supplied listener container factory and event keys.
- BrokerRunning - Class in org.springframework.amqp.rabbit.junit
-
A rule that prevents integration tests from failing if the Rabbit broker application is not running or not accessible.
- BrokerRunningSupport - Class in org.springframework.amqp.rabbit.junit
-
A class that can be used to prevent integration tests from failing if the Rabbit broker application is not running or not accessible.
- BrokerRunningSupport.BrokerNotAliveException - Exception in org.springframework.amqp.rabbit.junit
-
The
RuntimeException
thrown when broker is not available on the provided host port. - BrokerTestUtils - Class in org.springframework.amqp.rabbit.junit
-
Global convenience class for all integration tests, carrying constants and other utilities for broker set up.
- build() - Method in class org.springframework.amqp.core.ExchangeBuilder
- build() - Method in class org.springframework.amqp.core.MessageBuilder
- build() - Method in class org.springframework.amqp.core.MessageBuilderSupport
- build() - Method in class org.springframework.amqp.core.MessagePropertiesBuilder
- build() - Method in class org.springframework.amqp.core.QueueBuilder
-
Builds a final queue.
- build() - Method in class org.springframework.amqp.rabbit.config.RetryInterceptorBuilder
- build() - Method in class org.springframework.amqp.rabbit.config.RetryInterceptorBuilder.StatefulRetryInterceptorBuilder
- build() - Method in class org.springframework.amqp.rabbit.config.RetryInterceptorBuilder.StatelessRetryInterceptorBuilder
- build() - Method in class org.springframework.amqp.rabbit.log4j2.AmqpAppender.Builder
- Builder() - Constructor for class org.springframework.amqp.rabbit.log4j2.AmqpAppender.Builder
- buildInstance(String, Filter, Layout<? extends Serializable>, boolean, AmqpAppender.AmqpManager, BlockingQueue<AmqpAppender.Event>) - Method in class org.springframework.amqp.rabbit.log4j2.AmqpAppender.Builder
-
Subclasses can extends Builder, use same logic but need to modify class instance.
- buildListenerArguments(Object, Channel, Message) - Method in class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter
-
Build an array of arguments to be passed into the target listener method.
- buildMessage(Channel, Object, Type) - Method in class org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener
-
Build a Rabbit message to be sent as response based on the given result object.
- buildMessage(Channel, Object, Type) - Method in class org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter
-
Build a Rabbit message to be sent as response based on the given result object.
- buildProperties() - Method in class org.springframework.amqp.core.MessageBuilderSupport
C
- CachingConnectionFactory - Class in org.springframework.amqp.rabbit.connection
-
A
ConnectionFactory
implementation that (when the cache mode isCachingConnectionFactory.CacheMode.CHANNEL
(default) returns the same Connection from allCachingConnectionFactory.createConnection()
calls, and ignores calls toConnection.close()
and cachesChannel
. - CachingConnectionFactory() - Constructor for class org.springframework.amqp.rabbit.connection.CachingConnectionFactory
-
Create a new CachingConnectionFactory initializing the hostname to be the value returned from InetAddress.getLocalHost(), or "localhost" if getLocalHost() throws an exception.
- CachingConnectionFactory(int) - Constructor for class org.springframework.amqp.rabbit.connection.CachingConnectionFactory
-
Create a new CachingConnectionFactory given a port on the hostname returned from InetAddress.getLocalHost(), or "localhost" if getLocalHost() throws an exception.
- CachingConnectionFactory(ConnectionFactory) - Constructor for class org.springframework.amqp.rabbit.connection.CachingConnectionFactory
-
Create a new CachingConnectionFactory for the given target ConnectionFactory.
- CachingConnectionFactory(String) - Constructor for class org.springframework.amqp.rabbit.connection.CachingConnectionFactory
-
Create a new CachingConnectionFactory given a host name.
- CachingConnectionFactory(String, int) - Constructor for class org.springframework.amqp.rabbit.connection.CachingConnectionFactory
-
Create a new CachingConnectionFactory given a host name and port.
- CachingConnectionFactory(URI) - Constructor for class org.springframework.amqp.rabbit.connection.CachingConnectionFactory
-
Create a new CachingConnectionFactory given a
URI
. - CachingConnectionFactory.CacheMode - Enum in org.springframework.amqp.rabbit.connection
-
The cache mode.
- CachingConnectionFactory.ConfirmType - Enum in org.springframework.amqp.rabbit.connection
-
The type of publisher confirms to use.
- call(String, Callable<T>) - Method in class org.springframework.amqp.rabbit.connection.ConnectionFactoryContextWrapper
-
Execute a
Callable
binding the givenConnectionFactory
and finally unbinding it. - call(Callable<T>) - Method in class org.springframework.amqp.rabbit.connection.ConnectionFactoryContextWrapper
-
Execute a
Callable
binding to the defaultConnectionFactory
and finally unbinding it. - cancel(boolean) - Method in class org.springframework.amqp.rabbit.AsyncRabbitTemplate.RabbitFuture
- cancel(Channel, String) - Static method in class org.springframework.amqp.rabbit.connection.RabbitUtils
- cancelled() - Method in class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer
- canDebatch(MessageProperties) - Method in interface org.springframework.amqp.rabbit.batch.BatchingStrategy
-
Return true if this strategy can decode a batch of messages from a message body.
- canDebatch(MessageProperties) - Method in class org.springframework.amqp.rabbit.batch.SimpleBatchingStrategy
- capture() - Method in annotation type org.springframework.amqp.rabbit.test.RabbitListenerTest
-
Set to true to advise the listener with a capture advice,
- categories() - Method in annotation type org.springframework.amqp.rabbit.junit.LogLevels
-
Category names representing Log4j or Logback categories to change.
- categories(String...) - Method in class org.springframework.amqp.rabbit.junit.LogLevelAdjuster
- CATEGORY_LEVEL - Static variable in class org.springframework.amqp.rabbit.log4j2.AmqpAppender
-
Key name for the logger level name in the message properties.
- CATEGORY_LEVEL - Static variable in class org.springframework.amqp.rabbit.logback.AmqpAppender
-
Key name for the logger level name in the message properties
- CATEGORY_NAME - Static variable in class org.springframework.amqp.rabbit.log4j2.AmqpAppender
-
Key name for the logger category name in the message properties.
- CATEGORY_NAME - Static variable in class org.springframework.amqp.rabbit.logback.AmqpAppender
-
Key name for the logger category name in the message properties
- causeChainContainsARADRE(Throwable) - Method in class org.springframework.amqp.rabbit.listener.ConditionalRejectingErrorHandler
-
Return true if there is already an
AmqpRejectAndDontRequeueException
present in the cause chain. - causeChainHasImmediateAcknowledgeAmqpException(Throwable) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
-
Traverse the cause chain and, if an
ImmediateAcknowledgeAmqpException
is found before anAmqpRejectAndDontRequeueException
, return true. - CHANNEL - org.springframework.amqp.rabbit.connection.CachingConnectionFactory.CacheMode
-
Cache channels - single connection.
- CHANNEL - Static variable in class org.springframework.amqp.support.AmqpHeaders
- CHANNEL_PROTOCOL_CLASS_ID_20 - Static variable in class org.springframework.amqp.rabbit.connection.RabbitUtils
-
AMQP Channel protocol class id.
- ChannelAwareBatchMessageListener - Interface in org.springframework.amqp.rabbit.listener.api
-
Used to receive a batch of messages if the container supports it.
- ChannelAwareMessageListener - Interface in org.springframework.amqp.rabbit.listener.api
-
A message listener that is aware of the Channel on which the message was received.
- ChannelCallback<T> - Interface in org.springframework.amqp.rabbit.core
-
Basic callback for use in RabbitTemplate.
- ChannelListener - Interface in org.springframework.amqp.rabbit.connection
-
A listener for new channel creation and destruction.
- ChannelProxy - Interface in org.springframework.amqp.rabbit.connection
-
Subinterface of
Channel
to be implemented by Channel proxies. - checkAfterCompletion() - Static method in class org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils
-
When using transaction synchronization, call this method after the transaction commits to verify that the RabbitMQ transaction committed.
- 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.
- checkConnect() - Method in class org.springframework.amqp.rabbit.listener.DirectMessageListenerContainer
- checkMessageListener(Object) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
-
Check the given message listener, throwing an exception if it does not correspond to a supported listener type.
- checkMismatchedQueues() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- classes() - Method in annotation type org.springframework.amqp.rabbit.junit.LogLevels
-
Classes representing Log4j categories to change.
- ClassMapper - Interface in org.springframework.amqp.support.converter
-
Strategy for setting metadata on messages such that one can create the class that needs to be instantiated when receiving a message.
- clear() - Static method in class org.springframework.amqp.rabbit.connection.SimpleResourceHolder
-
Clear resources for the current thread.
- clearConfirmListeners() - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- clearConnectionListeners() - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
- clearConnectionListeners() - Method in class org.springframework.amqp.rabbit.connection.AbstractRoutingConnectionFactory
- clearConnectionListeners() - Method in interface org.springframework.amqp.rabbit.connection.ConnectionFactory
- clearConnectionListeners() - Method in class org.springframework.amqp.rabbit.connection.LocalizedQueueConnectionFactory
- clearDelegates() - Method in class org.springframework.amqp.rabbit.connection.CompositeConnectionListener
- clearDeliveryTags() - Method in class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer
-
Clear the delivery tags when rolling back with an external transaction manager.
- clearEnvironmentVariableOverrides() - Static method in class org.springframework.amqp.rabbit.junit.BrokerRunning
-
Clear any environment variable overrides set in
BrokerRunning.setEnvironmentVariableOverrides(Map)
. - clearEnvironmentVariableOverrides() - Static method in class org.springframework.amqp.rabbit.junit.BrokerRunningSupport
-
Clear any environment variable overrides set in
BrokerRunningSupport.setEnvironmentVariableOverrides(Map)
. - clearPhysicalCloseRequired() - Static method in class org.springframework.amqp.rabbit.connection.RabbitUtils
-
Clear the physicalCloseRequired flag.
- clearReturnListeners() - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- clientLocal - org.springframework.amqp.core.QueueBuilder.LeaderLocator
-
Deploy on the node we are connected to.
- clientLocal - org.springframework.amqp.core.QueueBuilder.MasterLocator
-
Deprecated.Deploy on the node we are connected to.
- clone() - Method in class org.springframework.amqp.core.Queue
- close() - Method in interface org.springframework.amqp.rabbit.connection.Connection
-
Close this connection and all its channels with the
AMQP.REPLY_SUCCESS
close code and message 'OK'. - close() - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- close() - Method in class org.springframework.amqp.rabbit.connection.SimpleConnection
- close() - Method in interface org.springframework.rabbit.stream.producer.RabbitStreamOperations
- close() - Method in class org.springframework.rabbit.stream.producer.RabbitStreamTemplate
- close(int, String) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- closeAll() - Method in class org.springframework.amqp.rabbit.connection.RabbitResourceHolder
- closeAndClear(Collection<ChannelProxy>) - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory
- closeChannel(Channel) - Static method in class org.springframework.amqp.rabbit.connection.RabbitUtils
-
Close the given RabbitMQ Channel and ignore any thrown exception.
- closeChannels(Collection<ChannelProxy>) - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory
- closeConnection(Connection) - Static method in class org.springframework.amqp.rabbit.connection.RabbitUtils
-
Close the given RabbitMQ Connection and ignore any thrown exception.
- closeMessageConsumer(Channel, Collection<String>, boolean) - Static method in class org.springframework.amqp.rabbit.connection.RabbitUtils
- closeThreadChannel() - Method in interface org.springframework.amqp.rabbit.connection.Connection
-
Close any channel associated with the current thread.
- closeThreadChannel() - Method in class org.springframework.amqp.rabbit.connection.ThreadChannelConnectionFactory
-
Close the channel associated with this thread, if any.
- ClosingRecoveryListener - Class in org.springframework.amqp.rabbit.connection
-
A
RecoveryListener
that closes the recovered channel, to avoid orphaned consumers. - CLUSTER_ID - Static variable in class org.springframework.amqp.support.AmqpHeaders
- commitAll() - Method in class org.springframework.amqp.rabbit.connection.RabbitResourceHolder
- commitIfNecessary(boolean) - Method in class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer
-
Perform a commit or message acknowledgement, as appropriate.
- commitIfNecessary(Channel) - Static method in class org.springframework.amqp.rabbit.connection.RabbitUtils
-
Commit the Channel if not within a JTA transaction.
- CompositeChannelListener - Class in org.springframework.amqp.rabbit.connection
- CompositeChannelListener() - Constructor for class org.springframework.amqp.rabbit.connection.CompositeChannelListener
- CompositeConnectionListener - Class in org.springframework.amqp.rabbit.connection
-
A composite listener that invokes its delegages in turn.
- CompositeConnectionListener() - Constructor for class org.springframework.amqp.rabbit.connection.CompositeConnectionListener
- concurrency() - Method in annotation type org.springframework.amqp.rabbit.annotation.RabbitListener
-
Set the concurrency of the listener container for this listener.
- ConditionalExceptionLogger - Interface in org.springframework.amqp.support
-
For components that support customization of the logging of certain events, users can provide an implementation of this interface to modify the existing logging behavior.
- ConditionalRejectingErrorHandler - Class in org.springframework.amqp.rabbit.listener
-
ErrorHandler
that conditionally wraps the Exception in anAmqpRejectAndDontRequeueException
if the configured rejection strategy determines that the message is fatal and should not be requeued. - ConditionalRejectingErrorHandler() - Constructor for class org.springframework.amqp.rabbit.listener.ConditionalRejectingErrorHandler
-
Create a handler with the
ConditionalRejectingErrorHandler.DefaultExceptionStrategy
. - ConditionalRejectingErrorHandler(FatalExceptionStrategy) - Constructor for class org.springframework.amqp.rabbit.listener.ConditionalRejectingErrorHandler
-
Create a handler with the supplied
FatalExceptionStrategy
implementation. - ConditionalRejectingErrorHandler.DefaultExceptionStrategy - Class in org.springframework.amqp.rabbit.listener
-
Default implementation of
FatalExceptionStrategy
. - configure(C) - Method in interface org.springframework.amqp.rabbit.config.ContainerCustomizer
-
Configure the container.
- configureAdminIfNeeded() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- configureKeyManagers() - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
- configureListenerAdapter(MessagingMessageListenerAdapter) - Method in class org.springframework.amqp.rabbit.listener.MethodRabbitListenerEndpoint
-
Create a
HandlerAdapter
for this listener adapter. - configureListenerAdapter(MessagingMessageListenerAdapter) - Method in class org.springframework.amqp.rabbit.listener.MultiMethodRabbitListenerEndpoint
- configureRabbitConnectionFactory(RabbitConnectionFactoryBean) - Method in class org.springframework.amqp.rabbit.log4j2.AmqpAppender.AmqpManager
-
Configure the
RabbitConnectionFactoryBean
. - configureRabbitConnectionFactory(RabbitConnectionFactoryBean) - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
-
Configure the
RabbitConnectionFactoryBean
. - configureRabbitListeners(RabbitListenerEndpointRegistrar) - Method in interface org.springframework.amqp.rabbit.annotation.RabbitListenerConfigurer
-
Callback allowing a
RabbitListenerEndpointRegistry
and specificRabbitListenerEndpoint
instances to be registered against the givenRabbitListenerEndpointRegistrar
. - configureTrustManagers() - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
- confirm(CorrelationData, boolean, String) - Method in class org.springframework.amqp.rabbit.AsyncRabbitTemplate
- confirm(CorrelationData, boolean, String) - Method in interface org.springframework.amqp.rabbit.core.RabbitTemplate.ConfirmCallback
-
Confirmation callback.
- Confirm(boolean, String) - Constructor for class org.springframework.amqp.rabbit.connection.CorrelationData.Confirm
- confirmSelect() - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- Connection - Interface in org.springframework.amqp.rabbit.connection
- CONNECTION - org.springframework.amqp.rabbit.connection.CachingConnectionFactory.CacheMode
-
Cache connections and channels within each connection.
- CONNECTION_PROTOCOL_CLASS_ID_10 - Static variable in class org.springframework.amqp.rabbit.connection.RabbitUtils
-
AMQP Connection protocol class id.
- ConnectionBlockedEvent - Class in org.springframework.amqp.rabbit.connection
-
The
AmqpEvent
emitted by theCachingConnectionFactory
when its connections are blocked. - ConnectionBlockedEvent(Connection, String) - Constructor for class org.springframework.amqp.rabbit.connection.ConnectionBlockedEvent
- connectionFactory - Variable in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
- ConnectionFactory - Interface in org.springframework.amqp.rabbit.connection
-
An interface based ConnectionFactory for creating
Connections
. - ConnectionFactoryConfigurationUtils - Class in org.springframework.amqp.rabbit.connection
-
Utility methods for configuring connection factories.
- ConnectionFactoryContextWrapper - Class in org.springframework.amqp.rabbit.connection
-
Helper class to handle
ConnectionFactory
context binding and unbinding when executing instructions. - ConnectionFactoryContextWrapper(ConnectionFactory) - Constructor for class org.springframework.amqp.rabbit.connection.ConnectionFactoryContextWrapper
- ConnectionFactoryUtils - Class in org.springframework.amqp.rabbit.connection
-
Helper class for managing a Spring based Rabbit
ConnectionFactory
, in particular for obtaining transactional Rabbit resources for a given ConnectionFactory. - ConnectionFactoryUtils.ResourceFactory - Interface in org.springframework.amqp.rabbit.connection
-
Callback interface for resource creation.
- ConnectionListener - Interface in org.springframework.amqp.rabbit.connection
-
A listener for connection creation and closing.
- ConnectionNameStrategy - Interface in org.springframework.amqp.rabbit.connection
-
A strategy to build an application-specific connection name, which can be displayed in the management UI if RabbitMQ server supports it.
- ConnectionProxy - Interface in org.springframework.amqp.rabbit.connection
-
Subinterface of
Connection
to be implemented by Connection proxies. - ConnectionUnblockedEvent - Class in org.springframework.amqp.rabbit.connection
-
The
AmqpEvent
emitted by theCachingConnectionFactory
when its connections are unblocked. - ConnectionUnblockedEvent(Connection) - Constructor for class org.springframework.amqp.rabbit.connection.ConnectionUnblockedEvent
- CONSUME_METHOD_ID_20 - Static variable in class org.springframework.amqp.rabbit.connection.RabbitUtils
-
AMQP consume method.
- ConsumeOkEvent - Class in org.springframework.amqp.rabbit.listener
-
An
AmqpEvent
emitted by the listener container when consumer is subscribed to the queue. - ConsumeOkEvent(Object, String, String) - Constructor for class org.springframework.amqp.rabbit.listener.ConsumeOkEvent
-
Instantiate a
ConsumeOkEvent
based on the provided consumer, queue and consumer tag. - ConsumeOkNotReceivedException - Exception in org.springframework.amqp.rabbit.core
-
Thrown when a blocking receive operation is performed but the consumeOk was not received before the receive timeout.
- ConsumeOkNotReceivedException(String) - Constructor for exception org.springframework.amqp.rabbit.core.ConsumeOkNotReceivedException
- CONSUMER_QUEUE - Static variable in class org.springframework.amqp.support.AmqpHeaders
-
The queue from which the listener container consumer received the message.
- CONSUMER_TAG - Static variable in class org.springframework.amqp.support.AmqpHeaders
-
The tag of the listener container consumer that received the message.
- ConsumerCancelledException - Exception in org.springframework.amqp.rabbit.support
-
Thrown when the broker cancels the consumer and the message queue is drained.
- ConsumerCancelledException() - Constructor for exception org.springframework.amqp.rabbit.support.ConsumerCancelledException
- ConsumerCancelledException(Throwable) - Constructor for exception org.springframework.amqp.rabbit.support.ConsumerCancelledException
- ConsumerChannelRegistry - Class in org.springframework.amqp.rabbit.connection
-
Consumers register their primary channels with this class.
- consumerCount(String) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- ConsumerCustomizer - Interface in org.springframework.rabbit.stream.listener
-
Customizer for
ConsumerBuilder
. - consumerRemoved(DirectMessageListenerContainer.SimpleConsumer) - Method in class org.springframework.amqp.rabbit.listener.DirectMessageListenerContainer
-
Called whenever a consumer is removed.
- consumerRemoved(DirectMessageListenerContainer.SimpleConsumer) - Method in class org.springframework.amqp.rabbit.listener.DirectReplyToMessageListenerContainer
- consumers - Variable in class org.springframework.amqp.rabbit.listener.DirectMessageListenerContainer
- consumersMonitor - Variable in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- 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.
- containerAckMode(AcknowledgeMode) - Method in class org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener
- ContainerCustomizer<C extends MessageListenerContainer> - Interface in org.springframework.amqp.rabbit.config
-
Called by the container factory after the container is created and configured.
- containerFactory() - Method in annotation type org.springframework.amqp.rabbit.annotation.RabbitListener
-
The bean name of the
RabbitListenerContainerFactory
to use to create the message listener container responsible to serve this endpoint. - containerType() - Method in annotation type org.springframework.amqp.rabbit.test.context.SpringRabbitTest
-
Set the container type to determine which container factory to configure.
- ContainerUtils - Class in org.springframework.amqp.rabbit.listener.support
-
Utility methods for listener containers.
- containsChannel(Channel) - Method in class org.springframework.amqp.rabbit.connection.RabbitResourceHolder
- CONTENT_ENCODING - Static variable in class org.springframework.amqp.support.AmqpHeaders
- CONTENT_LENGTH - Static variable in class org.springframework.amqp.support.AmqpHeaders
- CONTENT_TYPE - Static variable in class org.springframework.amqp.support.AmqpHeaders
- CONTENT_TYPE_BYTES - Static variable in class org.springframework.amqp.core.MessageProperties
- CONTENT_TYPE_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
-
A composite
MessageConverter
that delegates to an actualMessageConverter
based on the contentType header. - ContentTypeDelegatingMessageConverter() - Constructor for class org.springframework.amqp.support.converter.ContentTypeDelegatingMessageConverter
-
Constructs an instance using a default
SimpleMessageConverter
. - ContentTypeDelegatingMessageConverter(MessageConverter) - Constructor for class org.springframework.amqp.support.converter.ContentTypeDelegatingMessageConverter
-
Constructs an instance using a the supplied default converter.
- convert(Object, Type, MessageConverter) - Method in class org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener
-
Convert to a message, with reply content type based on settings.
- convert(Message, Type) - Method in class org.springframework.amqp.support.converter.ProjectingMessageConverter
- convertAmqpException(RuntimeException) - Method in class org.springframework.amqp.rabbit.core.RabbitMessagingTemplate
- convertAmqpMessage(Message) - Method in class org.springframework.amqp.rabbit.core.RabbitMessagingTemplate
- convertAndSend(Object) - Method in interface org.springframework.amqp.core.AmqpTemplate
-
Convert a Java object to an Amqp
Message
and send it to a default exchange with a default routing key. - convertAndSend(Object) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
- convertAndSend(Object) - Method in interface org.springframework.rabbit.stream.producer.RabbitStreamOperations
-
Convert to and send a Spring AMQP message.
- convertAndSend(Object) - Method in class org.springframework.rabbit.stream.producer.RabbitStreamTemplate
- 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(Object, MessagePostProcessor) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
- convertAndSend(Object, MessagePostProcessor) - Method in interface org.springframework.rabbit.stream.producer.RabbitStreamOperations
-
Convert to and send a Spring AMQP message.
- convertAndSend(Object, MessagePostProcessor) - Method in class org.springframework.rabbit.stream.producer.RabbitStreamTemplate
- convertAndSend(Object, MessagePostProcessor, CorrelationData) - Method in interface org.springframework.amqp.rabbit.core.RabbitOperations
-
Convert a Java object to an Amqp
Message
and send it to a default exchange with a default routing key. - convertAndSend(Object, MessagePostProcessor, CorrelationData) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
- 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, Object) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
- 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, Object, MessagePostProcessor) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
- convertAndSend(String, Object, MessagePostProcessor, CorrelationData) - Method in interface org.springframework.amqp.rabbit.core.RabbitOperations
-
Convert a Java object to an Amqp
Message
and send it to a default exchange with a specific routing key. - convertAndSend(String, Object, MessagePostProcessor, CorrelationData) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
- convertAndSend(String, Object, CorrelationData) - Method in interface org.springframework.amqp.rabbit.core.RabbitOperations
-
Convert a Java object to an Amqp
Message
and send it to a default exchange with a specific routing key. - convertAndSend(String, Object, CorrelationData) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
- 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(String, String, Object) - Method in interface org.springframework.amqp.rabbit.core.RabbitMessageOperations
-
Convert the given Object to serialized form, possibly using a
MessageConverter
, wrap it as a message and send it to a specific exchange with a specific routing key. - convertAndSend(String, String, Object) - Method in class org.springframework.amqp.rabbit.core.RabbitMessagingTemplate
- convertAndSend(String, String, Object) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
- convertAndSend(String, String, Object, Map<String, Object>) - Method in interface org.springframework.amqp.rabbit.core.RabbitMessageOperations
-
Convert the given Object to serialized form, possibly using a
MessageConverter
, wrap it as a message with the given headers and send it to a specific exchange with a specific routing key. - convertAndSend(String, String, Object, Map<String, Object>) - Method in class org.springframework.amqp.rabbit.core.RabbitMessagingTemplate
- convertAndSend(String, String, Object, Map<String, Object>, MessagePostProcessor) - Method in interface org.springframework.amqp.rabbit.core.RabbitMessageOperations
-
Convert the given Object to serialized form, possibly using a
MessageConverter
, wrap it as a message with the given headers, apply the given post processor, and send the resulting message to a specific exchange with a specific routing key. - convertAndSend(String, String, Object, Map<String, Object>, MessagePostProcessor) - Method in class org.springframework.amqp.rabbit.core.RabbitMessagingTemplate
- convertAndSend(String, String, Object, MessagePostProcessor) - Method in interface org.springframework.amqp.core.AmqpTemplate
-
Convert a Java object to an Amqp
Message
and send it to a specific exchange with a specific routing key. - convertAndSend(String, String, Object, MessagePostProcessor) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
- convertAndSend(String, String, Object, MessagePostProcessor, CorrelationData) - Method in interface org.springframework.amqp.rabbit.core.RabbitOperations
-
Convert a Java object to an Amqp
Message
and send it to a specific exchange with a specific routing key. - convertAndSend(String, String, Object, MessagePostProcessor, CorrelationData) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
- convertAndSend(String, String, Object, CorrelationData) - Method in interface org.springframework.amqp.rabbit.core.RabbitOperations
-
Convert a Java object to an Amqp
Message
and send it to a specific exchange with a specific routing key. - convertAndSend(String, String, Object, CorrelationData) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
- convertAndSend(String, String, Object, MessagePostProcessor) - Method in interface org.springframework.amqp.rabbit.core.RabbitMessageOperations
-
Convert the given Object to serialized form, possibly using a
MessageConverter
, wrap it as a message, apply the given post processor, and send the resulting message to a specific exchange with a specific routing key. - convertAndSend(String, String, Object, MessagePostProcessor) - Method in class org.springframework.amqp.rabbit.core.RabbitMessagingTemplate
- converterWinsContentType() - Method in annotation type org.springframework.amqp.rabbit.annotation.RabbitListener
-
Set to 'false' to override any content type headers set by the message converter with the value of the 'replyContentType' property.
- convertMessageIfNecessary(Object) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
- convertRabbitAccessException(Exception) - Method in class org.springframework.amqp.rabbit.connection.RabbitAccessor
- convertRabbitAccessException(Throwable) - Static method in class org.springframework.amqp.rabbit.support.RabbitExceptionTranslator
- convertSendAndReceive(Object) - Method in interface org.springframework.amqp.core.AmqpTemplate
-
Basic RPC pattern with conversion.
- convertSendAndReceive(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(Object) - Method in class org.springframework.amqp.rabbit.AsyncRabbitTemplate
- convertSendAndReceive(Object) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
- convertSendAndReceive(Object, MessagePostProcessor) - Method in interface org.springframework.amqp.core.AmqpTemplate
-
Basic RPC pattern with conversion.
- 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(Object, MessagePostProcessor) - Method in class org.springframework.amqp.rabbit.AsyncRabbitTemplate
- convertSendAndReceive(Object, MessagePostProcessor) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
- convertSendAndReceive(Object, MessagePostProcessor, CorrelationData) - Method in interface org.springframework.amqp.rabbit.core.RabbitOperations
-
Basic RPC pattern with conversion.
- convertSendAndReceive(Object, MessagePostProcessor, CorrelationData) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
- convertSendAndReceive(Object, CorrelationData) - Method in interface org.springframework.amqp.rabbit.core.RabbitOperations
-
Basic RPC pattern with conversion.
- convertSendAndReceive(Object, CorrelationData) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
- convertSendAndReceive(String, Object) - Method in interface org.springframework.amqp.core.AmqpTemplate
-
Basic RPC pattern with conversion.
- 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, Object) - Method in class org.springframework.amqp.rabbit.AsyncRabbitTemplate
- convertSendAndReceive(String, Object) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
- convertSendAndReceive(String, 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.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, Object, MessagePostProcessor) - Method in class org.springframework.amqp.rabbit.AsyncRabbitTemplate
- convertSendAndReceive(String, Object, MessagePostProcessor) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
- convertSendAndReceive(String, Object, MessagePostProcessor, CorrelationData) - Method in interface org.springframework.amqp.rabbit.core.RabbitOperations
-
Basic RPC pattern with conversion.
- convertSendAndReceive(String, Object, MessagePostProcessor, CorrelationData) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
- convertSendAndReceive(String, Object, CorrelationData) - Method in interface org.springframework.amqp.rabbit.core.RabbitOperations
-
Basic RPC pattern with conversion.
- convertSendAndReceive(String, Object, CorrelationData) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
- convertSendAndReceive(String, 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.AsyncAmqpTemplate
-
Convert the object to a message and send it to the provided exchange and routing key.
- convertSendAndReceive(String, String, Object) - Method in class org.springframework.amqp.rabbit.AsyncRabbitTemplate
- convertSendAndReceive(String, String, Object) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
- convertSendAndReceive(String, String, Object, Class<T>) - Method in interface org.springframework.amqp.rabbit.core.RabbitMessageOperations
-
Convert the given request Object to serialized form, possibly using a
MessageConverter
, send it as aMessage
to a specific exchange with a specific routing key, receive the reply and convert its body of the specified target class. - convertSendAndReceive(String, String, Object, Class<T>) - Method in class org.springframework.amqp.rabbit.core.RabbitMessagingTemplate
- convertSendAndReceive(String, String, Object, Class<T>, MessagePostProcessor) - Method in interface org.springframework.amqp.rabbit.core.RabbitMessageOperations
-
Convert the given request Object to serialized form, possibly using a
MessageConverter
, apply the given post processor and send the resultingMessage
to a specific exchange with a specific routing key, receive the reply and convert its body of the given target class. - convertSendAndReceive(String, String, Object, Class<T>, MessagePostProcessor) - Method in class org.springframework.amqp.rabbit.core.RabbitMessagingTemplate
- convertSendAndReceive(String, String, Object, Map<String, Object>, Class<T>) - Method in interface org.springframework.amqp.rabbit.core.RabbitMessageOperations
-
Convert the given request Object to serialized form, possibly using a
MessageConverter
, send it as aMessage
with the given headers, to a specific exchange with a specific routing key, receive the reply and convert its body of the specified target class. - convertSendAndReceive(String, String, Object, Map<String, Object>, Class<T>) - Method in class org.springframework.amqp.rabbit.core.RabbitMessagingTemplate
- convertSendAndReceive(String, String, Object, Map<String, Object>, Class<T>, MessagePostProcessor) - Method in interface org.springframework.amqp.rabbit.core.RabbitMessageOperations
-
Convert the given request Object to serialized form, possibly using a
MessageConverter
, wrap it as a message with the given headers, apply the given post processor and send the resultingMessage
to a specific exchange with a specific routing key,, receive the reply and convert its body of the given target class. - convertSendAndReceive(String, String, Object, Map<String, Object>, Class<T>, MessagePostProcessor) - Method in class org.springframework.amqp.rabbit.core.RabbitMessagingTemplate
- convertSendAndReceive(String, 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.AsyncAmqpTemplate
-
Convert the object to a message and send it to the provided exchange and routing key after invoking the
MessagePostProcessor
. - convertSendAndReceive(String, String, Object, MessagePostProcessor) - Method in class org.springframework.amqp.rabbit.AsyncRabbitTemplate
- convertSendAndReceive(String, String, Object, MessagePostProcessor) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
- convertSendAndReceive(String, String, Object, MessagePostProcessor, CorrelationData) - Method in interface org.springframework.amqp.rabbit.core.RabbitOperations
-
Basic RPC pattern with conversion.
- convertSendAndReceive(String, String, Object, MessagePostProcessor, CorrelationData) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
- convertSendAndReceive(String, String, Object, CorrelationData) - Method in interface org.springframework.amqp.rabbit.core.RabbitOperations
-
Basic RPC pattern with conversion.
- convertSendAndReceive(String, String, Object, CorrelationData) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
- convertSendAndReceiveAsType(Object, MessagePostProcessor, CorrelationData, ParameterizedTypeReference<T>) - Method in interface org.springframework.amqp.rabbit.core.RabbitOperations
-
Basic RPC pattern with conversion.
- convertSendAndReceiveAsType(Object, MessagePostProcessor, CorrelationData, ParameterizedTypeReference<T>) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
- 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(Object, MessagePostProcessor, ParameterizedTypeReference<C>) - Method in class org.springframework.amqp.rabbit.AsyncRabbitTemplate
- convertSendAndReceiveAsType(Object, MessagePostProcessor, ParameterizedTypeReference<T>) - Method in interface org.springframework.amqp.core.AmqpTemplate
-
Basic RPC pattern with conversion.
- convertSendAndReceiveAsType(Object, MessagePostProcessor, ParameterizedTypeReference<T>) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
- convertSendAndReceiveAsType(Object, CorrelationData, ParameterizedTypeReference<T>) - Method in interface org.springframework.amqp.rabbit.core.RabbitOperations
-
Basic RPC pattern with conversion.
- convertSendAndReceiveAsType(Object, CorrelationData, ParameterizedTypeReference<T>) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
- 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(Object, ParameterizedTypeReference<C>) - Method in class org.springframework.amqp.rabbit.AsyncRabbitTemplate
- convertSendAndReceiveAsType(Object, ParameterizedTypeReference<T>) - Method in interface org.springframework.amqp.core.AmqpTemplate
-
Basic RPC pattern with conversion.
- convertSendAndReceiveAsType(Object, ParameterizedTypeReference<T>) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
- convertSendAndReceiveAsType(String, Object, MessagePostProcessor, CorrelationData, ParameterizedTypeReference<T>) - Method in interface org.springframework.amqp.rabbit.core.RabbitOperations
-
Basic RPC pattern with conversion.
- convertSendAndReceiveAsType(String, Object, MessagePostProcessor, CorrelationData, ParameterizedTypeReference<T>) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
- 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, Object, MessagePostProcessor, ParameterizedTypeReference<C>) - Method in class org.springframework.amqp.rabbit.AsyncRabbitTemplate
- convertSendAndReceiveAsType(String, 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 class org.springframework.amqp.rabbit.core.RabbitTemplate
- convertSendAndReceiveAsType(String, Object, CorrelationData, ParameterizedTypeReference<T>) - Method in interface org.springframework.amqp.rabbit.core.RabbitOperations
-
Basic RPC pattern with conversion.
- convertSendAndReceiveAsType(String, Object, CorrelationData, ParameterizedTypeReference<T>) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
- 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, Object, ParameterizedTypeReference<C>) - Method in class org.springframework.amqp.rabbit.AsyncRabbitTemplate
- convertSendAndReceiveAsType(String, Object, ParameterizedTypeReference<T>) - Method in interface org.springframework.amqp.core.AmqpTemplate
-
Basic RPC pattern with conversion.
- convertSendAndReceiveAsType(String, Object, ParameterizedTypeReference<T>) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
- convertSendAndReceiveAsType(String, String, Object, MessagePostProcessor, CorrelationData, ParameterizedTypeReference<T>) - Method in interface org.springframework.amqp.rabbit.core.RabbitOperations
-
Basic RPC pattern with conversion.
- convertSendAndReceiveAsType(String, String, Object, MessagePostProcessor, CorrelationData, ParameterizedTypeReference<T>) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
- 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
. - convertSendAndReceiveAsType(String, String, Object, MessagePostProcessor, ParameterizedTypeReference<C>) - Method in class org.springframework.amqp.rabbit.AsyncRabbitTemplate
- convertSendAndReceiveAsType(String, 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 class org.springframework.amqp.rabbit.core.RabbitTemplate
- convertSendAndReceiveAsType(String, String, Object, CorrelationData, ParameterizedTypeReference<T>) - Method in interface org.springframework.amqp.rabbit.core.RabbitOperations
-
Basic RPC pattern with conversion.
- 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(String, String, Object, ParameterizedTypeReference<C>) - Method in class org.springframework.amqp.rabbit.AsyncRabbitTemplate
- convertSendAndReceiveAsType(String, 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 class org.springframework.amqp.rabbit.core.RabbitTemplate
- convertSendAndReceiveRaw(String, String, Object, MessagePostProcessor, CorrelationData) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
-
Convert and send a message and return the raw reply message, or null.
- 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
- CORRELATED - org.springframework.amqp.rabbit.connection.CachingConnectionFactory.ConfirmType
-
Use with
CorrelationData
to correlate confirmations with sent messsages. - 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
- correlationConvertAndSend(Object, CorrelationData) - Method in interface org.springframework.amqp.rabbit.core.RabbitOperations
-
Convert a Java object to an Amqp
Message
and send it to a default exchange with a default routing key. - correlationConvertAndSend(Object, CorrelationData) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
- CorrelationData - Class in org.springframework.amqp.rabbit.connection
-
Base class for correlating publisher confirms to sent messages.
- CorrelationData() - Constructor for class org.springframework.amqp.rabbit.connection.CorrelationData
-
Construct an instance with a null Id.
- CorrelationData(String) - Constructor for class org.springframework.amqp.rabbit.connection.CorrelationData
-
Construct an instance with the supplied id.
- CorrelationData.Confirm - Class in org.springframework.amqp.rabbit.connection
-
Represents a publisher confirmation.
- CorrelationDataPostProcessor - Interface in org.springframework.amqp.rabbit.core
-
A callback invoked immediately before publishing a message to update, replace, or create correlation data for publisher confirms.
- countDown() - Method in class org.springframework.amqp.rabbit.connection.PendingConfirm
-
Count down the returned message latch; call after the listener has been called.
- counter - Variable in class org.springframework.amqp.rabbit.config.AbstractRabbitListenerContainerFactory
- createBareConnection() - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
- createBlockingQueueConsumer() - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer
- createChannel(boolean) - Method in interface org.springframework.amqp.rabbit.connection.Connection
-
Create a new channel, using an internally allocated channel number.
- createChannel(boolean) - Method in class org.springframework.amqp.rabbit.connection.SimpleConnection
- createChannel(Channel, ExecutorService) - Method in interface org.springframework.amqp.rabbit.connection.PublisherCallbackChannelFactory
-
Create a
PublisherCallbackChannel
instance based on the provided delegate and executor. - createChannel(Connection) - Method in interface org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils.ResourceFactory
-
Create a new RabbitMQ Session for registration with a RabbitResourceHolder.
- createClient(String, String, String) - Method in class org.springframework.amqp.rabbit.connection.LocalizedQueueConnectionFactory
-
Create a client instance.
- createConnection() - Method in class org.springframework.amqp.rabbit.connection.AbstractRoutingConnectionFactory
- createConnection() - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory
- createConnection() - Method in interface org.springframework.amqp.rabbit.connection.ConnectionFactory
- createConnection() - Method in interface org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils.ResourceFactory
-
Create a new RabbitMQ Connection for registration with a RabbitResourceHolder.
- createConnection() - Method in class org.springframework.amqp.rabbit.connection.LocalizedQueueConnectionFactory
- createConnection() - Method in class org.springframework.amqp.rabbit.connection.PooledChannelConnectionFactory
- createConnection() - Method in class org.springframework.amqp.rabbit.connection.RabbitAccessor
-
Create a RabbitMQ Connection via this template's ConnectionFactory and its host and port values.
- createConnection() - Method in class org.springframework.amqp.rabbit.connection.ThreadChannelConnectionFactory
- createConnection(ConnectionFactory, boolean) - Static method in class org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils
-
Create a connection with this connection factory and/or its publisher factory.
- createConnectionFactory(String, String) - Method in class org.springframework.amqp.rabbit.connection.LocalizedQueueConnectionFactory
-
Create a dedicated connection factory for the address.
- createConsumerTag(String) - Method in interface org.springframework.amqp.support.ConsumerTagStrategy
-
Create the consumer tag, optionally based on the queue name that the consumer will listen to.
- createContainerInstance() - Method in class org.springframework.amqp.rabbit.config.AbstractRabbitListenerContainerFactory
-
Create an empty container instance.
- createContainerInstance() - Method in class org.springframework.amqp.rabbit.config.DirectRabbitListenerContainerFactory
- createContainerInstance() - Method in class org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory
- createContainerInstance() - Method in class org.springframework.rabbit.stream.config.StreamRabbitListenerContainerFactory
-
Create an instance of the listener container.
- createElementDescription(Element) - Static method in class org.springframework.amqp.rabbit.config.NamespaceUtils
-
Provides a user friendly description of an element based on its node name and, if available, its "id" attribute value.
- createEventQueue() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
-
Subclasses can override this method to inject a custom queue implementation.
- createExpressionDefIfAttributeDefined(String, Element) - Static method in class org.springframework.amqp.rabbit.config.NamespaceUtils
- createExpressionDefinitionFromValueOrExpression(String, String, ParserContext, Element, boolean) - Static method in class org.springframework.amqp.rabbit.config.NamespaceUtils
- createInstance() - Method in class org.springframework.amqp.rabbit.config.ListenerContainerFactoryBean
- createInstance() - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
- createInstance() - Method in class org.springframework.amqp.rabbit.support.ExpressionFactoryBean
- createListenerContainer() - Method in interface org.springframework.amqp.rabbit.listener.RabbitListenerContainerFactory
-
Create a
MessageListenerContainer
with noMessageListener
or queues; the listener must be added later before the container is started. - createListenerContainer(RabbitListenerEndpoint) - Method in class org.springframework.amqp.rabbit.config.AbstractRabbitListenerContainerFactory
- createListenerContainer(RabbitListenerEndpoint) - Method in class org.springframework.amqp.rabbit.config.BaseRabbitListenerContainerFactory
- createListenerContainer(RabbitListenerEndpoint) - Method in interface org.springframework.amqp.rabbit.listener.RabbitListenerContainerFactory
-
Create a
MessageListenerContainer
for the givenRabbitListenerEndpoint
. - createListenerContainer(RabbitListenerEndpoint) - Method in class org.springframework.rabbit.stream.config.StreamRabbitListenerContainerFactory
- createListenerContainer(RabbitListenerEndpoint, RabbitListenerContainerFactory<?>) - Method in class org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistry
-
Create and start a new
MessageListenerContainer
using the specified factory. - createMessage(Object, MessageProperties) - Method in class org.springframework.amqp.support.converter.AbstractJackson2MessageConverter
- 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.
- 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.
- createMessageListener(MessageListenerContainer) - Method in class org.springframework.amqp.rabbit.config.SimpleRabbitListenerEndpoint
- createMessageListener(MessageListenerContainer) - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint
-
Create a
MessageListener
that is able to serve this endpoint for the specified container. - createMessageListener(MessageListenerContainer) - Method in class org.springframework.amqp.rabbit.listener.MethodRabbitListenerEndpoint
- createMessageListenerInstance() - Method in class org.springframework.amqp.rabbit.listener.MethodRabbitListenerEndpoint
-
Create an empty
MessagingMessageListenerAdapter
instance. - createObjectInputStream(InputStream, String) - Method in class org.springframework.amqp.support.converter.SimpleMessageConverter
-
Create an ObjectInputStream for the given InputStream and codebase.
- createRabbitConnectionFactory() - Method in class org.springframework.amqp.rabbit.log4j2.AmqpAppender.AmqpManager
-
Create the
ConnectionFactory
. - createRabbitConnectionFactory() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
-
Create the
ConnectionFactory
. - createRabbitTemplate(ConnectionFactory) - Method in class org.springframework.amqp.rabbit.core.RabbitGatewaySupport
-
Create a RabbitTemplate for the given ConnectionFactory.
- createSSLContext() - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
-
Override this method to create and/or configure the
SSLContext
used by theConnectionFactory
. - CustomExchange - Class in org.springframework.amqp.core
-
Simple container collecting information to describe a custom exchange.
- CustomExchange(String, String) - Constructor for class org.springframework.amqp.core.CustomExchange
- CustomExchange(String, String, boolean, boolean) - Constructor for class org.springframework.amqp.core.CustomExchange
- CustomExchange(String, String, boolean, boolean, Map<String, Object>) - Constructor for class org.springframework.amqp.core.CustomExchange
D
- deactivate() - Method in class org.springframework.amqp.rabbit.support.ActiveObjectCounter
- deadLetterExchange(String) - Method in class org.springframework.amqp.core.QueueBuilder
-
Set the dead-letter exchange to which to route expired or rejected messages.
- deadLetterRoutingKey(String) - Method in class org.springframework.amqp.core.QueueBuilder
-
Set the routing key to use when routing expired or rejected messages to the dead-letter exchange.
- debatch(Message) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- deBatch(Message, Consumer<Message>) - Method in interface org.springframework.amqp.rabbit.batch.BatchingStrategy
-
Decode a message into fragments.
- deBatch(Message, Consumer<Message>) - Method in class org.springframework.amqp.rabbit.batch.SimpleBatchingStrategy
-
Debatch a message that has a header with
MessageProperties.SPRING_BATCH_FORMAT
set toMessageProperties.BATCH_FORMAT_LENGTH_HEADER4
. - Declarable - Interface in org.springframework.amqp.core
-
Classes implementing this interface can be auto-declared with the broker during context initialization by an
AmqpAdmin
. - DeclarableCustomizer - Interface in org.springframework.amqp.core
-
Beans of this type are invoked by the
AmqpAdmin
before declaring theDeclarable
, allowing customization thereof. - Declarables - Class in org.springframework.amqp.core
-
A collection of
Declarable
objects; used to declare multiple objects on the broker using a single bean declaration for the collection. - Declarables(Collection<? extends Declarable>) - Constructor for class org.springframework.amqp.core.Declarables
- Declarables(Declarable...) - Constructor for class org.springframework.amqp.core.Declarables
- DeclarationExceptionEvent - Class in org.springframework.amqp.rabbit.core
-
Application event published when a declaration exception occurs.
- DeclarationExceptionEvent(Object, Declarable, Throwable) - Constructor for class org.springframework.amqp.rabbit.core.DeclarationExceptionEvent
- declare() - Method in annotation type org.springframework.amqp.rabbit.annotation.Exchange
- declare() - Method in annotation type org.springframework.amqp.rabbit.annotation.Queue
- declare() - Method in annotation type org.springframework.amqp.rabbit.annotation.QueueBinding
- DECLARE_METHOD_ID_10 - Static variable in class org.springframework.amqp.rabbit.connection.RabbitUtils
-
AMQP declare method.
- declareBinding(Binding) - Method in interface org.springframework.amqp.core.AmqpAdmin
-
Declare a binding of a queue to an exchange.
- declareBinding(Binding) - Method in class org.springframework.amqp.rabbit.core.RabbitAdmin
- declareExchange(Exchange) - Method in interface org.springframework.amqp.core.AmqpAdmin
-
Declare an exchange.
- declareExchange(Exchange) - Method in class org.springframework.amqp.rabbit.core.RabbitAdmin
- DeclareExchangeConnectionListener - Class in org.springframework.amqp.rabbit.core
-
A
ConnectionListener
that will declare a single exchange when the connection is established. - DeclareExchangeConnectionListener(Exchange, RabbitAdmin) - Constructor for class org.springframework.amqp.rabbit.core.DeclareExchangeConnectionListener
- declareQueue() - Method in interface org.springframework.amqp.core.AmqpAdmin
-
Declare a queue whose name is automatically named.
- declareQueue() - Method in class org.springframework.amqp.rabbit.core.RabbitAdmin
-
Declares a server-named exclusive, autodelete, non-durable queue.
- declareQueue(Queue) - Method in interface org.springframework.amqp.core.AmqpAdmin
-
Declare the given queue.
- declareQueue(Queue) - Method in class org.springframework.amqp.rabbit.core.RabbitAdmin
-
Declare the given queue.
- declareTransactional(Channel) - Static method in class org.springframework.amqp.rabbit.connection.RabbitUtils
-
Declare to that broker that a channel is going to be used transactionally, and convert exceptions that arise.
- DEFAULT - Static variable in class org.springframework.amqp.core.Base64UrlNamingStrategy
-
The default instance - using
spring.gen-
as the prefix. - DEFAULT - Static variable in class org.springframework.amqp.core.DirectExchange
-
The default exchange.
- DEFAULT - Static variable in class org.springframework.amqp.core.UUIDNamingStrategy
-
The default instance.
- DEFAULT_CHARSET - Static variable in class org.springframework.amqp.support.converter.AbstractJackson2MessageConverter
-
The charset used when converting
String
to/frombyte[]
. - DEFAULT_CHARSET - Static variable in class org.springframework.amqp.support.converter.SerializerMessageConverter
- DEFAULT_CHARSET - Static variable in class org.springframework.amqp.support.converter.SimpleMessageConverter
- DEFAULT_CLASSID_FIELD_NAME - Static variable in class org.springframework.amqp.support.converter.AbstractJavaTypeMapper
- DEFAULT_CLASSID_FIELD_NAME - Static variable in class org.springframework.amqp.support.converter.DefaultClassMapper
- DEFAULT_CLOSE_TIMEOUT - Static variable in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
- DEFAULT_CONTENT_CLASSID_FIELD_NAME - Static variable in class org.springframework.amqp.support.converter.AbstractJavaTypeMapper
- DEFAULT_CONTENT_TYPE - Static variable in class org.springframework.amqp.core.MessageProperties
- DEFAULT_DEBATCHING_ENABLED - Static variable in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- DEFAULT_DELIVERY_MODE - Static variable in class org.springframework.amqp.core.MessageProperties
- DEFAULT_EXCHANGE_NAME - Static variable in class org.springframework.amqp.rabbit.core.RabbitAdmin
-
The default exchange name.
- DEFAULT_FRAME_MAX_HEADROOM - Static variable in class org.springframework.amqp.rabbit.retry.RepublishMessageRecoverer
- DEFAULT_KEY_CLASSID_FIELD_NAME - Static variable in class org.springframework.amqp.support.converter.AbstractJavaTypeMapper
- DEFAULT_PORT - Static variable in class org.springframework.amqp.rabbit.junit.BrokerTestUtils
- DEFAULT_PREFETCH_COUNT - Static variable in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- DEFAULT_PRIORITY - Static variable in class org.springframework.amqp.core.MessageProperties
- DEFAULT_QUEUE_NAME - Static variable in class org.springframework.amqp.rabbit.junit.BrokerRunningSupport
- DEFAULT_RABBIT_LISTENER_CONTAINER_FACTORY_BEAN_NAME - Static variable in class org.springframework.amqp.rabbit.annotation.RabbitListenerAnnotationBeanPostProcessor
-
The bean name of the default
RabbitListenerContainerFactory
. - DEFAULT_RECEIVE_TIMEOUT - Static variable in class org.springframework.amqp.rabbit.AsyncRabbitTemplate
- DEFAULT_RECEIVE_TIMEOUT - Static variable in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer
- DEFAULT_RECOVERY_INTERVAL - Static variable in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
-
The default recovery interval: 5000 ms = 5 seconds.
- DEFAULT_SHUTDOWN_TIMEOUT - Static variable in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- DefaultClassMapper - Class in org.springframework.amqp.support.converter
-
Maps to/from JSON using type information in the
MessageProperties
; the default name of the message property containing the type is "__TypeId__". - DefaultClassMapper() - Constructor for class org.springframework.amqp.support.converter.DefaultClassMapper
- DefaultExceptionStrategy() - Constructor for class org.springframework.amqp.rabbit.listener.ConditionalRejectingErrorHandler.DefaultExceptionStrategy
- DefaultJackson2JavaTypeMapper - Class in org.springframework.amqp.support.converter
-
Jackson 2 type mapper.
- DefaultJackson2JavaTypeMapper() - Constructor for class org.springframework.amqp.support.converter.DefaultJackson2JavaTypeMapper
- DefaultMessagePropertiesConverter - Class in org.springframework.amqp.rabbit.support
-
Default implementation of the
MessagePropertiesConverter
strategy. - DefaultMessagePropertiesConverter() - Constructor for class org.springframework.amqp.rabbit.support.DefaultMessagePropertiesConverter
-
Construct an instance where
LongString
s will be returned unconverted when longer than 1024 bytes. - DefaultMessagePropertiesConverter(int) - Constructor for class org.springframework.amqp.rabbit.support.DefaultMessagePropertiesConverter
-
Construct an instance where
LongString
s will be returned unconverted when longer than this limit. - DefaultMessagePropertiesConverter(int, boolean) - Constructor for class org.springframework.amqp.rabbit.support.DefaultMessagePropertiesConverter
-
Construct an instance where
LongString
s will be returned unconverted or as aDataInputStream
when longer than this limit. - DefaultStreamMessageConverter - Class in org.springframework.rabbit.stream.support.converter
-
Default
StreamMessageConverter
. - DefaultStreamMessageConverter() - Constructor for class org.springframework.rabbit.stream.support.converter.DefaultStreamMessageConverter
-
Construct an instance using a
WrapperMessageBuilder
. - DefaultStreamMessageConverter(Codec) - Constructor for class org.springframework.rabbit.stream.support.converter.DefaultStreamMessageConverter
-
Construct an instance using the provided codec.
- DeflaterPostProcessor - Class in org.springframework.amqp.support.postprocessor
-
A post processor that uses a
DeflaterOutputStream
to compress the message body. - DeflaterPostProcessor() - Constructor for class org.springframework.amqp.support.postprocessor.DeflaterPostProcessor
- DeflaterPostProcessor(boolean) - Constructor for class org.springframework.amqp.support.postprocessor.DeflaterPostProcessor
- DELAY - Static variable in class org.springframework.amqp.support.AmqpHeaders
- delayed() - Method in class org.springframework.amqp.core.ExchangeBuilder
-
Set the delayed flag.
- delayed() - Method in annotation type org.springframework.amqp.rabbit.annotation.Exchange
- delegate() - Method in interface org.springframework.amqp.rabbit.core.RabbitTemplate.ReturnsCallback
-
Deprecated.- will be removed with
RabbitTemplate.ReturnCallback
. - DelegatingDecompressingPostProcessor - Class in org.springframework.amqp.support.postprocessor
-
A
MessagePostProcessor
that delegates to one of itsMessagePostProcessor
s depending on the content encoding. - DelegatingDecompressingPostProcessor() - Constructor for class org.springframework.amqp.support.postprocessor.DelegatingDecompressingPostProcessor
-
Construct an instance with the default decompressors (gzip, zip, deflate) with the alwaysDecompress flag set to true.
- DelegatingInvocableHandler - Class in org.springframework.amqp.rabbit.listener.adapter
-
Delegates to an
InvocableHandlerMethod
based on the message payload type. - DelegatingInvocableHandler(List<InvocableHandlerMethod>, Object, BeanExpressionResolver, BeanExpressionContext) - Constructor for class org.springframework.amqp.rabbit.listener.adapter.DelegatingInvocableHandler
-
Construct an instance with the supplied handlers for the bean.
- DelegatingInvocableHandler(List<InvocableHandlerMethod>, InvocableHandlerMethod, Object, BeanExpressionResolver, BeanExpressionContext) - Constructor for class org.springframework.amqp.rabbit.listener.adapter.DelegatingInvocableHandler
-
Construct an instance with the supplied handlers for the bean.
- DelegatingInvocableHandler(List<InvocableHandlerMethod>, InvocableHandlerMethod, Object, BeanExpressionResolver, BeanExpressionContext, Validator) - Constructor for class org.springframework.amqp.rabbit.listener.adapter.DelegatingInvocableHandler
-
Construct an instance with the supplied handlers for the bean.
- deleteExchange(String) - Method in interface org.springframework.amqp.core.AmqpAdmin
-
Delete an exchange.
- deleteExchange(String) - Method in class org.springframework.amqp.rabbit.core.RabbitAdmin
- deleteExchanges(String...) - Method in class org.springframework.amqp.rabbit.junit.BrokerRunning
-
Delete arbitrary exchanges from the broker.
- deleteExchanges(String...) - Method in class org.springframework.amqp.rabbit.junit.BrokerRunningSupport
-
Delete arbitrary exchanges from the broker.
- deleteQueue(String) - Method in interface org.springframework.amqp.core.AmqpAdmin
-
Delete a queue, without regard for whether it is in use or has messages on it.
- deleteQueue(String) - Method in class org.springframework.amqp.rabbit.core.RabbitAdmin
- deleteQueue(String, boolean, boolean) - Method in interface org.springframework.amqp.core.AmqpAdmin
-
Delete a queue.
- deleteQueue(String, boolean, boolean) - Method in class org.springframework.amqp.rabbit.core.RabbitAdmin
- deleteQueues(String...) - Method in class org.springframework.amqp.rabbit.junit.BrokerRunning
-
Delete arbitrary queues from the broker.
- deleteQueues(String...) - Method in class org.springframework.amqp.rabbit.junit.BrokerRunningSupport
-
Delete arbitrary queues from the broker.
- Delivery - Class in org.springframework.amqp.rabbit.support
-
Encapsulates an arbitrary message - simple "bean" holder structure.
- Delivery(String, Envelope, AMQP.BasicProperties, byte[], String) - Constructor for class org.springframework.amqp.rabbit.support.Delivery
- DELIVERY_MODE - Static variable in class org.springframework.amqp.support.AmqpHeaders
- DELIVERY_TAG - Static variable in class org.springframework.amqp.support.AmqpHeaders
- deliveryLimit(int) - Method in class org.springframework.amqp.core.QueueBuilder
-
Set the delivery limit; only applies to quorum queues.
- deserialize(byte[]) - Static method in class org.springframework.amqp.utils.SerializationUtils
-
Deserialize the bytes.
- deserialize(InputStream, Set<String>, ClassLoader) - Static method in class org.springframework.amqp.utils.SerializationUtils
-
Deserialize the stream.
- deserialize(ObjectInputStream) - Static method in class org.springframework.amqp.utils.SerializationUtils
-
Deserialize the stream.
- destination - Variable in class org.springframework.amqp.core.BindingBuilder.HeadersExchangeMapConfigurer
- destroy() - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
- destroy() - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory
-
Close the underlying shared connection.
- destroy() - Method in class org.springframework.amqp.rabbit.connection.LocalizedQueueConnectionFactory
- destroy() - Method in class org.springframework.amqp.rabbit.connection.PooledChannelConnectionFactory
- destroy() - Method in class org.springframework.amqp.rabbit.connection.ThreadChannelConnectionFactory
- destroy() - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
- destroy() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
-
Calls
AbstractMessageListenerContainer.shutdown()
when the BeanFactory destroys the container instance. - destroy() - Method in class org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistry
- determineConfirmsReturnsCapability(ConnectionFactory) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
- determineCurrentLookupKey() - Method in class org.springframework.amqp.rabbit.connection.AbstractRoutingConnectionFactory
-
Determine the current lookup key.
- determineCurrentLookupKey() - Method in class org.springframework.amqp.rabbit.connection.SimpleRoutingConnectionFactory
- determineTargetConnectionFactory() - Method in class org.springframework.amqp.rabbit.connection.AbstractRoutingConnectionFactory
-
Retrieve the current target
ConnectionFactory
. - direct - org.springframework.amqp.rabbit.config.ListenerContainerFactoryBean.Type
- direct - org.springframework.amqp.rabbit.test.context.SpringRabbitTest.ContainerType
- DIRECT - Static variable in class org.springframework.amqp.core.ExchangeTypes
-
Direct exchange.
- directExchange(String) - Static method in class org.springframework.amqp.core.ExchangeBuilder
-
Return a
DirectExchange
builder. - DirectExchange - Class in org.springframework.amqp.core
-
Simple container collecting information to describe a direct exchange.
- DirectExchange(String) - Constructor for class org.springframework.amqp.core.DirectExchange
- DirectExchange(String, boolean, boolean) - Constructor for class org.springframework.amqp.core.DirectExchange
- DirectExchange(String, boolean, boolean, Map<String, Object>) - Constructor for class org.springframework.amqp.core.DirectExchange
- DirectExchangeParser - Class in org.springframework.amqp.rabbit.config
- DirectExchangeParser() - Constructor for class org.springframework.amqp.rabbit.config.DirectExchangeParser
- DirectMessageListenerContainer - Class in org.springframework.amqp.rabbit.listener
-
The
SimpleMessageListenerContainer
is not so simple. - DirectMessageListenerContainer() - Constructor for class org.springframework.amqp.rabbit.listener.DirectMessageListenerContainer
-
Create an instance;
RabbitAccessor.setConnectionFactory(ConnectionFactory)
must be called before starting. - DirectMessageListenerContainer(ConnectionFactory) - Constructor for class org.springframework.amqp.rabbit.listener.DirectMessageListenerContainer
-
Create an instance with the provided connection factory.
- DirectRabbitListenerContainerFactory - Class in org.springframework.amqp.rabbit.config
-
A
RabbitListenerContainerFactory
implementation to build a regularDirectMessageListenerContainer
. - DirectRabbitListenerContainerFactory() - Constructor for class org.springframework.amqp.rabbit.config.DirectRabbitListenerContainerFactory
- DirectReplyToMessageListenerContainer - Class in org.springframework.amqp.rabbit.listener
-
Listener container for Direct ReplyTo only listens to the pseudo queue
Address.AMQ_RABBITMQ_REPLY_TO
. - DirectReplyToMessageListenerContainer(ConnectionFactory) - Constructor for class org.springframework.amqp.rabbit.listener.DirectReplyToMessageListenerContainer
- DirectReplyToMessageListenerContainer.ChannelHolder - Class in org.springframework.amqp.rabbit.listener
-
Holder for a channel; contains a consumer epoch used to prevent inappropriate release of the consumer after it has been allocated for reuse.
- doBegin(Object, TransactionDefinition) - Method in class org.springframework.amqp.rabbit.transaction.RabbitTransactionManager
- doCleanupAfterCompletion(Object) - Method in class org.springframework.amqp.rabbit.transaction.RabbitTransactionManager
- doCommit(DefaultTransactionStatus) - Method in class org.springframework.amqp.rabbit.transaction.RabbitTransactionManager
- doGetTransaction() - Method in class org.springframework.amqp.rabbit.transaction.RabbitTransactionManager
- doHandleResult(InvocationResult, Message, Channel, Object) - Method in class org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener
- doInitialize() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
-
Register any invokers within this container.
- doInitialize() - Method in class org.springframework.amqp.rabbit.listener.DirectMessageListenerContainer
- doInitialize() - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer
- doInRabbit(Channel) - Method in interface org.springframework.amqp.rabbit.core.ChannelCallback
-
Execute any number of operations against the supplied RabbitMQ
Channel
, possibly returning a result. - doInRabbit(RabbitOperations) - Method in interface org.springframework.amqp.rabbit.core.RabbitOperations.OperationsCallback
-
Execute any number of operations using a dedicated
Channel
as long as those operations are performed on the template argument and on the calling thread. - doInvokeListener(MessageListener, Object) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
-
Invoke the specified listener as Spring Rabbit MessageListener.
- doInvokeListener(ChannelAwareMessageListener, Channel, Object) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
-
Invoke the specified listener as Spring ChannelAwareMessageListener, exposing a new Rabbit Session (potentially with its own transaction) to the listener if demanded.
- doParse(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.amqp.rabbit.config.AbstractExchangeParser
- doParse(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.amqp.rabbit.config.QueueParser
- doParseBindings(Element, ParserContext, String, Element, AbstractExchangeParser) - Method in class org.springframework.amqp.rabbit.config.AbstractExchangeParser
- doPublish(Channel, Address, Message) - Method in class org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener
- doReceive(String) - Method in class org.springframework.amqp.rabbit.core.RabbitMessagingTemplate
- doReceiveNoWait(String) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
-
Non-blocking receive.
- doRedeclareElementsIfNecessary() - Method in class org.springframework.amqp.rabbit.listener.DirectMessageListenerContainer
- doResume(Object, Object) - Method in class org.springframework.amqp.rabbit.transaction.RabbitTransactionManager
- doRollback(DefaultTransactionStatus) - Method in class org.springframework.amqp.rabbit.transaction.RabbitTransactionManager
- doSend(Channel, String, String, Message, boolean, CorrelationData) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
-
Send the given message to the specified exchange.
- doSend(String, String, Message) - Method in class org.springframework.amqp.rabbit.retry.RepublishMessageRecoverer
-
Send the message.
- doSend(String, String, Message) - Method in class org.springframework.amqp.rabbit.retry.RepublishMessageRecovererWithConfirms
- doSend(String, String, Message<?>) - Method in class org.springframework.amqp.rabbit.core.RabbitMessagingTemplate
- doSend(String, Message<?>) - Method in class org.springframework.amqp.rabbit.core.RabbitMessagingTemplate
- doSend(AmqpAppender.Event, LogEvent, MessageProperties) - Method in class org.springframework.amqp.rabbit.log4j2.AmqpAppender
- doSendAndReceive(String, String, Message, CorrelationData) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
-
Send a message and wait for a reply.
- doSendAndReceive(String, String, Message<?>) - Method in class org.springframework.amqp.rabbit.core.RabbitMessagingTemplate
- doSendAndReceive(String, Message<?>) - Method in class org.springframework.amqp.rabbit.core.RabbitMessagingTemplate
- doSendAndReceiveWithFixed(String, String, Message, CorrelationData) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
- doSendAndReceiveWithFixed(String, String, Message, CorrelationData) - Method in class org.springframework.amqp.rabbit.test.TestRabbitTemplate
- doSendAndReceiveWithTemporary(String, String, Message, CorrelationData) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
- doSetPossibleAuthenticationFailureFatal(boolean) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- doSetPublisherConnectionFactory(AbstractConnectionFactory) - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
- doSetRollbackOnly(DefaultTransactionStatus) - Method in class org.springframework.amqp.rabbit.transaction.RabbitTransactionManager
- doShutdown() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
-
Close the registered invokers.
- doShutdown() - Method in class org.springframework.amqp.rabbit.listener.DirectMessageListenerContainer
- doShutdown() - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer
- doStart() - Method in class org.springframework.amqp.rabbit.core.BatchingRabbitTemplate
- doStart() - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
-
Perform additional start actions.
- doStart() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
-
Start this container, and notify all invoker tasks.
- doStart() - Method in class org.springframework.amqp.rabbit.listener.DirectMessageListenerContainer
- doStart() - Method in class org.springframework.amqp.rabbit.listener.DirectReplyToMessageListenerContainer
- doStart() - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer
-
Re-initializes this container's Rabbit message consumers, if not initialized already.
- doStop() - Method in class org.springframework.amqp.rabbit.core.BatchingRabbitTemplate
- doStop() - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
-
Perform additional stop actions.
- doStop() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
-
This method is invoked when the container is stopping.
- doStop() - Method in class org.springframework.amqp.rabbit.listener.DirectMessageListenerContainer
- doSuspend(Object) - Method in class org.springframework.amqp.rabbit.transaction.RabbitTransactionManager
- dropHead - org.springframework.amqp.core.QueueBuilder.Overflow
-
Drop the oldest message.
- durable() - Static method in class org.springframework.amqp.core.QueueBuilder
-
Creates a builder for a durable queue with a generated unique name -
spring.gen-<random>
. - durable() - Method in annotation type org.springframework.amqp.rabbit.annotation.Exchange
- durable() - Method in annotation type org.springframework.amqp.rabbit.annotation.Queue
-
Specifies if this queue should be durable.
- durable(boolean) - Method in class org.springframework.amqp.core.ExchangeBuilder
-
Set the durable flag.
- durable(String) - Static method in class org.springframework.amqp.core.QueueBuilder
-
Creates a builder for a durable queue.
E
- enableAfterCompletionFailureCapture(boolean) - Static method in class org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils
-
Call this method to enable capturing
AfterCompletionFailedException
s when using transaction synchronization. - EnableRabbit - Annotation Type in org.springframework.amqp.rabbit.annotation
-
Enable Rabbit listener annotated endpoints that are created under the cover by a
RabbitListenerContainerFactory
. - equals(Object) - Method in class org.springframework.amqp.core.Address
- equals(Object) - Method in class org.springframework.amqp.core.Message
- equals(Object) - Method in class org.springframework.amqp.core.MessageProperties
- equals(Object) - Method in class org.springframework.amqp.core.QueueInformation
- equals(Object) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- equals(Object) - Method in class org.springframework.rabbit.stream.support.StreamMessageProperties
- errorExchangeName - Variable in class org.springframework.amqp.rabbit.retry.RepublishMessageRecoverer
- errorHandler() - Method in annotation type org.springframework.amqp.rabbit.annotation.RabbitListener
-
Set an
RabbitListenerErrorHandler
to invoke if the listener method throws an exception. - errorRoutingKey - Variable in class org.springframework.amqp.rabbit.retry.RepublishMessageRecoverer
- errorRoutingKeyPrefix(String) - Method in class org.springframework.amqp.rabbit.retry.RepublishMessageRecoverer
-
Apply a prefix to the outbound routing key, which will be prefixed to the original message routing key (if no explicit routing key was provided in the constructor; ignored otherwise.
- errorTemplate - Variable in class org.springframework.amqp.rabbit.retry.RepublishMessageRecoverer
- evaluateExecutionCondition(ExtensionContext) - Method in class org.springframework.amqp.rabbit.junit.LogLevelsCondition
- evaluateExecutionCondition(ExtensionContext) - Method in class org.springframework.amqp.rabbit.junit.LongRunningIntegrationTestCondition
- evaluateExecutionCondition(ExtensionContext) - Method in class org.springframework.amqp.rabbit.junit.RabbitAvailableCondition
- Event(ILoggingEvent) - Constructor for class org.springframework.amqp.rabbit.logback.AmqpAppender.Event
- Event(LogEvent, Map<?, ?>) - Constructor for class org.springframework.amqp.rabbit.log4j2.AmqpAppender.Event
- EventSender() - Constructor for class org.springframework.amqp.rabbit.log4j2.AmqpAppender.EventSender
- EventSender() - Constructor for class org.springframework.amqp.rabbit.logback.AmqpAppender.EventSender
- exchange - Variable in class org.springframework.amqp.core.BindingBuilder.HeadersExchangeMapConfigurer
- exchange() - Method in annotation type org.springframework.amqp.rabbit.annotation.QueueBinding
- Exchange - Interface in org.springframework.amqp.core
-
Interface for all exchanges.
- Exchange - Annotation Type in org.springframework.amqp.rabbit.annotation
-
An exchange to which to bind a
RabbitListener
queue. - EXCHANGE - org.springframework.amqp.core.Binding.DestinationType
-
Exchange destination.
- EXCHANGE_CLASS_ID_40 - Static variable in class org.springframework.amqp.rabbit.connection.RabbitUtils
-
AMQP exchange class id.
- exchangeBind(String, String, String) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- exchangeBind(String, String, String, Map<String, Object>) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- exchangeBindNoWait(String, String, String, Map<String, Object>) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- ExchangeBuilder - Class in org.springframework.amqp.core
-
Builder providing a fluent API for building
Exchange
s. - ExchangeBuilder(String, String) - Constructor for class org.springframework.amqp.core.ExchangeBuilder
-
Construct an instance of the appropriate type.
- exchangeDeclare(String, BuiltinExchangeType) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- exchangeDeclare(String, BuiltinExchangeType, boolean) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- exchangeDeclare(String, BuiltinExchangeType, boolean, boolean, boolean, Map<String, Object>) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- exchangeDeclare(String, BuiltinExchangeType, boolean, boolean, Map<String, Object>) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- exchangeDeclare(String, String) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- exchangeDeclare(String, String, boolean) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- exchangeDeclare(String, String, boolean, boolean, boolean, Map<String, Object>) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- exchangeDeclare(String, String, boolean, boolean, Map<String, Object>) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- exchangeDeclareNoWait(String, BuiltinExchangeType, boolean, boolean, boolean, Map<String, Object>) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- exchangeDeclareNoWait(String, String, boolean, boolean, boolean, Map<String, Object>) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- exchangeDeclarePassive(String) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- exchangeDelete(String) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- exchangeDelete(String, boolean) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- exchangeDeleteNoWait(String, boolean) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- ExchangeTypes - Class in org.springframework.amqp.core
-
Constants for the standard Exchange type names.
- ExchangeTypes() - Constructor for class org.springframework.amqp.core.ExchangeTypes
- exchangeUnbind(String, String, String) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- exchangeUnbind(String, String, String, Map<String, Object>) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- exchangeUnbindNoWait(String, String, String, Map<String, Object>) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- exclusive() - Method in class org.springframework.amqp.core.QueueBuilder
-
The final queue will be exclusive.
- exclusive() - Method in annotation type org.springframework.amqp.rabbit.annotation.Queue
-
Specifies if this queue should be exclusive.
- exclusive() - Method in annotation type org.springframework.amqp.rabbit.annotation.RabbitListener
-
When
true
, a single consumer in the container will have exclusive use of theRabbitListener.queues()
, preventing other consumers from receiving messages from the queues. - execute(ChannelCallback<T>) - Method in interface org.springframework.amqp.rabbit.core.RabbitOperations
-
Execute the callback with a channel and reliably close the channel afterwards.
- execute(ChannelCallback<T>) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
- executeListener(Channel, Object) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
-
Execute the specified listener, committing or rolling back the transaction afterwards (if necessary).
- executor() - Method in annotation type org.springframework.amqp.rabbit.annotation.RabbitListener
-
Set the task executor bean name to use for this listener's container; overrides any executor set on the container factory.
- exist() - Method in class org.springframework.amqp.core.BindingBuilder.HeadersExchangeMapConfigurer.HeadersExchangeKeysBindingCreator
- exists() - Method in class org.springframework.amqp.core.BindingBuilder.HeadersExchangeMapConfigurer.HeadersExchangeSingleValueBindingCreator
- expectedQueueNames() - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
-
Invoked by the container during startup so it can verify the queue is correctly configured (if a simple reply queue name is used instead of exchange/routingKey).
- expectedQueueNames() - Method in interface org.springframework.amqp.rabbit.support.ListenerContainerAware
-
Return the queue names that the listener expects to listen to.
- EXPIRATION - Static variable in class org.springframework.amqp.support.AmqpHeaders
- expire(PublisherCallbackChannel.Listener, long) - Method in interface org.springframework.amqp.rabbit.connection.PublisherCallbackChannel
-
Expire (remove) any
PendingConfirm
s created before cutoffTime for the supplied listener and return them to the caller. - expire(PublisherCallbackChannel.Listener, long) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- expires(int) - Method in class org.springframework.amqp.core.QueueBuilder
-
Set the time that the queue can remain unused before being deleted.
- ExpressionFactoryBean - Class in org.springframework.amqp.rabbit.support
-
FactoryBean for creating Expression instances.
- ExpressionFactoryBean(String) - Constructor for class org.springframework.amqp.rabbit.support.ExpressionFactoryBean
- extractMessage(Message) - Method in class org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener
-
Extract the message body from the given Rabbit message.
- extractPayload(Message) - Method in class org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter.MessagingMessageConverterAdapter
- extractPayload(Message) - Method in class org.springframework.amqp.support.converter.MessagingMessageConverter
-
Extract the payload of the specified
Message
.
F
- factory() - Static method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- FALSE - Static variable in annotation type org.springframework.amqp.rabbit.annotation.Exchange
- FANOUT - Static variable in class org.springframework.amqp.core.ExchangeTypes
-
Fanout exchange.
- fanoutExchange(String) - Static method in class org.springframework.amqp.core.ExchangeBuilder
-
Return a
FanoutExchange
builder. - FanoutExchange - Class in org.springframework.amqp.core
-
Simple container collecting information to describe a fanout exchange.
- FanoutExchange(String) - Constructor for class org.springframework.amqp.core.FanoutExchange
- FanoutExchange(String, boolean, boolean) - Constructor for class org.springframework.amqp.core.FanoutExchange
- FanoutExchange(String, boolean, boolean, Map<String, Object>) - Constructor for class org.springframework.amqp.core.FanoutExchange
- FanoutExchangeParser - Class in org.springframework.amqp.rabbit.config
- FanoutExchangeParser() - Constructor for class org.springframework.amqp.rabbit.config.FanoutExchangeParser
- fatal() - Static method in class org.springframework.amqp.rabbit.junit.BrokerRunning
- fatal() - Static method in class org.springframework.amqp.rabbit.junit.BrokerRunningSupport
- FatalExceptionStrategy - Interface in org.springframework.amqp.rabbit.listener
-
A strategy interface for the
ConditionalRejectingErrorHandler
to decide whether an exception should be considered to be fatal and the message should not be requeued. - FatalListenerExecutionException - Exception in org.springframework.amqp.rabbit.listener.exception
-
Exception to be thrown when the execution of a listener method failed with an irrecoverable problem.
- FatalListenerExecutionException(String) - Constructor for exception org.springframework.amqp.rabbit.listener.exception.FatalListenerExecutionException
-
Constructor for ListenerExecutionFailedException.
- FatalListenerExecutionException(String, Throwable) - Constructor for exception org.springframework.amqp.rabbit.listener.exception.FatalListenerExecutionException
-
Constructor for ListenerExecutionFailedException.
- FatalListenerStartupException - Exception in org.springframework.amqp.rabbit.listener.exception
-
Exception to be thrown when the execution of a listener method failed on startup.
- FatalListenerStartupException(String, Throwable) - Constructor for exception org.springframework.amqp.rabbit.listener.exception.FatalListenerStartupException
-
Constructor for ListenerExecutionFailedException.
- findHandlerForPayload(Class<? extends Object>) - Method in class org.springframework.amqp.rabbit.listener.adapter.DelegatingInvocableHandler
- findIdleConsumer() - Method in class org.springframework.amqp.rabbit.listener.DirectMessageListenerContainer
-
When adjusting down, return a consumer that can be canceled.
- findIdleConsumer() - Method in class org.springframework.amqp.rabbit.listener.DirectReplyToMessageListenerContainer
- flush() - Method in class org.springframework.amqp.rabbit.core.BatchingRabbitTemplate
-
Flush any partial in-progress batches.
- frameMaxHeadroom(int) - Method in class org.springframework.amqp.rabbit.retry.RepublishMessageRecoverer
-
Set the amount by which the negotiated frame_max is to be reduced when considering truncating the stack trace header.
- fromClass(Class<?>, MessageProperties) - Method in interface org.springframework.amqp.support.converter.ClassMapper
- fromClass(Class<?>, MessageProperties) - Method in class org.springframework.amqp.support.converter.DefaultClassMapper
- fromClass(Class<?>, MessageProperties) - Method in class org.springframework.amqp.support.converter.DefaultJackson2JavaTypeMapper
- fromClonedMessage(Message) - Static method in class org.springframework.amqp.core.MessageBuilder
-
The final message will have a copy of the message body, the MessageProperties will be cloned (top level only).
- fromClonedProperties(MessageProperties) - Static method in class org.springframework.amqp.core.MessagePropertiesBuilder
-
Performs a shallow copy of the properties for the initial value.
- fromHeaders(MessageHeaders, MessageProperties) - Method in class org.springframework.amqp.support.SimpleAmqpHeaderMapper
- fromInferredTypeHeader(MessageProperties) - Method in class org.springframework.amqp.support.converter.AbstractJavaTypeMapper
- fromInt(int) - Static method in enum org.springframework.amqp.core.MessageDeliveryMode
- fromJavaType(JavaType, MessageProperties) - Method in class org.springframework.amqp.support.converter.DefaultJackson2JavaTypeMapper
- fromJavaType(JavaType, MessageProperties) - Method in interface org.springframework.amqp.support.converter.Jackson2JavaTypeMapper
-
Set the message properties according to the type.
- fromMessage(Message) - Static method in class org.springframework.amqp.core.MessageBuilder
-
The final message body will be a direct reference to the message body, the MessageProperties will be a shallow copy.
- fromMessage(Message) - Method in class org.springframework.amqp.support.converter.AbstractJackson2MessageConverter
- fromMessage(Message) - Method in class org.springframework.amqp.support.converter.ContentTypeDelegatingMessageConverter
- fromMessage(Message) - Method in class org.springframework.amqp.support.converter.MarshallingMessageConverter
-
Unmarshals the given
Message
into an object. - fromMessage(Message) - Method in interface org.springframework.amqp.support.converter.MessageConverter
-
Convert from a Message to a Java object.
- fromMessage(Message) - Method in class org.springframework.amqp.support.converter.MessagingMessageConverter
- fromMessage(Message) - Method in class org.springframework.amqp.support.converter.RemoteInvocationAwareMessageConverterAdapter
- fromMessage(Message) - Method in class org.springframework.amqp.support.converter.SerializerMessageConverter
-
Converts from a AMQP Message to an Object.
- fromMessage(Message) - Method in class org.springframework.amqp.support.converter.SimpleMessageConverter
-
Converts from a AMQP Message to an Object.
- fromMessage(Message) - Method in class org.springframework.rabbit.stream.support.converter.DefaultStreamMessageConverter
- fromMessage(Message) - Method in interface org.springframework.rabbit.stream.support.converter.StreamMessageConverter
- fromMessage(Message, Object) - Method in class org.springframework.amqp.support.converter.AbstractJackson2MessageConverter
-
A variant of
MessageConverter.fromMessage(Message)
which takes an extra conversion context as an argument. - fromMessage(Message, Object) - Method in interface org.springframework.amqp.support.converter.SmartMessageConverter
-
A variant of
MessageConverter.fromMessage(Message)
which takes an extra conversion context as an argument. - fromMessageProperties(MessageProperties, String) - Method in class org.springframework.amqp.rabbit.support.DefaultMessagePropertiesConverter
- fromMessageProperties(MessageProperties, String) - Method in interface org.springframework.amqp.rabbit.support.MessagePropertiesConverter
- fromProperties(MessageProperties) - Static method in class org.springframework.amqp.core.MessagePropertiesBuilder
-
Initializes the builder with the supplied properties; the same object will be returned by
MessagePropertiesBuilder.build()
.
G
- generateId() - Method in class org.springframework.amqp.rabbit.junit.BrokerRunning
-
Generate the connection id for the connection used by the rule's connection factory.
- generateId() - Method in class org.springframework.amqp.rabbit.junit.BrokerRunningSupport
-
Generate the connection id for the connection used by the rule's connection factory.
- 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
- get(Object) - Static method in class org.springframework.amqp.rabbit.connection.SimpleResourceHolder
-
Retrieve a resource for the given key that is bound to the current thread.
- getAckMode() - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint
- getAckMode() - Method in interface org.springframework.amqp.rabbit.listener.RabbitListenerEndpoint
-
Override the container factory's
AcknowledgeMode
. - getAcknowledgeMode() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- getActiveConsumerCount() - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer
- 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.
- getAdapter(boolean, Object, Method, boolean, RabbitListenerErrorHandler, BatchingStrategy) - Method in interface org.springframework.amqp.rabbit.listener.MethodRabbitListenerEndpoint.AdapterProvider
-
Get an adapter instance.
- getAddress() - Method in class org.springframework.amqp.rabbit.connection.SimpleConnection
- getAddress(RetryContext) - Static method in class org.springframework.amqp.support.SendRetryContextAccessor
-
Retrieve the
Address
from the context. - getAddresses() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
- getAdmin() - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint
- getAdminPassword() - Method in class org.springframework.amqp.rabbit.junit.BrokerRunning
-
Return the admin password.
- getAdminPassword() - Method in class org.springframework.amqp.rabbit.junit.BrokerRunningSupport
-
Return the admin password.
- getAdminUri() - Method in class org.springframework.amqp.rabbit.junit.BrokerRunning
-
Return the admin uri.
- getAdminUri() - Method in class org.springframework.amqp.rabbit.junit.BrokerRunningSupport
-
Return the admin uri.
- getAdminUser() - Method in class org.springframework.amqp.rabbit.junit.BrokerRunning
-
Return the admin user.
- getAdminUser() - Method in class org.springframework.amqp.rabbit.junit.BrokerRunningSupport
-
Return the admin user.
- getAdviceChain() - Method in class org.springframework.amqp.rabbit.config.AbstractRabbitListenerContainerFactory
- getAdviceChain() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- getAfterReceivePostProcessors() - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
-
Return configured after receive
MessagePostProcessor
s ornull
. - getAfterReceivePostProcessors() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- getAmqpAdmin() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- getAmqpMessageConverter() - Method in class org.springframework.amqp.rabbit.core.RabbitMessagingTemplate
- getAmqpTemplate() - Method in class org.springframework.amqp.remoting.client.AmqpClientInterceptor
-
Deprecated.
- getAmqpTemplate() - Method in class org.springframework.amqp.remoting.service.AmqpInvokerServiceExporter
-
Deprecated.
- getAppId() - Method in class org.springframework.amqp.core.MessageProperties
- getAppId() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
- getApplicationContext() - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
- getApplicationContext() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- getApplicationEventPublisher() - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
- getApplicationEventPublisher() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- getApplicationId() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
- 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.
- getArguments() - Method in class org.springframework.amqp.rabbit.test.RabbitListenerTestHarness.InvocationData
- getAutoStartup() - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint
- getAutoStartup() - Method in interface org.springframework.amqp.rabbit.listener.RabbitListenerEndpoint
-
Override of the default autoStartup property.
- getBackOffExecution() - Method in class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer
- getBatchingStrategy() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- getBatchingStrategy() - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint
- getBean() - Method in class org.springframework.amqp.rabbit.listener.adapter.DelegatingInvocableHandler
- getBean() - Method in class org.springframework.amqp.rabbit.listener.adapter.HandlerAdapter
-
Get the bean from the handler method.
- getBean() - Method in class org.springframework.amqp.rabbit.listener.adapter.InvocationResult
- getBean() - Method in class org.springframework.amqp.rabbit.listener.MethodRabbitListenerEndpoint
- getBeanClass(Element) - Method in class org.springframework.amqp.rabbit.config.DirectExchangeParser
- getBeanClass(Element) - Method in class org.springframework.amqp.rabbit.config.FanoutExchangeParser
- getBeanClass(Element) - Method in class org.springframework.amqp.rabbit.config.HeadersExchangeParser
- getBeanClass(Element) - Method in class org.springframework.amqp.rabbit.config.QueueParser
- getBeanClass(Element) - Method in class org.springframework.amqp.rabbit.config.TopicExchangeParser
- getBeanExpressionContext() - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint
- getBeanFactory() - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint
- getBeanName() - Method in class org.springframework.amqp.rabbit.AsyncRabbitTemplate
- getBeanName() - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
-
Return a bean name of the component or null if not a bean.
- getBeanName() - Method in class org.springframework.amqp.rabbit.core.RabbitAdmin
- getBeanName() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- getBeanName() - Method in class org.springframework.rabbit.stream.listener.StreamListenerContainer
-
Return the bean name.
- getBeanResolver() - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint
- getBindingsFailedException() - Method in class org.springframework.amqp.rabbit.core.BrokerEventListener
-
Return any exception thrown when attempting to bind the queue to the event exchange.
- getBody() - Method in class org.springframework.amqp.core.Message
- getBody() - Method in class org.springframework.amqp.rabbit.support.Delivery
-
Retrieve the message body.
- getBrokerRunning() - Static method in class org.springframework.amqp.rabbit.junit.RabbitAvailableCondition
- getCacheMode() - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory
- getCacheProperties() - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory
- getCause() - Method in class org.springframework.amqp.rabbit.connection.PendingConfirm
- getChannel() - Method in class org.springframework.amqp.rabbit.connection.RabbitResourceHolder
- getChannel() - Method in class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer
- getChannel() - Method in class org.springframework.amqp.rabbit.listener.DirectReplyToMessageListenerContainer.ChannelHolder
- getChannel(RabbitResourceHolder) - Method in interface org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils.ResourceFactory
-
Fetch an appropriate Channel from the given RabbitResourceHolder.
- getChannel(RabbitResourceHolder) - Method in class org.springframework.amqp.rabbit.connection.RabbitAccessor
-
Fetch an appropriate Channel from the given RabbitResourceHolder.
- getChannelCacheSize() - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory
- getChannelHolder() - Method in class org.springframework.amqp.rabbit.listener.DirectReplyToMessageListenerContainer
-
Get the channel holder associated with a direct reply-to consumer; contains a consumer epoch to prevent inappropriate releases.
- getChannelListener() - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
-
A composite channel listener to be used by subclasses when creating and closing channels.
- getChannelNumber() - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- getChannelsExecutor() - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory
-
Determine the executor service used for target channels.
- getCharset() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
- getClassIdFieldName() - Method in class org.springframework.amqp.support.converter.AbstractJavaTypeMapper
- getClassIdFieldName() - Method in class org.springframework.amqp.support.converter.DefaultClassMapper
-
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
- getCloseReason() - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- getCloseTimeout() - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
- getClusterId() - Method in class org.springframework.amqp.core.MessageProperties
- getClusterId() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
- getCompressorStream(OutputStream) - Method in class org.springframework.amqp.support.postprocessor.AbstractCompressingPostProcessor
-
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
- getConcurrency() - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint
-
The concurrency of this endpoint; Not used by this abstract class; used by subclasses to set the concurrency appropriate for the container type.
- getConcurrency() - Method in interface org.springframework.amqp.rabbit.listener.RabbitListenerEndpoint
- getConfirm() - Method in class org.springframework.amqp.rabbit.AsyncRabbitTemplate.RabbitFuture
-
When confirms are enabled contains a
ListenableFuture
for the confirmation. - getConfirmationCode() - Method in exception org.springframework.rabbit.stream.producer.StreamSendException
-
Return the confirmation code, if available.
- getConnection() - Method in class org.springframework.amqp.rabbit.connection.ConnectionBlockedEvent
- getConnection() - Method in class org.springframework.amqp.rabbit.connection.ConnectionUnblockedEvent
- getConnection() - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- getConnection() - Method in class org.springframework.amqp.rabbit.connection.RabbitResourceHolder
- getConnection(RabbitResourceHolder) - Method in interface org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils.ResourceFactory
-
Fetch an appropriate Connection from the given RabbitResourceHolder.
- getConnection(RabbitResourceHolder) - Method in class org.springframework.amqp.rabbit.connection.RabbitAccessor
-
Fetch an appropriate Connection from the given RabbitResourceHolder.
- getConnectionCacheSize() - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory
- getConnectionFactory() - Method in class org.springframework.amqp.rabbit.AsyncRabbitTemplate
- getConnectionFactory() - Method in class org.springframework.amqp.rabbit.connection.RabbitAccessor
- getConnectionFactory() - Method in class org.springframework.amqp.rabbit.core.RabbitGatewaySupport
- getConnectionFactory() - Method in interface org.springframework.amqp.rabbit.core.RabbitOperations
-
Return the connection factory for this operations.
- getConnectionFactory() - Method in class org.springframework.amqp.rabbit.junit.BrokerRunning
-
Get the connection factory used by this rule.
- getConnectionFactory() - Method in class org.springframework.amqp.rabbit.junit.BrokerRunningSupport
-
Get the connection factory used by this rule.
- getConnectionFactory() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- getConnectionFactory() - Method in class org.springframework.amqp.rabbit.transaction.RabbitTransactionManager
- getConnectionListener() - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
-
A composite connection listener to be used by subclasses when creating and closing connections.
- getConnectionNameStrategy() - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
- getConsumeDelay() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
-
Get the consumeDelay - a time to wait before consuming in ms.
- getConsumer() - Method in class org.springframework.amqp.rabbit.listener.AsyncConsumerStartedEvent
- getConsumer() - Method in class org.springframework.amqp.rabbit.listener.AsyncConsumerStoppedEvent
- getConsumerArguments() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
-
Return the consumer arguments.
- getConsumerChannel() - Static method in class org.springframework.amqp.rabbit.connection.ConsumerChannelRegistry
-
See registerConsumerChannel.
- getConsumerChannel(ConnectionFactory) - Static method in class org.springframework.amqp.rabbit.connection.ConsumerChannelRegistry
-
See registerConsumerChannel.
- getConsumerCount() - Method in class org.springframework.amqp.core.QueueInformation
- getConsumerEpoch() - Method in class org.springframework.amqp.rabbit.listener.DirectReplyToMessageListenerContainer.ChannelHolder
- getConsumerQueue() - Method in class org.springframework.amqp.core.MessageProperties
- getConsumerQueue() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
- getConsumerTag() - Method in class org.springframework.amqp.core.MessageProperties
- getConsumerTag() - Method in class org.springframework.amqp.rabbit.listener.ConsumeOkEvent
-
Obtain the consumer tag assigned to the consumer.
- getConsumerTag() - Method in class org.springframework.amqp.rabbit.support.Delivery
-
Retrieve the consumer tag.
- getConsumerTag() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
- getConsumerTags() - Method in class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer
- getConsumerTagStrategy() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
-
Return the consumer tag strategy to use.
- getContentClassIdFieldName() - Method in class org.springframework.amqp.support.converter.AbstractJavaTypeMapper
- getContentEncoding() - Method in class org.springframework.amqp.core.MessageProperties
- getContentEncoding() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
- getContentEncoding() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
- getContentLength() - Method in class org.springframework.amqp.core.MessageProperties
- getContentLength() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
- getContentType() - Method in class org.springframework.amqp.core.MessageProperties
- getContentType() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
- getContentType() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
- getContext() - Method in class org.springframework.rabbit.stream.support.StreamMessageProperties
-
Return the stream
MessageHandler.Context
for the message. - getContextStopped() - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
- getConverterForContentType(String) - Method in class org.springframework.amqp.support.converter.ContentTypeDelegatingMessageConverter
- getCorrelationData() - Method in class org.springframework.amqp.rabbit.connection.PendingConfirm
-
The correlation data supplied by the client when sending the message corresponding to this confirmation.
- getCorrelationId() - Method in class org.springframework.amqp.core.MessageProperties
-
Get the correlation id.
- getCorrelationId() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
- getCount() - Method in class org.springframework.amqp.rabbit.support.ActiveObjectCounter
- getCreationTime() - Method in class org.springframework.rabbit.stream.support.StreamMessageProperties
-
See
Properties.getCreationTime()
. - getCustomMethodArgumentResolvers() - Method in class org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistrar
-
Return the list of
HandlerMethodArgumentResolver
. - getDeclarable() - Method in class org.springframework.amqp.rabbit.core.DeclarationExceptionEvent
- 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
AmqpAdmin
s 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
- getDefaultConsumer() - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- getDefaultHostName() - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
- getDefaultListenerMethod() - Method in class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter
- getDefaultReceiveQueue() - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
-
Return the configured default receive queue.
- getDefaultRequeueRejected() - Method in class org.springframework.amqp.rabbit.config.BaseRabbitListenerContainerFactory
-
Return the defaultRequeueRejected.
- getDelay() - Method in class org.springframework.amqp.core.MessageProperties
-
The x-delay header (outbound).
- getDelegate() - Method in interface org.springframework.amqp.rabbit.connection.Connection
-
Return the underlying RabbitMQ connection.
- getDelegate() - Method in interface org.springframework.amqp.rabbit.connection.PublisherCallbackChannel
-
Use this to invoke methods on the underlying rabbit client
Channel
that are not supported by this implementation. - getDelegate() - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- getDelegate() - Method in class org.springframework.amqp.rabbit.connection.SimpleConnection
- getDelegate() - Method in class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter
- getDelegate(String) - Method in class org.springframework.amqp.rabbit.test.RabbitListenerTestHarness
-
Get the actual listener object (not the spy).
- getDelegates() - Method in class org.springframework.amqp.support.converter.ContentTypeDelegatingMessageConverter
- getDeliveryMode() - Method in class org.springframework.amqp.core.MessageProperties
- getDeliveryMode() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
- getDeliveryMode() - Method in class org.springframework.amqp.rabbit.retry.RepublishMessageRecoverer
- 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
- getEncoder() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
- getEncoding() - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
-
The encoding used when converting between byte arrays and Strings in message properties.
- getEncoding() - Method in class org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener
-
The encoding to use when inter-converting between byte arrays and Strings in message properties.
- 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
- getEndpointDescription() - Method in class org.springframework.amqp.rabbit.config.SimpleRabbitListenerEndpoint
- getEndpointDescription() - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint
- getEndpointDescription() - Method in class org.springframework.amqp.rabbit.listener.MethodRabbitListenerEndpoint
- getEndpointRegistry() - Method in class org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistrar
- getEnvelope() - Method in class org.springframework.amqp.rabbit.support.Delivery
-
Retrieve the message envelope.
- getErrorRoutingKeyPrefix() - Method in class org.springframework.amqp.rabbit.retry.RepublishMessageRecoverer
- getEvent() - Method in class org.springframework.amqp.rabbit.log4j2.AmqpAppender.Event
- getEvent() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender.Event
- getEventProperties() - Method in class org.springframework.amqp.rabbit.core.BrokerEvent
-
Properties of the event
MessageProperties.getHeaders()
. - getEventType() - Method in class org.springframework.amqp.rabbit.core.BrokerEvent
-
The event type (
MessageProperties.getReceivedRoutingKey()
). - getExceptions() - Method in class org.springframework.amqp.rabbit.test.mockito.LambdaAnswer
-
Return the exceptions thrown, if any.
- getExceptions() - Method in class org.springframework.amqp.rabbit.test.mockito.LatchCountDownAndCallRealMethodAnswer
-
Return the exceptions thrown.
- getExceptionStrategy() - Method in class org.springframework.amqp.rabbit.listener.ConditionalRejectingErrorHandler
-
Return the exception strategy.
- 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.
- getExchange() - Method in class org.springframework.amqp.rabbit.batch.MessageBatch
- getExchange() - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
- getExchangeName() - Method in class org.springframework.amqp.core.Address
- getExchangeName() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
- getExchangeType() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
- getExclusiveConsumerExceptionLogger() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- getExecutorService() - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
- getExpiration() - Method in class org.springframework.amqp.core.MessageProperties
- getExpiration() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
- getExpressionString() - Method in class org.springframework.amqp.rabbit.support.ValueExpression
- getFailedDeclarationRetryInterval() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- getFailedMessage() - Method in exception org.springframework.amqp.rabbit.core.AmqpNackReceivedException
-
Return the failed message.
- getFailedMessage() - Method in exception org.springframework.amqp.rabbit.support.ListenerExecutionFailedException
- getFailedMessages() - Method in exception org.springframework.amqp.rabbit.support.ListenerExecutionFailedException
- getFuture() - Method in class org.springframework.amqp.rabbit.connection.CorrelationData
-
Return a future to check the success/failure of the publish operation.
- getGroup() - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint
- getGroup() - Method in interface org.springframework.amqp.rabbit.listener.RabbitListenerEndpoint
- getGroupId() - Method in class org.springframework.rabbit.stream.support.StreamMessageProperties
-
See
Properties.getGroupId()
. - getGroupSequence() - Method in class org.springframework.rabbit.stream.support.StreamMessageProperties
-
See
Properties.getGroupSequence()
. - getHandlerAdapter() - Method in class org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter
- getHandlerForPayload(Class<? extends Object>) - Method in class org.springframework.amqp.rabbit.listener.adapter.DelegatingInvocableHandler
- 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
- getHost() - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
- getHost() - Method in class org.springframework.amqp.rabbit.connection.AbstractRoutingConnectionFactory
- getHost() - Method in interface org.springframework.amqp.rabbit.connection.ConnectionFactory
- getHost() - Method in class org.springframework.amqp.rabbit.connection.LocalizedQueueConnectionFactory
- getHost() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
- getHostName() - Method in class org.springframework.amqp.rabbit.junit.BrokerRunning
-
Return the port.
- getHostName() - Method in class org.springframework.amqp.rabbit.junit.BrokerRunningSupport
-
Return the port.
- getId() - Method in class org.springframework.amqp.rabbit.connection.CorrelationData
-
Return the id.
- getId() - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint
- getId() - Method in interface org.springframework.amqp.rabbit.listener.RabbitListenerEndpoint
- getIdClassMapping() - Method in class org.springframework.amqp.support.converter.AbstractJavaTypeMapper
- getIdleEventInterval() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- getIdleTime() - Method in class org.springframework.amqp.rabbit.listener.ListenerContainerIdleEvent
-
How long the container has been idle.
- 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.
- getInvocationResultFor(Object, Object) - Method in class org.springframework.amqp.rabbit.listener.adapter.DelegatingInvocableHandler
- getInvocationResultFor(Object, Object) - Method in class org.springframework.amqp.rabbit.listener.adapter.HandlerAdapter
-
Build an
InvocationResult
for the result and inbound payload. - getJavaLangErrorHandler() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- getJavaTypeMapper() - Method in class org.springframework.amqp.support.converter.AbstractJackson2MessageConverter
- getKey(Message) - Method in interface org.springframework.amqp.rabbit.retry.MessageKeyGenerator
-
Generate a unique key for the message that is repeatable on redelivery.
- getKeyClassIdFieldName() - Method in class org.springframework.amqp.support.converter.AbstractJavaTypeMapper
- getKeyStore() - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
- getKeyStore() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
- getKeyStoreAlgorithm() - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
- getKeyStorePassphrase() - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
- getKeyStorePassphrase() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
- getKeyStoreResource() - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
- getKeyStoreType() - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
-
Get the key store type - this defaults to PKCS12 if not overridden by
RabbitConnectionFactoryBean.setSslPropertiesLocation(Resource)
orRabbitConnectionFactoryBean.setKeyStoreType(java.lang.String)
. - getKeyStoreType() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
- getLambdaAnswerFor(String, boolean, LambdaAnswer.ValueToReturn<T>) - Method in class org.springframework.amqp.rabbit.test.RabbitListenerTestHarness
-
Return a
LambdaAnswer
that is properly configured to invoke the listener. - getLastDeclarationExceptionEvent() - Method in class org.springframework.amqp.rabbit.core.RabbitAdmin
- getLastReceive() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
-
Get the time the last message was received - initialized to container start time.
- getLatch() - Method in class org.springframework.amqp.rabbit.test.mockito.LatchCountDownAndCallRealMethodAnswer
- getLatchAnswerFor(String, int) - Method in class org.springframework.amqp.rabbit.test.RabbitListenerTestHarness
-
Return a
LatchCountDownAndCallRealMethodAnswer
that is properly configured to invoke the listener. - getLevel() - Method in class org.springframework.amqp.support.postprocessor.AbstractDeflaterPostProcessor
-
Get the deflater compression level.
- getListenerContainer(String) - Method in class org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistry
-
Return the
MessageListenerContainer
with the specified id ornull
if no such container exists. - getListenerContainerIds() - Method in class org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistry
-
Return the ids of the managed
MessageListenerContainer
instance(s). - getListenerContainers() - Method in class org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistry
- getListenerId() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
-
The 'id' attribute of the listener.
- getListenerId() - Method in class org.springframework.amqp.rabbit.listener.ListenerContainerIdleEvent
-
The id of the listener (if
@RabbitListener
) or the container bean name. - getListenerId() - Method in class org.springframework.rabbit.stream.listener.StreamListenerContainer
-
The 'id' attribute of the listener.
- getListenerMethodName(Message, Object) - Method in class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter
-
Determine the name of the listener method that will handle the given message.
- getLocalAddress() - Method in class org.springframework.amqp.rabbit.connection.SimpleConnection
- getLocalPort() - Method in interface org.springframework.amqp.rabbit.connection.Connection
- getLocalPort() - Method in class org.springframework.amqp.rabbit.connection.SimpleConnection
- getMaxFrame(ConnectionFactory) - Static method in class org.springframework.amqp.rabbit.connection.RabbitUtils
-
Return the negotiated frame_max.
- getMaxSenderRetries() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
- getMessage() - Method in class org.springframework.amqp.core.ReturnedMessage
-
Get the message.
- getMessage() - Method in class org.springframework.amqp.rabbit.batch.MessageBatch
- getMessage(RetryContext) - Static method in class org.springframework.amqp.support.SendRetryContextAccessor
-
Retrieve the
Message
from the context. - getMessageConverter() - Method in class org.springframework.amqp.rabbit.AsyncRabbitTemplate
- getMessageConverter() - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
-
Return the message converter for this template.
- getMessageConverter() - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint
- getMessageConverter() - Method in class org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener
-
Return the converter that will convert incoming Rabbit messages to listener method arguments, and objects returned from listener methods back to Rabbit messages.
- getMessageConverter() - Method in interface org.springframework.amqp.rabbit.listener.RabbitListenerEndpoint
-
Used by the container factory to check if this endpoint supports the preferred way for a container factory to pass a message converter to the endpoint's adapter.
- getMessageConverter() - Method in class org.springframework.amqp.remoting.service.AmqpInvokerServiceExporter
-
Deprecated.
- 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
- getMessageHandlerMethodFactory() - Method in class org.springframework.amqp.rabbit.listener.MethodRabbitListenerEndpoint
- getMessageHandlerMethodFactory() - Method in class org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistrar
- getMessageId() - Method in class org.springframework.amqp.core.MessageProperties
- getMessageId() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
- getMessageListener() - Method in class org.springframework.amqp.rabbit.config.SimpleRabbitListenerEndpoint
- getMessageListener() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- getMessageListener() - Method in interface org.springframework.amqp.rabbit.listener.MessageListenerContainer
-
Get the message listener.
- getMessageListener() - Method in class org.springframework.rabbit.stream.listener.StreamListenerContainer
- getMessageProperties() - Method in class org.springframework.amqp.core.Message
- getMessageProperties() - Method in class org.springframework.amqp.rabbit.core.BrokerEvent
-
The complete
MessageProperties
from the event representing the event. - getMessagePropertiesConverter() - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
-
Return the properties converter.
- getMessagePropertiesConverter() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- getMessageRecoverer() - Method in class org.springframework.amqp.rabbit.config.AbstractRetryOperationsInterceptorFactoryBean
- getMessagingMessageConverter() - Method in class org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter
- getMethod() - Method in class org.springframework.amqp.rabbit.listener.adapter.InvocationResult
- getMethod() - Method in class org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter.MessagingMessageConverterAdapter
- getMethod() - Method in class org.springframework.amqp.rabbit.listener.MethodRabbitListenerEndpoint
- getMethodAsString(Object) - Method in class org.springframework.amqp.rabbit.listener.adapter.HandlerAdapter
-
Get the method signature for the payload type via
Method.toGenericString()
. - getMethodFor(Object) - Method in class org.springframework.amqp.rabbit.listener.adapter.DelegatingInvocableHandler
-
Return the method that will be invoked for this payload.
- getMethodFor(Object) - Method in class org.springframework.amqp.rabbit.listener.adapter.HandlerAdapter
-
Get the method for the payload type.
- getMethodNameFor(Object) - Method in class org.springframework.amqp.rabbit.listener.adapter.DelegatingInvocableHandler
-
Return a string representation of the method that will be invoked for this payload.
- getNackCause() - Method in class org.springframework.amqp.rabbit.AsyncRabbitTemplate.RabbitFuture
-
When confirms are enabled and a nack is received, contains the cause for the nack, if any.
- getName() - Method in class org.springframework.amqp.core.AbstractExchange
- getName() - Method in interface org.springframework.amqp.core.Exchange
-
The name of the exchange.
- getName() - Method in class org.springframework.amqp.core.Queue
-
Return the name provided in the constructor.
- getName() - Method in class org.springframework.amqp.core.QueueInformation
- getNewConsumer() - Method in class org.springframework.amqp.rabbit.listener.AsyncConsumerRestartedEvent
- getNextInvocationDataFor(String, long, TimeUnit) - Method in class org.springframework.amqp.rabbit.test.RabbitListenerTestHarness
- getNextPublishSeqNo() - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- getObject() - Method in class org.springframework.amqp.rabbit.config.BindingFactoryBean
- getObject() - Method in class org.springframework.amqp.rabbit.config.StatefulRetryOperationsInterceptorFactoryBean
- getObject() - Method in class org.springframework.amqp.rabbit.config.StatelessRetryOperationsInterceptorFactoryBean
- getObject() - Method in class org.springframework.amqp.remoting.client.AmqpProxyFactoryBean
-
Deprecated.
- getObjectType() - Method in class org.springframework.amqp.rabbit.config.BindingFactoryBean
- getObjectType() - Method in class org.springframework.amqp.rabbit.config.ListenerContainerFactoryBean
- getObjectType() - Method in class org.springframework.amqp.rabbit.config.StatefulRetryOperationsInterceptorFactoryBean
- getObjectType() - Method in class org.springframework.amqp.rabbit.config.StatelessRetryOperationsInterceptorFactoryBean
- getObjectType() - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
- getObjectType() - Method in class org.springframework.amqp.rabbit.support.ExpressionFactoryBean
- getObjectType() - Method in class org.springframework.amqp.remoting.client.AmqpProxyFactoryBean
-
Deprecated.
- getOldConsumer() - Method in class org.springframework.amqp.rabbit.listener.AsyncConsumerRestartedEvent
- 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.rabbit.annotation.RabbitListenerAnnotationBeanPostProcessor
- getOrder() - Method in class org.springframework.amqp.support.postprocessor.AbstractCompressingPostProcessor
- getOrder() - Method in class org.springframework.amqp.support.postprocessor.AbstractDecompressingPostProcessor
- getOrder() - Method in class org.springframework.amqp.support.postprocessor.DelegatingDecompressingPostProcessor
- getPassword() - Method in class org.springframework.amqp.rabbit.junit.BrokerRunning
-
Return the password.
- getPassword() - Method in class org.springframework.amqp.rabbit.junit.BrokerRunningSupport
-
Return the password.
- getPassword() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
- getPendingConfirmsCount() - Method in interface org.springframework.amqp.rabbit.connection.PublisherCallbackChannel
-
Get the total pending confirms count.
- getPendingConfirmsCount() - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- getPendingConfirmsCount(PublisherCallbackChannel.Listener) - Method in interface org.springframework.amqp.rabbit.connection.PublisherCallbackChannel
-
Get the
PendingConfirm
s count. - getPendingConfirmsCount(PublisherCallbackChannel.Listener) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- getPhase() - Method in class org.springframework.amqp.rabbit.AsyncRabbitTemplate
- getPhase() - Method in class org.springframework.amqp.rabbit.config.ListenerContainerFactoryBean
- getPhase() - Method in class org.springframework.amqp.rabbit.core.BrokerEventListener
- getPhase() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- getPhase() - Method in class org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistry
- getPort() - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
- getPort() - Method in class org.springframework.amqp.rabbit.connection.AbstractRoutingConnectionFactory
- getPort() - Method in interface org.springframework.amqp.rabbit.connection.ConnectionFactory
- getPort() - Method in class org.springframework.amqp.rabbit.connection.LocalizedQueueConnectionFactory
- getPort() - Method in class org.springframework.amqp.rabbit.connection.SimpleConnection
- getPort() - Method in class org.springframework.amqp.rabbit.junit.BrokerRunning
-
Return the port.
- getPort() - Method in class org.springframework.amqp.rabbit.junit.BrokerRunningSupport
-
Return the port.
- getPort() - Static method in class org.springframework.amqp.rabbit.junit.BrokerTestUtils
-
The port that the broker is listening on (e.g.
- getPort() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
- getPrefetchCount() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
-
Return the prefetch count.
- getPriority() - Method in class org.springframework.amqp.core.MessageProperties
- getPriority() - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint
- getPriority() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
- getProperties() - Method in class org.springframework.amqp.rabbit.log4j2.AmqpAppender.Event
- getProperties() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender.Event
- getProperties() - Method in class org.springframework.amqp.rabbit.support.Delivery
-
Retrieve the message properties.
- getPropertyValue(Object, String) - Static method in class org.springframework.amqp.utils.test.TestUtils
-
Uses nested
DirectFieldAccessor
s 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
- getPublisherConnectionFactory() - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
- getPublisherConnectionFactory() - Method in interface org.springframework.amqp.rabbit.connection.ConnectionFactory
-
Return a separate connection factory for publishers (if implemented).
- getPublisherConnectionFactoryCacheProperties() - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory
-
Return the cache properties from the underlying publisher sub-factory.
- getPublishSequenceNumber() - Method in class org.springframework.amqp.core.MessageProperties
-
Return the publish sequence number if publisher confirms are enabled; set by the template.
- getQueue() - Method in class org.springframework.amqp.rabbit.listener.ConsumeOkEvent
-
Obtain the queue name a consumer has been subscribed.
- getQueue() - Method in class org.springframework.amqp.rabbit.listener.MissingQueueEvent
-
Return the missing queue.
- getQueue() - Method in class org.springframework.amqp.rabbit.support.Delivery
-
Retrieve the queue.
- getQueuedEventCount() - Method in class org.springframework.amqp.rabbit.log4j2.AmqpAppender
-
Return the number of events waiting to be sent.
- getQueuedEventCount() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
-
Return the number of events waiting to be sent.
- getQueueInfo(String) - Method in interface org.springframework.amqp.core.AmqpAdmin
-
Returns information about the queue, if it exists.
- getQueueInfo(String) - Method in class org.springframework.amqp.rabbit.core.RabbitAdmin
- getQueueNames() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- getQueueNames() - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint
- getQueueNames() - Method in class org.springframework.amqp.rabbit.listener.ListenerContainerIdleEvent
-
The queues the container is listening to.
- getQueueNamesAsSet() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- getQueueNamesToQueues() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
-
Returns a map of current queue names to the Queue object; allows the determination of a changed broker-named queue.
- getQueueProperties(String) - Method in interface org.springframework.amqp.core.AmqpAdmin
-
Returns an implementation-specific Map of properties if the queue exists.
- getQueueProperties(String) - Method in class org.springframework.amqp.rabbit.core.RabbitAdmin
-
Returns 3 properties
RabbitAdmin.QUEUE_NAME
,RabbitAdmin.QUEUE_MESSAGE_COUNT
,RabbitAdmin.QUEUE_CONSUMER_COUNT
, or null if the queue doesn't exist. - getQueues() - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint
- getRabbitConnectionFactory() - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
-
Return a reference to the underlying Rabbit Connection factory.
- getRabbitConnectionFactory() - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
-
Access the connection factory to set any other properties not supported by this factory bean.
- getRabbitOperations() - Method in class org.springframework.amqp.rabbit.core.RabbitGatewaySupport
- getRabbitTemplate() - Method in class org.springframework.amqp.rabbit.AsyncRabbitTemplate
-
Return the underlying
RabbitTemplate
used for sending. - getRabbitTemplate() - Method in class org.springframework.amqp.rabbit.core.RabbitAdmin
- getRabbitTemplate() - Method in class org.springframework.amqp.rabbit.core.RabbitMessagingTemplate
- getReason() - Method in class org.springframework.amqp.rabbit.connection.ConnectionBlockedEvent
- getReason() - Method in class org.springframework.amqp.rabbit.connection.CorrelationData.Confirm
- getReason() - Method in class org.springframework.amqp.rabbit.listener.ListenerContainerConsumerFailedEvent
- getReason() - Method in class org.springframework.amqp.rabbit.listener.ListenerContainerConsumerTerminatedEvent
- 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
- getReceivedExchange(Message) - Method in class org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener
- 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
- getRecoveryBackOff() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- 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
-
Deprecated.
- getReplyCode() - Method in exception org.springframework.amqp.core.AmqpMessageReturnedException
- getReplyCode() - Method in class org.springframework.amqp.core.ReturnedMessage
-
Get the reply code.
- getReplyContentType() - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint
- getReplyContentType() - Method in class org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener
-
Get the reply content type.
- getReplyContentType() - Method in interface org.springframework.amqp.rabbit.listener.RabbitListenerEndpoint
-
Get the reply content type.
- getReplyPostProcessor() - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint
- getReplyPostProcessor() - Method in interface org.springframework.amqp.rabbit.listener.RabbitListenerEndpoint
-
Return a
ReplyPostProcessor
to post process a reply message before it is sent. - 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, Object, InvocationResult) - Method in class org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener
-
Determine a reply-to Address for the given message.
- getReplyToAddress(Message, T) - Method in interface org.springframework.amqp.core.ReplyToAddressCallback
- getReplyToGroupId() - Method in class org.springframework.rabbit.stream.support.StreamMessageProperties
-
See
Properties.getReplyToGroupId()
. - getRequest() - Method in class org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener.ReplyExpressionRoot
- getRequestMessage() - Method in exception org.springframework.amqp.core.AmqpReplyTimeoutException
- getResolver() - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint
- getResourceFactory() - Method in class org.springframework.amqp.rabbit.transaction.RabbitTransactionManager
- getResourceLoader() - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
-
Get the resource loader; used to resolve the key store and trust store
Resource
s to input streams. - getResources() - Static method in class org.springframework.amqp.rabbit.connection.SimpleResourceHolder
-
Return all resources that are bound to the current thread.
- getResult() - Method in class org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener.ReplyExpressionRoot
- getResult() - Method in class org.springframework.amqp.rabbit.test.RabbitListenerTestHarness.InvocationData
- getRetryOperations() - Method in class org.springframework.amqp.rabbit.config.AbstractRetryOperationsInterceptorFactoryBean
- getReturned() - Method in exception org.springframework.amqp.core.AmqpMessageReturnedException
- getReturned() - Method in class org.springframework.amqp.rabbit.connection.CorrelationData
-
Get the returned message and metadata, if any.
- getReturnedMessage() - Method in exception org.springframework.amqp.core.AmqpMessageReturnedException
- getReturnedMessage() - Method in class org.springframework.amqp.rabbit.connection.CorrelationData
-
Deprecated.in favor of
CorrelationData.getReturned()
. - getReturnType() - Method in class org.springframework.amqp.rabbit.AsyncRabbitTemplate.RabbitConverterFuture
- getReturnType() - Method in class org.springframework.amqp.rabbit.listener.adapter.InvocationResult
- getReturnTypeFor(Object) - Method in class org.springframework.amqp.rabbit.listener.adapter.HandlerAdapter
-
Return the return type for the method that will be chosen for this payload.
- getReturnValue() - Method in class org.springframework.amqp.rabbit.listener.adapter.InvocationResult
- getRoutingConnectionFactory() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
-
Return the (@link RoutingConnectionFactory} if the connection factory is a
RoutingConnectionFactory
; null otherwise. - 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.rabbit.batch.MessageBatch
- getRoutingKey() - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
- getRoutingKey() - Method in class org.springframework.amqp.remoting.client.AmqpClientInterceptor
-
Deprecated.
- getRoutingKeyPattern() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
- getRoutingLookupKey() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
-
Return the lookup key if the connection factory is a
RoutingConnectionFactory
; null otherwise. - getSaslConfig() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
- getSecureRandom() - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
- getSenderPoolSize() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
- getSendTo() - Method in class org.springframework.amqp.rabbit.listener.adapter.InvocationResult
- getShutdownTimeout() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- getSource() - Method in class org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener.ReplyExpressionRoot
- getSpy(String) - Method in class org.springframework.amqp.rabbit.test.RabbitListenerTestHarness
- getSslAlgorithm() - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
- getSslAlgorithm() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
- getSslPropertiesLocation() - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
- getSslPropertiesLocation() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
- getStreamConverter() - Method in class org.springframework.rabbit.stream.listener.StreamListenerContainer
- getSubject() - Method in class org.springframework.rabbit.stream.support.StreamMessageProperties
-
See
Properties.getSubject()
. - getSyncStatus() - Method in exception org.springframework.amqp.rabbit.connection.AfterCompletionFailedException
-
Return the synchronization status.
- getTargetBean() - Method in class org.springframework.amqp.core.MessageProperties
-
The target bean when using
@RabbitListener
. - getTargetChannel() - Method in interface org.springframework.amqp.rabbit.connection.ChannelProxy
-
Return the target Channel of this proxy.
- getTargetConnection() - Method in interface org.springframework.amqp.rabbit.connection.ConnectionProxy
-
Return the target Channel of this proxy.
- getTargetConnectionFactory(Object) - Method in class org.springframework.amqp.rabbit.connection.AbstractRoutingConnectionFactory
- getTargetConnectionFactory(Object) - Method in class org.springframework.amqp.rabbit.connection.LocalizedQueueConnectionFactory
- getTargetConnectionFactory(Object) - Method in interface org.springframework.amqp.rabbit.connection.RoutingConnectionFactory
-
Returns the
ConnectionFactory
bound to given lookup key, or null if one does not exist. - getTargetMethod() - Method in class org.springframework.amqp.core.MessageProperties
-
The target method when using a
@RabbitListener
. - getTaskExecutor() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- getTaskExecutor() - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint
- getTaskExecutor() - Method in interface org.springframework.amqp.rabbit.listener.RabbitListenerEndpoint
-
Get the task executor to use for this endpoint's listener container.
- getThrowable() - Method in class org.springframework.amqp.rabbit.core.DeclarationExceptionEvent
- getThrowable() - Method in class org.springframework.amqp.rabbit.listener.ListenerContainerConsumerFailedEvent
- getThrowable() - Method in class org.springframework.amqp.rabbit.test.RabbitListenerTestHarness.InvocationData
- getTimestamp() - Method in class org.springframework.amqp.core.MessageProperties
- getTimestamp() - Method in class org.springframework.amqp.rabbit.connection.PendingConfirm
- getTimestamp() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
- getTo() - Method in class org.springframework.rabbit.stream.support.StreamMessageProperties
-
See
Properties.getTo()
. - getTransactionalResourceHolder() - Method in class org.springframework.amqp.rabbit.connection.RabbitAccessor
- getTransactionalResourceHolder(ConnectionFactory, boolean) - Static method in class org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils
-
Obtain a RabbitMQ Channel that is synchronized with the current transaction, if any.
- getTransactionalResourceHolder(ConnectionFactory, boolean, boolean) - Static method in class org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils
-
Obtain a RabbitMQ Channel that is synchronized with the current transaction, if any.
- getTransactionAttribute() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- getTransactionManager() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- getTrustStore() - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
- getTrustStore() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
- getTrustStoreAlgorithm() - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
- getTrustStorePassphrase() - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
- getTrustStorePassphrase() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
- getTrustStoreResource() - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
- getTrustStoreType() - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
-
Get the trust store type - this defaults to JKS if not overridden by
RabbitConnectionFactoryBean.setSslPropertiesLocation(Resource)
orRabbitConnectionFactoryBean.setTrustStoreType(java.lang.String)
. - getTrustStoreType() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
- 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.
- getUnconfirmed(long) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
-
Gets unconfirmed correlation data older than age and removes them.
- getUnconfirmedCount() - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
-
Gets unconfirmed messages count.
- getUri() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
- getUser() - Method in class org.springframework.amqp.rabbit.junit.BrokerRunning
-
Return the user.
- getUser() - Method in class org.springframework.amqp.rabbit.junit.BrokerRunningSupport
-
Return the user.
- getUserId() - Method in class org.springframework.amqp.core.MessageProperties
- getUserId() - Method in class org.springframework.amqp.support.AmqpMessageHeaderAccessor
- getUsername() - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
-
Return the user name from the underlying rabbit connection factory.
- getUsername() - Method in class org.springframework.amqp.rabbit.connection.AbstractRoutingConnectionFactory
- getUsername() - Method in interface org.springframework.amqp.rabbit.connection.ConnectionFactory
- getUsername() - Method in class org.springframework.amqp.rabbit.connection.LocalizedQueueConnectionFactory
- getUsername() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
- getUUID() - Method in interface org.springframework.amqp.rabbit.connection.PublisherCallbackChannel.Listener
-
Returns the UUID used to identify this Listener for returns.
- getUUID() - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
- getValidator() - Method in class org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistrar
-
Get the validator, if supplied.
- getValue() - Method in enum org.springframework.amqp.core.QueueBuilder.LeaderLocator
-
Return the value.
- getValue() - Method in enum org.springframework.amqp.core.QueueBuilder.MasterLocator
-
Deprecated.Return the value.
- getValue() - Method in enum org.springframework.amqp.core.QueueBuilder.Overflow
-
Return the value.
- getValue() - Method in class org.springframework.amqp.rabbit.support.ValueExpression
- getValue(Class<T>) - Method in class org.springframework.amqp.rabbit.support.ValueExpression
- getValue(Object) - Method in class org.springframework.amqp.rabbit.support.ValueExpression
- getValue(Object, Class<T>) - Method in class org.springframework.amqp.rabbit.support.ValueExpression
- getValue(EvaluationContext) - Method in class org.springframework.amqp.rabbit.support.ValueExpression
- getValue(EvaluationContext, Class<T>) - Method in class org.springframework.amqp.rabbit.support.ValueExpression
- getValue(EvaluationContext, Object) - Method in class org.springframework.amqp.rabbit.support.ValueExpression
- getValue(EvaluationContext, Object, Class<T>) - Method in class org.springframework.amqp.rabbit.support.ValueExpression
- getValueType() - Method in class org.springframework.amqp.rabbit.support.ValueExpression
- getValueType(Object) - Method in class org.springframework.amqp.rabbit.support.ValueExpression
- getValueType(EvaluationContext) - Method in class org.springframework.amqp.rabbit.support.ValueExpression
- getValueType(EvaluationContext, Object) - Method in class org.springframework.amqp.rabbit.support.ValueExpression
- getValueTypeDescriptor() - Method in class org.springframework.amqp.rabbit.support.ValueExpression
- getValueTypeDescriptor(Object) - Method in class org.springframework.amqp.rabbit.support.ValueExpression
- getValueTypeDescriptor(EvaluationContext) - Method in class org.springframework.amqp.rabbit.support.ValueExpression
- getValueTypeDescriptor(EvaluationContext, Object) - Method in class org.springframework.amqp.rabbit.support.ValueExpression
- getVirtualHost() - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
- getVirtualHost() - Method in class org.springframework.amqp.rabbit.connection.AbstractRoutingConnectionFactory
- getVirtualHost() - Method in interface org.springframework.amqp.rabbit.connection.ConnectionFactory
- getVirtualHost() - Method in class org.springframework.amqp.rabbit.connection.LocalizedQueueConnectionFactory
- getVirtualHost() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
- getXDeathHeader() - Method in class org.springframework.amqp.core.MessageProperties
-
Return the x-death header.
- group() - Method in annotation type org.springframework.amqp.rabbit.annotation.RabbitListener
-
If provided, the listener container for this listener will be added to a bean with this value as its name, of type
Collection<MessageListenerContainer>
. - GUnzipPostProcessor - Class in org.springframework.amqp.support.postprocessor
-
A post processor that uses a
GZIPInputStream
to decompress the message body. - GUnzipPostProcessor() - Constructor for class org.springframework.amqp.support.postprocessor.GUnzipPostProcessor
- GUnzipPostProcessor(boolean) - Constructor for class org.springframework.amqp.support.postprocessor.GUnzipPostProcessor
- GZipPostProcessor - Class in org.springframework.amqp.support.postprocessor
-
A post processor that uses a
GZIPOutputStream
to compress the message body. - GZipPostProcessor() - Constructor for class org.springframework.amqp.support.postprocessor.GZipPostProcessor
- GZipPostProcessor(boolean) - Constructor for class org.springframework.amqp.support.postprocessor.GZipPostProcessor
H
- handle(Return) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- handle(Error) - Method in interface org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.JavaLangErrorHandler
-
Handle the error; typically, the JVM will be terminated.
- handle(R) - Method in interface org.springframework.amqp.core.ReceiveAndReplyCallback
- handleAck(long, boolean) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- handleConfirm(PendingConfirm, boolean) - Method in interface org.springframework.amqp.rabbit.connection.PublisherCallbackChannel.Listener
-
Invoked by the channel when a confirm is received.
- handleConfirm(PendingConfirm, boolean) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
- handleDiscarded(Message) - Method in class org.springframework.amqp.rabbit.listener.ConditionalRejectingErrorHandler
-
Called when a message with a fatal exception has an
x-death
header, prior to discarding the message. - handleError(Throwable) - Method in class org.springframework.amqp.rabbit.listener.ConditionalRejectingErrorHandler
- handleError(Message, Message<?>, ListenerExecutionFailedException) - Method in interface org.springframework.amqp.rabbit.listener.api.RabbitListenerErrorHandler
-
Handle the error.
- handleListenerException(Throwable) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
-
Handle the given exception that arose during listener execution.
- handleListenerException(Throwable) - Method in class org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener
-
Handle the given exception that arose during listener execution.
- handleMessage(T) - Method in interface org.springframework.amqp.rabbit.listener.adapter.ReplyingMessageListener
-
Handle the message and return a reply.
- handleNack(long, boolean) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- HandlerAdapter - Class in org.springframework.amqp.rabbit.listener.adapter
-
A wrapper for either an
InvocableHandlerMethod
orDelegatingInvocableHandler
. - HandlerAdapter(DelegatingInvocableHandler) - Constructor for class org.springframework.amqp.rabbit.listener.adapter.HandlerAdapter
-
Construct an instance with the provided delegating handler.
- HandlerAdapter(InvocableHandlerMethod) - Constructor for class org.springframework.amqp.rabbit.listener.adapter.HandlerAdapter
-
Construct an instance with the provided method.
- handleRecovery(Recoverable) - Method in class org.springframework.amqp.rabbit.connection.ClosingRecoveryListener
- handleRecoveryStarted(Recoverable) - Method in class org.springframework.amqp.rabbit.connection.ClosingRecoveryListener
- handleResult(InvocationResult, Message, Channel) - Method in class org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener
-
Handle the given result object returned from the listener method, sending a response message back.
- handleResult(InvocationResult, Message, Channel, Object) - Method in class org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener
-
Handle the given result object returned from the listener method, sending a response message back.
- handleReturn(int, String, String, String, AMQP.BasicProperties, byte[]) - Method in interface org.springframework.amqp.rabbit.connection.PublisherCallbackChannel.Listener
-
Deprecated.
- handleReturn(int, String, String, String, AMQP.BasicProperties, byte[]) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
- handleReturn(Return) - Method in interface org.springframework.amqp.rabbit.connection.PublisherCallbackChannel.Listener
-
Handle a returned message.
- handleReturn(Return) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
- handleStartupFailure(BackOffExecution) - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer
- has(Object) - Static method in class org.springframework.amqp.rabbit.connection.SimpleResourceHolder
-
Check if there is a resource for the given key bound to the current thread.
- hasDefaultHandler() - Method in class org.springframework.amqp.rabbit.listener.adapter.DelegatingInvocableHandler
- hasDelivery() - Method in class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer
- hashCode() - Method in class org.springframework.amqp.core.Address
- hashCode() - Method in class org.springframework.amqp.core.Message
- hashCode() - Method in class org.springframework.amqp.core.MessageProperties
- hashCode() - Method in class org.springframework.amqp.core.QueueInformation
- hashCode() - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- hashCode() - Method in class org.springframework.rabbit.stream.support.StreamMessageProperties
- hasInferredTypeHeader(MessageProperties) - Method in class org.springframework.amqp.support.converter.AbstractJavaTypeMapper
- hasPublisherConnectionFactory() - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
- HEADERS - Static variable in class org.springframework.amqp.core.ExchangeTypes
-
Headers exchange.
- headersExchange(String) - Static method in class org.springframework.amqp.core.ExchangeBuilder
-
Return a
HeadersExchange
builder. - HeadersExchange - Class in org.springframework.amqp.core
-
Headers exchange.
- HeadersExchange(String) - Constructor for class org.springframework.amqp.core.HeadersExchange
- HeadersExchange(String, boolean, boolean) - Constructor for class org.springframework.amqp.core.HeadersExchange
- HeadersExchange(String, boolean, boolean, Map<String, Object>) - Constructor for class org.springframework.amqp.core.HeadersExchange
- HeadersExchangeParser - Class in org.springframework.amqp.rabbit.config
- HeadersExchangeParser() - Constructor for class org.springframework.amqp.rabbit.config.HeadersExchangeParser
- host() - Method in annotation type org.springframework.amqp.rabbit.test.context.SpringRabbitTest
-
Set the host when not using
RabbitAvailable
.
I
- id() - Method in annotation type org.springframework.amqp.rabbit.annotation.RabbitListener
-
The unique identifier of the container managing for this endpoint.
- ignoreDeclarationExceptions() - Method in class org.springframework.amqp.core.ExchangeBuilder
-
Switch on ignore exceptions such as mismatched properties when declaring.
- ignoreDeclarationExceptions() - Method in annotation type org.springframework.amqp.rabbit.annotation.Exchange
- ignoreDeclarationExceptions() - Method in annotation type org.springframework.amqp.rabbit.annotation.Queue
- ignoreDeclarationExceptions() - Method in annotation type org.springframework.amqp.rabbit.annotation.QueueBinding
- 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(String, Throwable) - Constructor for exception org.springframework.amqp.ImmediateAcknowledgeAmqpException
- ImmediateAcknowledgeAmqpException(Throwable) - Constructor for exception org.springframework.amqp.ImmediateAcknowledgeAmqpException
- ImmediateRequeueAmqpException - Exception in org.springframework.amqp
-
The special
AmqpException
to be thrown from the listener (e.g. - ImmediateRequeueAmqpException(String) - Constructor for exception org.springframework.amqp.ImmediateRequeueAmqpException
- ImmediateRequeueAmqpException(String, Throwable) - Constructor for exception org.springframework.amqp.ImmediateRequeueAmqpException
- ImmediateRequeueAmqpException(Throwable) - Constructor for exception org.springframework.amqp.ImmediateRequeueAmqpException
- ImmediateRequeueMessageRecoverer - Class in org.springframework.amqp.rabbit.retry
-
The
MessageRecoverer
implementation to throw anImmediateRequeueAmqpException
for subsequent requeuing in the listener container. - ImmediateRequeueMessageRecoverer() - Constructor for class org.springframework.amqp.rabbit.retry.ImmediateRequeueMessageRecoverer
- incrementRetries() - Method in class org.springframework.amqp.rabbit.log4j2.AmqpAppender.Event
- incrementRetries() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender.Event
- INFERRED - org.springframework.amqp.support.converter.Jackson2JavaTypeMapper.TypePrecedence
- 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
- init() - Method in class org.springframework.amqp.rabbit.config.RabbitNamespaceHandler
- initDefaultStrategies() - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
-
Set up the default strategies.
- initGateway() - Method in class org.springframework.amqp.rabbit.core.RabbitGatewaySupport
-
Subclasses can override this for custom initialization behavior.
- initialize() - Method in interface org.springframework.amqp.core.AmqpAdmin
-
Initialize the admin.
- initialize() - Method in class org.springframework.amqp.rabbit.core.RabbitAdmin
-
Declares all the exchanges, queues and bindings in the enclosing application context, if any.
- initialize() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
-
Initialize this container.
- initializeConsumers() - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer
- initializeContainer(C, RabbitListenerEndpoint) - Method in class org.springframework.amqp.rabbit.config.AbstractRabbitListenerContainerFactory
-
Further initialize the specified container.
- initializeContainer(DirectMessageListenerContainer, RabbitListenerEndpoint) - Method in class org.springframework.amqp.rabbit.config.DirectRabbitListenerContainerFactory
- initializeContainer(SimpleMessageListenerContainer, RabbitListenerEndpoint) - Method in class org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory
- initializeProxy(Object) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- INORDER - org.springframework.amqp.rabbit.connection.AbstractConnectionFactory.AddressShuffleMode
-
Shuffle the addresses after opening a connection, moving the first address to the end.
- 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.
- internal() - Method in annotation type org.springframework.amqp.rabbit.annotation.Exchange
- InvocationData(MethodInvocation, Object) - Constructor for class org.springframework.amqp.rabbit.test.RabbitListenerTestHarness.InvocationData
- InvocationData(MethodInvocation, Throwable) - Constructor for class org.springframework.amqp.rabbit.test.RabbitListenerTestHarness.InvocationData
- InvocationResult - Class in org.springframework.amqp.rabbit.listener.adapter
-
The result of a listener method invocation.
- InvocationResult(Object, Expression, Type, Object, Method) - Constructor for class org.springframework.amqp.rabbit.listener.adapter.InvocationResult
-
Construct an instance with the provided properties.
- invoke(MethodInvocation) - Method in class org.springframework.amqp.remoting.client.AmqpClientInterceptor
-
Deprecated.
- invoke(RabbitOperations.OperationsCallback<T>) - Method in interface org.springframework.amqp.rabbit.core.RabbitOperations
-
Invoke the callback and run all operations on the template argument in a dedicated thread-bound channel and reliably close the channel afterwards.
- invoke(RabbitOperations.OperationsCallback<T>, ConfirmCallback, ConfirmCallback) - Method in interface org.springframework.amqp.rabbit.core.RabbitOperations
-
Invoke operations on the same channel.
- invoke(RabbitOperations.OperationsCallback<T>, ConfirmCallback, ConfirmCallback) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
- invoke(Message<?>, Object...) - Method in class org.springframework.amqp.rabbit.listener.adapter.DelegatingInvocableHandler
-
Invoke the method with the given message.
- invoke(Message<?>, Object...) - Method in class org.springframework.amqp.rabbit.listener.adapter.HandlerAdapter
-
Invoke the appropriate method for the payload.
- invokeErrorHandler(Throwable) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
-
Invoke the registered ErrorHandler, if any.
- invokeHandlerAndProcessResult(Message, Channel, Message<?>) - Method in class org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter
- invokeListener(Channel, Object) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- invokeListenerMethod(String, Object[], Message) - Method in class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter
-
Invoke the specified listener method.
- isAck() - Method in class org.springframework.amqp.rabbit.connection.CorrelationData.Confirm
- isActive() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- isActive() - Method in class org.springframework.amqp.rabbit.support.ActiveObjectCounter
- isAddMdcAsHeaders() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
- isAlwaysRequeueWithTxManagerRollback() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- isAmqpMessageList() - Method in class org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter.MessagingMessageConverterAdapter
- isAsyncReplies() - Method in interface org.springframework.amqp.core.MessageListener
-
Return true if this listener is request/reply and the replies are async.
- isAsyncReplies() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- isAsyncReplies() - Method in class org.springframework.amqp.rabbit.listener.adapter.DelegatingInvocableHandler
-
Return true if any handler method has an async reply type.
- isAsyncReplies() - Method in class org.springframework.amqp.rabbit.listener.adapter.HandlerAdapter
-
Return true if any handler method has an async reply type.
- isAsyncReplies() - Method in class org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter
- isAttributeDefined(Element, String) - Static method in class org.springframework.amqp.rabbit.config.NamespaceUtils
-
Checks the attribute to see if it is defined in the given element.
- isAutoAck() - Method in enum org.springframework.amqp.core.AcknowledgeMode
-
Return if the mode is
AcknowledgeMode.NONE
(which is calledautoAck
in RabbitMQ). - isAutoDeclare() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- isAutoDelete() - Method in class org.springframework.amqp.core.AbstractExchange
- isAutoDelete() - Method in interface org.springframework.amqp.core.Exchange
-
True if the server should delete the exchange when it is no longer in use (if all bindings are deleted).
- isAutoDelete() - Method in class org.springframework.amqp.core.Queue
-
True if the server should delete the queue when it is no longer in use (the last consumer is cancelled).
- isAutoDelete() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
- isAutoStartup() - Method in class org.springframework.amqp.rabbit.AsyncRabbitTemplate
- isAutoStartup() - Method in class org.springframework.amqp.rabbit.config.ListenerContainerFactoryBean
- isAutoStartup() - Method in class org.springframework.amqp.rabbit.core.BrokerEventListener
- isAutoStartup() - Method in class org.springframework.amqp.rabbit.core.RabbitAdmin
- isAutoStartup() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- isAutoStartup() - Method in class org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistry
- isAutoStartup() - Method in class org.springframework.rabbit.stream.listener.StreamListenerContainer
- isBatchListener() - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint
- isBrokerAndManagementRunning() - Static method in class org.springframework.amqp.rabbit.junit.BrokerRunning
- isBrokerAndManagementRunning() - Static method in class org.springframework.amqp.rabbit.junit.BrokerRunningSupport
- isBrokerAndManagementRunningWithEmptyQueues(String...) - Static method in class org.springframework.amqp.rabbit.junit.BrokerRunning
- isBrokerAndManagementRunningWithEmptyQueues(String...) - Static method in class org.springframework.amqp.rabbit.junit.BrokerRunningSupport
- isChannelLocallyTransacted() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
-
Check whether the given Channel is locally transacted, that is, whether its transaction is managed by this listener container's Channel handling and not by an external transaction coordinator.
- isChannelLocallyTransacted(Channel) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
-
Check whether the given Channel is locally transacted, that is, whether its transaction is managed by this template's Channel handling and not by an external transaction coordinator.
- isChannelTransacted() - Method in class org.springframework.amqp.rabbit.connection.RabbitAccessor
- isChannelTransactional(Channel, ConnectionFactory) - Static method in class org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils
-
Determine whether the given RabbitMQ Channel is transactional, that is, bound to the current thread by Spring's transaction facilities.
- isConfirmListener() - Method in interface org.springframework.amqp.rabbit.connection.PublisherCallbackChannel.Listener
- isConfirmListener() - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
- isConfirmSelected() - Method in interface org.springframework.amqp.rabbit.connection.ChannelProxy
-
Return true if confirms are selected on this channel.
- isConsumerBatchEnabled() - Method in interface org.springframework.amqp.rabbit.listener.MessageListenerContainer
-
Return true if this container is capable of (and configured to) create batches of consumed messages.
- isConsumerBatchEnabled() - Method in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer
- isContentLengthSet() - Method in class org.springframework.amqp.core.MessageProperties
- isConverterWinsContentType() - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint
- isConverterWinsContentType() - Method in class org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener
-
Return whether the content type set by a converter prevails or not.
- isConverterWinsContentType() - Method in interface org.springframework.amqp.rabbit.listener.RabbitListenerEndpoint
-
Return whether the content type set by a converter prevails or not.
- 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.
- isDeBatchingEnabled() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- isDeclareExchange() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
- isDefault() - Method in annotation type org.springframework.amqp.rabbit.annotation.RabbitHandler
-
When true, designate that this is the default fallback method if the payload type matches no other
RabbitHandler
method. - isDefaultRequeueRejected() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
-
Return the default requeue rejected.
- 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
- isDiscardFatalsWithXDeath() - Method in class org.springframework.amqp.rabbit.listener.ConditionalRejectingErrorHandler
-
Return the discardFatalsWithXDeath.
- isDurable() - Method in class org.springframework.amqp.core.AbstractExchange
- isDurable() - Method in interface org.springframework.amqp.core.Exchange
-
A durable exchange will survive a server restart.
- isDurable() - Method in class org.springframework.amqp.core.Queue
-
A durable queue will survive a server restart.
- isDurable() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
- isExchangeDeclarationFailure(Exception) - Static method in class org.springframework.amqp.rabbit.connection.RabbitUtils
-
Return true if there is a
ShutdownSignalException
in the cause tree and its reason is "COMMAND_INVALID" and the operation being performed was exchangeDeclare. - isExclusive() - Method in class org.springframework.amqp.core.Queue
-
True if the server should only send messages to the declarer's connection.
- isExclusive() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
-
Return whether the consumers should be exclusive.
- isExclusive() - Method in class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint
- isExclusiveUseChannelClose(ShutdownSignalException) - Static method in class org.springframework.amqp.rabbit.connection.RabbitUtils
-
Return true if the
ShutdownSignalException
reason is AMQP.Channel.Close and the operation that failed was basicConsumer and the failure text contains "exclusive". - isExistingTransaction(Object) - Method in class org.springframework.amqp.rabbit.transaction.RabbitTransactionManager
- isExposeListenerChannel() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- isFatal() - Method in class org.springframework.amqp.rabbit.listener.ListenerContainerConsumerFailedEvent
- isFatal(Throwable) - Method in class org.springframework.amqp.rabbit.listener.ConditionalRejectingErrorHandler.DefaultExceptionStrategy
- isFatal(Throwable) - Method in interface org.springframework.amqp.rabbit.listener.FatalExceptionStrategy
- isFinalRetryForMessageWithNoId() - Method in class org.springframework.amqp.core.MessageProperties
- isForceCloseChannel() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
-
Force close the channel if the consumer threads don't respond to a shutdown.
- isGenerateId() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
- isGlobalQos() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- 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.
- isIncludeCallerData() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
- 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.
- isLenientFallback() - Method in class org.springframework.amqp.rabbit.connection.AbstractRoutingConnectionFactory
- isMandatoryFor(Message) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
-
Return whether the provided message should be sent with the mandatory flag set.
- isManual() - Method in enum org.springframework.amqp.core.AcknowledgeMode
-
Return true if the mode is
AcknowledgeMode.MANUAL
. - isMessageList() - Method in class org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter.MessagingMessageConverterAdapter
- isMismatchedQueueArgs(Exception) - Static method in class org.springframework.amqp.rabbit.connection.RabbitUtils
-
Return true if there is a
ShutdownSignalException
in the cause tree and its reason is "PRECONDITION_FAILED" and the operation being performed was queueDeclare. - isMismatchedQueuesFatal() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- isMissingQueuesFatal() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- isMissingQueuesFatalSet() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- isNew(Message) - Method in interface org.springframework.amqp.rabbit.retry.NewMessageIdentifier
-
Query a message to see if it has been seen before.
- isNoLocal() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
-
Return whether the consumers should be no-local.
- isNormalCancel() - Method in class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer
-
Return true if cancellation is expected.
- isNormalChannelClose(ShutdownSignalException) - Static method in class org.springframework.amqp.rabbit.connection.RabbitUtils
-
Return true if the
ShutdownSignalException
reason is AMQP.Channel.Close and the reply code was AMQP.REPLY_SUCCESS (200) and the text equals "OK". - isNormalShutdown(ShutdownSignalException) - Static method in class org.springframework.amqp.rabbit.connection.RabbitUtils
-
Return true if the
ShutdownSignalException
reason is AMQP.Connection.Close and the reply code was AMQP.REPLY_SUCCESS (200) and the text equals "OK". - isNotRunning() - Static method in class org.springframework.amqp.rabbit.junit.BrokerRunning
- isNotRunning() - Static method in class org.springframework.amqp.rabbit.junit.BrokerRunningSupport
- isOpen() - Method in interface org.springframework.amqp.rabbit.connection.Connection
-
Flag to indicate the status of the connection.
- isOpen() - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- isOpen() - Method in class org.springframework.amqp.rabbit.connection.SimpleConnection
-
True if the connection is open.
- isPassiveDeclarationChannelClose(ShutdownSignalException) - Static method in class org.springframework.amqp.rabbit.connection.RabbitUtils
-
Return true if the
ShutdownSignalException
reason is AMQP.Channel.Close and the operation that failed was exchangeDeclare or queueDeclare. - isPhysicalCloseRequired() - Static method in class org.springframework.amqp.rabbit.connection.RabbitUtils
-
Gets and removes a ThreadLocal indicating the channel MUST be physically closed.
- isPossibleAuthenticationFailureFatal() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- isPossibleAuthenticationFailureFatalSet() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- isProjectionUsed() - Method in class org.springframework.amqp.core.MessageProperties
-
Get an internal flag used to communicate that conversion used projection; always false at the application level.
- isPublisherConfirms() - Method in class org.springframework.amqp.rabbit.connection.AbstractRoutingConnectionFactory
- isPublisherConfirms() - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory
- isPublisherConfirms() - Method in interface org.springframework.amqp.rabbit.connection.ConnectionFactory
-
Return true if publisher confirms are enabled.
- isPublisherReturns() - Method in class org.springframework.amqp.rabbit.connection.AbstractRoutingConnectionFactory
- isPublisherReturns() - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory
- isPublisherReturns() - Method in interface org.springframework.amqp.rabbit.connection.ConnectionFactory
-
Return true if publisher returns are enabled.
- isPurgeAfterEach() - Method in class org.springframework.amqp.rabbit.junit.BrokerRunningSupport
- isRedeclareManualDeclarations() - Method in class org.springframework.amqp.rabbit.core.RabbitAdmin
-
Normally, when a connection is recovered, the admin only recovers auto-delete queues, etc, that are declared as beans in the application context.
- 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.
- isRejectManual() - Method in class org.springframework.amqp.rabbit.listener.ConditionalRejectingErrorHandler
-
Return the rejectManual.
- isRejectManual(Throwable) - Static method in class org.springframework.amqp.rabbit.listener.support.ContainerUtils
-
Return true for
AmqpRejectAndDontRequeueException.isRejectManual()
. - isReleaseAfterCompletion() - Method in class org.springframework.amqp.rabbit.connection.RabbitResourceHolder
-
Whether the resources should be released after transaction completion.
- isReturned() - Method in class org.springframework.amqp.rabbit.connection.PendingConfirm
-
True if a returned message has been received.
- isReturnListener() - Method in interface org.springframework.amqp.rabbit.connection.PublisherCallbackChannel.Listener
- isReturnListener() - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
- isRunning() - Method in class org.springframework.amqp.rabbit.AsyncRabbitTemplate
- isRunning() - Method in class org.springframework.amqp.rabbit.config.ListenerContainerFactoryBean
- isRunning() - Method in class org.springframework.amqp.rabbit.core.BatchingRabbitTemplate
- isRunning() - Method in class org.springframework.amqp.rabbit.core.BrokerEventListener
- isRunning() - Method in interface org.springframework.amqp.rabbit.core.RabbitOperations
- isRunning() - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
- isRunning() - Static method in class org.springframework.amqp.rabbit.junit.BrokerRunning
- isRunning() - Static method in class org.springframework.amqp.rabbit.junit.BrokerRunningSupport
- isRunning() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
-
Determine whether this container is currently running, that is, whether it has been started and not stopped yet.
- isRunning() - Method in class org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistry
- isRunning() - Method in class org.springframework.rabbit.stream.listener.StreamListenerContainer
- isRunningWithEmptyQueues(String...) - Static method in class org.springframework.amqp.rabbit.junit.BrokerRunning
-
Ensure the broker is running and has a empty queue(s) with the specified name(s) in the default exchange.
- isRunningWithEmptyQueues(String...) - Static method in class org.springframework.amqp.rabbit.junit.BrokerRunningSupport
-
Ensure the broker is running and has a empty queue(s) with the specified name(s) in the default exchange.
- isShouldRun() - Method in class org.springframework.amqp.rabbit.junit.LongRunningIntegrationTest
-
Return true if the test should run.
- isSimplePublisherConfirms() - Method in class org.springframework.amqp.rabbit.connection.CachingConnectionFactory
- isSimplePublisherConfirms() - Method in interface org.springframework.amqp.rabbit.connection.ConnectionFactory
-
Return true if simple publisher confirms are enabled.
- isSimplePublisherConfirms() - Method in class org.springframework.amqp.rabbit.connection.PooledChannelConnectionFactory
- isSimplePublisherConfirms() - Method in class org.springframework.amqp.rabbit.connection.ThreadChannelConnectionFactory
- isSingleton() - Method in class org.springframework.amqp.rabbit.config.AbstractRetryOperationsInterceptorFactoryBean
- isSingleton() - Method in class org.springframework.amqp.rabbit.config.BindingFactoryBean
- isSingleton() - Method in class org.springframework.amqp.rabbit.config.StatefulRetryOperationsInterceptorFactoryBean
- isSingleton() - Method in class org.springframework.amqp.rabbit.config.StatelessRetryOperationsInterceptorFactoryBean
- isSingleton() - Method in class org.springframework.amqp.remoting.client.AmqpProxyFactoryBean
-
Deprecated.
- isSkipServerCertificateValidation() - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
-
Whether or not Server Side certificate has to be validated or not.
- isStatefulRetryFatalWithNullMessageId() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- isSynchedLocalTransactionAllowed() - Method in interface org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils.ResourceFactory
-
Return whether to allow for a local RabbitMQ transaction that is synchronized with a Spring-managed transaction (where the main transaction might be a JDBC-based one for a specific DataSource, for example), with the RabbitMQ transaction committing right after the main transaction.
- isTransactional() - Method in interface org.springframework.amqp.rabbit.connection.ChannelProxy
-
Return whether this channel has transactions enabled
txSelect()
. - isTransactionAllowed() - Method in enum org.springframework.amqp.core.AcknowledgeMode
-
Return if transactions are allowed - if the mode is
AcknowledgeMode.AUTO
orAcknowledgeMode.MANUAL
. - isTypeMapperSet() - Method in class org.springframework.amqp.support.converter.AbstractJackson2MessageConverter
-
Whether or not an explicit java type mapper has been provided.
- isUp() - Method in class org.springframework.amqp.rabbit.junit.BrokerRunning
- isUseProjectionForInterfaces() - Method in class org.springframework.amqp.support.converter.AbstractJackson2MessageConverter
- isUsePublisherConnection() - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
-
True if separate publisher connection(s) are used.
- isUserCauseFatal(Throwable) - Method in class org.springframework.amqp.rabbit.listener.ConditionalRejectingErrorHandler.DefaultExceptionStrategy
-
Subclasses can override this to add custom exceptions.
- isUseSsl() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
- isUseSSL() - Method in class org.springframework.amqp.rabbit.connection.RabbitConnectionFactoryBean
- isVerifyHostname() - Method in class org.springframework.amqp.rabbit.logback.AmqpAppender
-
Return true (default) if TLS hostname verification is enabled.
- isWritable(Object) - Method in class org.springframework.amqp.rabbit.support.ValueExpression
- isWritable(EvaluationContext) - Method in class org.springframework.amqp.rabbit.support.ValueExpression
- isWritable(EvaluationContext, Object) - Method in class org.springframework.amqp.rabbit.support.ValueExpression
J
- Jackson2JavaTypeMapper - Interface in org.springframework.amqp.support.converter
-
Strategy for setting metadata on messages such that one can create the class that needs to be instantiated when receiving a message.
- Jackson2JavaTypeMapper.TypePrecedence - Enum in org.springframework.amqp.support.converter
-
The precedence for type conversion - inferred from the method parameter or message headers.
- Jackson2JsonMessageConverter - Class in org.springframework.amqp.support.converter
-
JSON converter that uses the Jackson 2 Json library.
- Jackson2JsonMessageConverter() - Constructor for class org.springframework.amqp.support.converter.Jackson2JsonMessageConverter
-
Construct with an internal
ObjectMapper
instance and trusted packed to all (*
). - Jackson2JsonMessageConverter(ObjectMapper) - Constructor for class org.springframework.amqp.support.converter.Jackson2JsonMessageConverter
-
Construct with the provided
ObjectMapper
instance and trusted packed to all (*
). - Jackson2JsonMessageConverter(ObjectMapper, String...) - Constructor for class org.springframework.amqp.support.converter.Jackson2JsonMessageConverter
-
Construct with the provided
ObjectMapper
instance. - Jackson2JsonMessageConverter(String...) - Constructor for class org.springframework.amqp.support.converter.Jackson2JsonMessageConverter
-
Construct with an internal
ObjectMapper
instance. - Jackson2XmlMessageConverter - Class in org.springframework.amqp.support.converter
-
XML converter that uses the Jackson 2 Xml library.
- Jackson2XmlMessageConverter() - Constructor for class org.springframework.amqp.support.converter.Jackson2XmlMessageConverter
-
Construct with an internal
XmlMapper
instance and trusted packed to all (*
). - Jackson2XmlMessageConverter(XmlMapper) - Constructor for class org.springframework.amqp.support.converter.Jackson2XmlMessageConverter
-
Construct with the provided
XmlMapper
instance and trusted packed to all (*
). - Jackson2XmlMessageConverter(XmlMapper, String...) - Constructor for class org.springframework.amqp.support.converter.Jackson2XmlMessageConverter
-
Construct with the provided
XmlMapper
instance. - Jackson2XmlMessageConverter(String...) - Constructor for class org.springframework.amqp.support.converter.Jackson2XmlMessageConverter
-
Construct with an internal
XmlMapper
instance. - JavaUtils - Class in org.springframework.amqp.utils
-
Chained utility methods to simplify some Java repetitive code.
- JUnitUtils - Class in org.springframework.amqp.rabbit.junit
-
Utility methods for JUnit rules and conditions.
- JUnitUtils.LevelsContainer - Class in org.springframework.amqp.rabbit.junit
K
- key() - Method in annotation type org.springframework.amqp.rabbit.annotation.QueueBinding
L
- LambdaAnswer<T> - Class in org.springframework.amqp.rabbit.test.mockito
-
An
Answer
to optionally call the real method and allow returning a custom result. - LambdaAnswer(boolean, LambdaAnswer.ValueToReturn<T>) - Constructor for class org.springframework.amqp.rabbit.test.mockito.LambdaAnswer
-
Deprecated.in favor of
LambdaAnswer(boolean, ValueToReturn, Object)
. - LambdaAnswer(boolean, LambdaAnswer.ValueToReturn<T>, Object) - Constructor for class org.springframework.amqp.rabbit.test.mockito.LambdaAnswer
-
Construct an instance with the provided properties.
- LambdaAnswer.ValueToReturn<T> - Interface in org.springframework.amqp.rabbit.test.mockito
- LAST_IN_BATCH - Static variable in class org.springframework.amqp.support.AmqpHeaders
-
A flag to indicate that the current message is the last from a batch.
- LatchCountDownAndCallRealMethodAnswer - Class in org.springframework.amqp.rabbit.test.mockito
-
An
Answer
for void returning methods that calls the real method and counts down a latch. - LatchCountDownAndCallRealMethodAnswer(int) - Constructor for class org.springframework.amqp.rabbit.test.mockito.LatchCountDownAndCallRealMethodAnswer
-
Deprecated.in favor of
LatchCountDownAndCallRealMethodAnswer(int, Object)
. - LatchCountDownAndCallRealMethodAnswer(int, Object) - Constructor for class org.springframework.amqp.rabbit.test.mockito.LatchCountDownAndCallRealMethodAnswer
-
Get an instance with the provided properties.
- lazy() - Method in class org.springframework.amqp.core.QueueBuilder
-
Set the queue into lazy mode, keeping as many messages as possible on disk to reduce RAM usage on the broker.
- lazyLoad() - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- lazyLoad() - Method in interface org.springframework.amqp.rabbit.listener.MessageListenerContainer
-
Do not check for missing or mismatched queues during startup.
- leaderLocator(QueueBuilder.LeaderLocator) - 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.
- level() - Method in annotation type org.springframework.amqp.rabbit.junit.LogLevels
-
The Log4j level name to switch the categories to during the test.
- LevelsContainer(Map<Class<?>, Level>, Map<String, Level>, Map<String, Level>) - Constructor for class org.springframework.amqp.rabbit.junit.JUnitUtils.LevelsContainer
- ListenerContainerAware - Interface in org.springframework.amqp.rabbit.support
-
MessageListener
s that also implement this interface can have configuration verified during initialization. - ListenerContainerConsumerFailedEvent - Class in org.springframework.amqp.rabbit.listener
-
Published when a listener consumer fails.
- ListenerContainerConsumerFailedEvent(Object, String, Throwable, boolean) - Constructor for class org.springframework.amqp.rabbit.listener.ListenerContainerConsumerFailedEvent
-
Construct an instance with the provided arguments.
- ListenerContainerConsumerTerminatedEvent - Class in org.springframework.amqp.rabbit.listener
-
Published when a listener consumer is terminated.
- ListenerContainerConsumerTerminatedEvent(Object, String) - Constructor for class org.springframework.amqp.rabbit.listener.ListenerContainerConsumerTerminatedEvent
-
Construct an instance with the provided arguments.
- ListenerContainerFactoryBean - Class in org.springframework.amqp.rabbit.config
-
A Factory bean to create a listener container.
- ListenerContainerFactoryBean() - Constructor for class org.springframework.amqp.rabbit.config.ListenerContainerFactoryBean
- ListenerContainerFactoryBean.Type - Enum in org.springframework.amqp.rabbit.config
-
The container type.
- ListenerContainerIdleEvent - Class in org.springframework.amqp.rabbit.listener
-
An event that is emitted when a container is idle if the container is configured to do so.
- ListenerContainerIdleEvent(Object, long, String, String...) - Constructor for class org.springframework.amqp.rabbit.listener.ListenerContainerIdleEvent
- ListenerExecutionFailedException - Exception in org.springframework.amqp.rabbit.support
-
Exception to be thrown when the execution of a listener method failed.
- ListenerExecutionFailedException(String, Throwable, Message...) - Constructor for exception org.springframework.amqp.rabbit.support.ListenerExecutionFailedException
-
Constructor for ListenerExecutionFailedException.
- ListenerFailedRuleBasedTransactionAttribute - Class in org.springframework.amqp.rabbit.listener
-
Subclass of
RuleBasedTransactionAttribute
that is aware that listener exceptions are wrapped inListenerExecutionFailedException
s. - ListenerFailedRuleBasedTransactionAttribute() - Constructor for class org.springframework.amqp.rabbit.listener.ListenerFailedRuleBasedTransactionAttribute
- LocalizedQueueConnectionFactory - Class in org.springframework.amqp.rabbit.connection
-
A
RoutingConnectionFactory
that determines the node on which a queue is located and returns a factory that connects directly to that node. - LocalizedQueueConnectionFactory(ConnectionFactory, String[], String[], String[], String, String, String, boolean, String, String, String, String) - Constructor for class org.springframework.amqp.rabbit.connection.LocalizedQueueConnectionFactory
- LocalizedQueueConnectionFactory(ConnectionFactory, String[], String[], String[], String, String, String, boolean, Resource) - Constructor for class org.springframework.amqp.rabbit.connection.LocalizedQueueConnectionFactory
- LocalizedQueueConnectionFactory(ConnectionFactory, Map<String, String>, String[], String, String, String, boolean, String, String, String, String) - Constructor for class org.springframework.amqp.rabbit.connection.LocalizedQueueConnectionFactory
- LocalizedQueueConnectionFactory(ConnectionFactory, Map<String, String>, String[], String, String, String, boolean, Resource) - Constructor for class org.springframework.amqp.rabbit.connection.LocalizedQueueConnectionFactory
- log - Variable in class org.springframework.amqp.support.converter.AbstractJackson2MessageConverter
- log(Throwable) - Method in class org.springframework.amqp.rabbit.listener.ConditionalRejectingErrorHandler
-
Log the throwable at WARN level, including stack trace.
- log(Log, String, Throwable) - Method in interface org.springframework.amqp.support.ConditionalExceptionLogger
-
Log the event.
- logFatalException(ListenerExecutionFailedException, Throwable) - Method in class org.springframework.amqp.rabbit.listener.ConditionalRejectingErrorHandler.DefaultExceptionStrategy
-
Log the fatal ListenerExecutionFailedException at WARN level, excluding stack trace.
- logger - Variable in class org.springframework.amqp.rabbit.config.AbstractRabbitListenerContainerFactory
- logger - Variable in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
- logger - Variable in class org.springframework.amqp.rabbit.connection.RabbitAccessor
-
Logger available to subclasses.
- logger - Variable in class org.springframework.amqp.rabbit.core.RabbitAdmin
-
Logger available to subclasses.
- logger - Variable in class org.springframework.amqp.rabbit.core.RabbitGatewaySupport
-
Logger available to subclasses.
- logger - Variable in class org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener
-
Logger available to subclasses.
- logger - Variable in class org.springframework.amqp.rabbit.listener.ConditionalRejectingErrorHandler.DefaultExceptionStrategy
- logger - Variable in class org.springframework.amqp.rabbit.listener.ConditionalRejectingErrorHandler
- logger - Variable in class org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistry
- logger - Variable in class org.springframework.amqp.rabbit.retry.ImmediateRequeueMessageRecoverer
- logger - Variable in class org.springframework.amqp.rabbit.retry.RejectAndDontRequeueRecoverer
- logger - Variable in class org.springframework.amqp.rabbit.retry.RepublishMessageRecoverer
- logger - Variable in class org.springframework.amqp.support.postprocessor.AbstractCompressingPostProcessor
- logger - Variable in class org.springframework.rabbit.stream.listener.StreamListenerContainer
- logger - Variable in class org.springframework.rabbit.stream.producer.RabbitStreamTemplate
- LogLevelAdjuster - Class in org.springframework.amqp.rabbit.junit
-
A JUnit method @Rule that changes the logger level for a set of classes while a test method is running.
- LogLevelAdjuster(Level, Class<?>...) - Constructor for class org.springframework.amqp.rabbit.junit.LogLevelAdjuster
- LogLevels - Annotation Type in org.springframework.amqp.rabbit.junit
-
Test classes annotated with this will change logging levels between tests.
- LogLevelsCondition - Class in org.springframework.amqp.rabbit.junit
-
JUnit condition that adjusts and reverts log levels before/after each test.
- LogLevelsCondition() - Constructor for class org.springframework.amqp.rabbit.junit.LogLevelsCondition
- LongRunning - Annotation Type in org.springframework.amqp.rabbit.junit
-
Test classes annotated with this will not run if an environment variable or system property (default
RUN_LONG_INTEGRATION_TESTS
) is not present or does not have the value thatBoolean.parseBoolean(String)
evaluates totrue
. - LongRunningIntegrationTest - Class in org.springframework.amqp.rabbit.junit
-
Rule to prevent long running tests from running on every build; set environment variable RUN_LONG_INTEGRATION_TESTS on a CI nightly build to ensure coverage.
- LongRunningIntegrationTest() - Constructor for class org.springframework.amqp.rabbit.junit.LongRunningIntegrationTest
- LongRunningIntegrationTest(String) - Constructor for class org.springframework.amqp.rabbit.junit.LongRunningIntegrationTest
-
Check using a custom variable/property name.
- LongRunningIntegrationTestCondition - Class in org.springframework.amqp.rabbit.junit
-
ExecutionCondition
to skip long running tests unless an environment variable or property is set. - LongRunningIntegrationTestCondition() - Constructor for class org.springframework.amqp.rabbit.junit.LongRunningIntegrationTestCondition
M
- management() - Method in annotation type org.springframework.amqp.rabbit.junit.RabbitAvailable
-
Requires the management plugin to be available.
- MANUAL - org.springframework.amqp.core.AcknowledgeMode
-
Manual acks - user must ack/nack via a channel aware listener.
- MapBuilder<B extends MapBuilder<B,K,V>,K,V> - Class in org.springframework.amqp.utils
-
A
Builder
pattern implementation for aMap
. - 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
- MarshallingMessageConverter(Marshaller) - Constructor for class org.springframework.amqp.support.converter.MarshallingMessageConverter
-
Construct a new
MarshallingMessageConverter
with the givenMarshaller
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
-
Deprecated.in favor of
QueueBuilder.leaderLocator(LeaderLocator)
. - match() - Method in class org.springframework.amqp.core.BindingBuilder.HeadersExchangeMapConfigurer.HeadersExchangeMapBindingCreator
- matches(Object) - Method in class org.springframework.amqp.core.BindingBuilder.HeadersExchangeMapConfigurer.HeadersExchangeSingleValueBindingCreator
- matchHandlerMethod(Class<? extends Object>, InvocableHandlerMethod) - Method in class org.springframework.amqp.rabbit.listener.adapter.DelegatingInvocableHandler
- maxAttempts(int) - Method in class org.springframework.amqp.rabbit.config.RetryInterceptorBuilder
-
Apply the max attempts - a SimpleRetryPolicy will be used.
- 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[]) - Constructor for class org.springframework.amqp.core.Message
-
Construct an instance with the provided body and default
MessageProperties
. - Message(byte[], MessageProperties) - Constructor for class org.springframework.amqp.core.Message
-
Construct an instance with the provided body and properties.
- 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
- MessageBatch - Class in org.springframework.amqp.rabbit.batch
-
An object encapsulating a
Message
containing the batch of messages, the exchange, and routing key. - MessageBatch(String, String, Message) - Constructor for class org.springframework.amqp.rabbit.batch.MessageBatch
- MessageBatchRecoverer - Interface in org.springframework.amqp.rabbit.retry
-
A retry recoverer for use with a batch listener.
- messageBuilder() - Method in interface org.springframework.rabbit.stream.producer.RabbitStreamOperations
-
Return the producer's
MessageBuilder
to create native stream messages. - messageBuilder() - Method in class org.springframework.rabbit.stream.producer.RabbitStreamTemplate
- MessageBuilder - Class in org.springframework.amqp.core
-
Builds a Spring AMQP Message either from a byte[] body or another Message using a fluent API.
- MessageBuilderSupport<T> - Class in org.springframework.amqp.core
-
Support class for building
Message
andMessageProperties
fluent API. - MessageBuilderSupport() - Constructor for class org.springframework.amqp.core.MessageBuilderSupport
- MessageBuilderSupport(MessageProperties) - Constructor for class org.springframework.amqp.core.MessageBuilderSupport
- MessageConversionException - Exception in org.springframework.amqp.support.converter
-
Exception to be thrown by message converters if they encounter a problem with converting a message or object.
- MessageConversionException(String) - Constructor for exception org.springframework.amqp.support.converter.MessageConversionException
- MessageConversionException(String, Throwable) - Constructor for exception org.springframework.amqp.support.converter.MessageConversionException
- messageConverter() - Method in annotation type org.springframework.amqp.rabbit.annotation.RabbitListener
-
Override the container factory's message converter used for this listener.
- messageConverter() - Method in interface org.springframework.rabbit.stream.producer.RabbitStreamOperations
-
Return the message converter.
- messageConverter() - Method in class org.springframework.rabbit.stream.producer.RabbitStreamTemplate
- MessageConverter - Interface in org.springframework.amqp.support.converter
-
Message converter interface.
- messageCount(String) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- MessageDeliveryMode - Enum in org.springframework.amqp.core
-
Enumeration for the message delivery mode.
- messageKeyGenerator(MessageKeyGenerator) - Method in class org.springframework.amqp.rabbit.config.RetryInterceptorBuilder.StatefulRetryInterceptorBuilder
-
Stateful retry requires messages to be identifiable.
- MessageKeyGenerator - Interface in org.springframework.amqp.rabbit.retry
- MessageListener - Interface in org.springframework.amqp.core
-
Listener interface to receive asynchronous delivery of Amqp Messages.
- MessageListenerAdapter - Class in org.springframework.amqp.rabbit.listener.adapter
-
Message listener adapter that delegates the handling of messages to target listener methods via reflection, with flexible message type conversion.
- MessageListenerAdapter() - Constructor for class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter
-
Create a new
MessageListenerAdapter
with default settings. - MessageListenerAdapter(Object) - Constructor for class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter
-
Create a new
MessageListenerAdapter
for the given delegate. - MessageListenerAdapter(Object, String) - Constructor for class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter
-
Create a new
MessageListenerAdapter
for the given delegate while also declaring its POJO method. - MessageListenerAdapter(Object, MessageConverter) - Constructor for class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter
-
Create a new
MessageListenerAdapter
for the given delegate. - MessageListenerContainer - Interface in org.springframework.amqp.rabbit.listener
-
Internal abstraction used by the framework representing a message listener container.
- MessagePostProcessor - Interface in org.springframework.amqp.core
-
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.
- MessagePropertiesConverter - Interface in org.springframework.amqp.rabbit.support
-
Strategy interface for converting between Spring AMQP
MessageProperties
and RabbitMQ BasicProperties. - MessageRecoverer - Interface in org.springframework.amqp.rabbit.retry
- MessageRejectedWhileStoppingException - Exception in org.springframework.amqp.rabbit.listener.exception
-
Exception class that indicates a rejected message on shutdown.
- MessageRejectedWhileStoppingException() - Constructor for exception org.springframework.amqp.rabbit.listener.exception.MessageRejectedWhileStoppingException
- MessagingMessageConverter - Class in org.springframework.amqp.support.converter
-
Convert a
Message
from the messaging abstraction to and from aMessage
using an underlyingMessageConverter
for the payload and aAmqpHeaderMapper
to map the AMQP headers to and from standard message headers. - MessagingMessageConverter() - Constructor for class org.springframework.amqp.support.converter.MessagingMessageConverter
-
Create an instance with a default payload converter for an inbound handler.
- MessagingMessageConverter(MessageConverter, AmqpHeaderMapper) - Constructor for class org.springframework.amqp.support.converter.MessagingMessageConverter
-
Create an instance with the specified payload converter and header mapper.
- MessagingMessageListenerAdapter - Class in org.springframework.amqp.rabbit.listener.adapter
-
A
MessageListener
adapter that invokes a configurableHandlerAdapter
. - MessagingMessageListenerAdapter() - Constructor for class org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter
- MessagingMessageListenerAdapter(Object, Method) - Constructor for class org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter
- MessagingMessageListenerAdapter(Object, Method, boolean, RabbitListenerErrorHandler) - Constructor for class org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter
- MessagingMessageListenerAdapter(Object, Method, boolean, RabbitListenerErrorHandler, boolean) - Constructor for class org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter
- MessagingMessageListenerAdapter.MessagingMessageConverterAdapter - Class in org.springframework.amqp.rabbit.listener.adapter
-
Delegates payload extraction to
AbstractAdaptableMessageListener.extractMessage(org.springframework.amqp.core.Message message)
to enforce backward compatibility. - METHOD_ATTRIBUTE - Static variable in class org.springframework.amqp.rabbit.config.NamespaceUtils
- MethodRabbitListenerEndpoint - Class in org.springframework.amqp.rabbit.listener
-
A
RabbitListenerEndpoint
providing the method to invoke to process an incoming message for this endpoint. - MethodRabbitListenerEndpoint() - Constructor for class org.springframework.amqp.rabbit.listener.MethodRabbitListenerEndpoint
- MethodRabbitListenerEndpoint.AdapterProvider - Interface in org.springframework.amqp.rabbit.listener
-
Provider of listener adapters.
- minLeaders - org.springframework.amqp.core.QueueBuilder.LeaderLocator
-
Deploy on the node with the fewest queue leaders.
- minMasters - org.springframework.amqp.core.QueueBuilder.MasterLocator
-
Deprecated.Deploy on the node with the fewest masters.
- MissingQueueEvent - Class in org.springframework.amqp.rabbit.listener
-
Event published when a missing queue is detected.
- MissingQueueEvent(Object, String) - Constructor for class org.springframework.amqp.rabbit.listener.MissingQueueEvent
-
Construct an instance with the provided source and queue.
- MULTI_RABBIT_ADMIN_SUFFIX - Static variable in class org.springframework.amqp.rabbit.config.RabbitListenerConfigUtils
-
The MultiRabbit admins' suffix.
- MULTI_RABBIT_CONTAINER_FACTORY_BEAN_NAME - Static variable in class org.springframework.amqp.rabbit.config.RabbitListenerConfigUtils
-
The bean name of the ContainerFactory of the default broker for MultiRabbit.
- MULTI_RABBIT_ENABLED_PROPERTY - Static variable in class org.springframework.amqp.rabbit.config.RabbitListenerConfigUtils
-
The default property to enable/disable MultiRabbit processing.
- MultiMethodRabbitListenerEndpoint - Class in org.springframework.amqp.rabbit.listener
- MultiMethodRabbitListenerEndpoint(List<Method>, Object) - Constructor for class org.springframework.amqp.rabbit.listener.MultiMethodRabbitListenerEndpoint
-
Deprecated.- no longer used.
- MultiMethodRabbitListenerEndpoint(List<Method>, Method, Object) - Constructor for class org.springframework.amqp.rabbit.listener.MultiMethodRabbitListenerEndpoint
-
Construct an instance for the provided methods, default method and bean.
- MultiRabbitBootstrapConfiguration - Class in org.springframework.amqp.rabbit.annotation
-
An
ImportBeanDefinitionRegistrar
class that registers aMultiRabbitListenerAnnotationBeanPostProcessor
bean, if MultiRabbit is enabled. - MultiRabbitBootstrapConfiguration() - Constructor for class org.springframework.amqp.rabbit.annotation.MultiRabbitBootstrapConfiguration
- MultiRabbitListenerAnnotationBeanPostProcessor - Class in org.springframework.amqp.rabbit.annotation
-
An extension of
RabbitListenerAnnotationBeanPostProcessor
that indicates the proper RabbitAdmin bean to be used when processing to the listeners, and also associates it to the declarables (Exchanges, Queues, and Bindings) returned. - MultiRabbitListenerAnnotationBeanPostProcessor() - Constructor for class org.springframework.amqp.rabbit.annotation.MultiRabbitListenerAnnotationBeanPostProcessor
N
- name - Variable in class org.springframework.amqp.core.BindingBuilder.DestinationConfigurer
- name() - Method in annotation type org.springframework.amqp.rabbit.annotation.Argument
-
Return the argument name.
- name() - Method in annotation type org.springframework.amqp.rabbit.annotation.Exchange
- name() - Method in annotation type org.springframework.amqp.rabbit.annotation.Queue
- NamespaceUtils - Class in org.springframework.amqp.rabbit.config
-
Shared utility methods for namespace parsers.
- NamespaceUtils() - Constructor for class org.springframework.amqp.rabbit.config.NamespaceUtils
- NamingStrategy - Interface in org.springframework.amqp.core
-
A strategy to generate names.
- newBuilder() - Static method in class org.springframework.amqp.rabbit.log4j2.AmqpAppender
-
Create a new builder.
- newInstance() - Static method in class org.springframework.amqp.core.MessagePropertiesBuilder
-
Returns a builder with an initial set of properties.
- newMessageIdentifier(NewMessageIdentifier) - Method in class org.springframework.amqp.rabbit.config.RetryInterceptorBuilder.StatefulRetryInterceptorBuilder
-
Apply a custom new message identifier.
- NewMessageIdentifier - Interface in org.springframework.amqp.rabbit.retry
-
An optimization for stateful retry of message processing.
- nextMessage() - Method in class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer
-
Main application-side API: wait for the next message delivery and return it.
- nextMessage(long) - Method in class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer
-
Main application-side API: wait for the next message delivery and return it.
- nextRelease() - Method in interface org.springframework.amqp.rabbit.batch.BatchingStrategy
- nextRelease() - Method in class org.springframework.amqp.rabbit.batch.SimpleBatchingStrategy
- noargs() - Method in class org.springframework.amqp.core.BindingBuilder.GenericArgumentsConfigurer
- noBeanFoundMessage(Object, String, String, Class<?>) - Method in class org.springframework.amqp.rabbit.annotation.RabbitListenerAnnotationBeanPostProcessor
- NON_PERSISTENT - org.springframework.amqp.core.MessageDeliveryMode
-
Non persistent.
- nonDurable() - Static method in class org.springframework.amqp.core.QueueBuilder
-
Creates a builder for a non-durable (transient) queue.
- nonDurable(String) - Static method in class org.springframework.amqp.core.QueueBuilder
-
Creates a builder for a non-durable (transient) queue.
- NONE - org.springframework.amqp.core.AcknowledgeMode
-
No acks -
autoAck=true
inChannel.basicConsume()
. - NONE - org.springframework.amqp.rabbit.connection.AbstractConnectionFactory.AddressShuffleMode
-
Do not shuffle the addresses before or after opening a connection; attempt connections in a fixed order.
- NONE - org.springframework.amqp.rabbit.connection.CachingConnectionFactory.ConfirmType
-
Publisher confirms are disabled (default).
- notifyListeners() - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- nullSafeExchange(String) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
-
Return the exchange or the default exchange if null.
- nullSafeRoutingKey(String) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
-
Return the routing key or the default routing key if null.
O
- objectMapper - Variable in class org.springframework.amqp.support.converter.AbstractJackson2MessageConverter
- obtainNewConnectionName(ConnectionFactory) - Method in interface org.springframework.amqp.rabbit.connection.ConnectionNameStrategy
- obtainNewConnectionName(ConnectionFactory) - Method in class org.springframework.amqp.rabbit.connection.SimplePropertyValueConnectionNameStrategy
- onApplicationEvent(ContextClosedEvent) - Method in class org.springframework.amqp.rabbit.connection.AbstractConnectionFactory
- onApplicationEvent(ContextRefreshedEvent) - Method in class org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistry
- onApplicationEvent(ContextRefreshedEvent) - Method in class org.springframework.amqp.rabbit.test.TestRabbitTemplate
- onClose(Connection) - Method in class org.springframework.amqp.rabbit.connection.CompositeConnectionListener
- onClose(Connection) - Method in interface org.springframework.amqp.rabbit.connection.ConnectionListener
-
Called when a connection is closed.
- onClose(Connection) - Method in class org.springframework.amqp.rabbit.core.DeclareExchangeConnectionListener
- onCreate(Channel, boolean) - Method in interface org.springframework.amqp.rabbit.connection.ChannelListener
-
Called when a new channel is created.
- onCreate(Channel, boolean) - Method in class org.springframework.amqp.rabbit.connection.CompositeChannelListener
- onCreate(Channel, boolean) - Method in interface org.springframework.amqp.rabbit.connection.ShutDownChannelListener
- onCreate(Connection) - Method in class org.springframework.amqp.rabbit.connection.CompositeConnectionListener
- onCreate(Connection) - Method in interface org.springframework.amqp.rabbit.connection.ConnectionListener
-
Called when a new connection is established.
- onCreate(Connection) - Method in class org.springframework.amqp.rabbit.core.BrokerEventListener
- onCreate(Connection) - Method in class org.springframework.amqp.rabbit.core.DeclareExchangeConnectionListener
- onFailed(Exception) - Method in class org.springframework.amqp.rabbit.connection.CompositeConnectionListener
- onFailed(Exception) - Method in interface org.springframework.amqp.rabbit.connection.ConnectionListener
-
Called when a connection couldn't be established.
- onMessage(Message) - Method in interface org.springframework.amqp.core.BatchMessageListener
- onMessage(Message) - Method in interface org.springframework.amqp.core.MessageListener
-
Delivers a single message.
- onMessage(Message) - Method in class org.springframework.amqp.rabbit.core.BrokerEventListener
- onMessage(Message) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
-
Deprecated.
- onMessage(Message) - Method in interface org.springframework.amqp.rabbit.listener.api.ChannelAwareMessageListener
- onMessage(Message) - Method in class org.springframework.amqp.remoting.service.AmqpInvokerServiceExporter
-
Deprecated.
- onMessage(Message, Channel) - Method in class org.springframework.amqp.rabbit.AsyncRabbitTemplate
- onMessage(Message, Channel) - Method in class org.springframework.amqp.rabbit.core.RabbitTemplate
- onMessage(Message, Channel) - Method in class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter
-
Spring
ChannelAwareMessageListener
entry point. - onMessage(Message, Channel) - Method in class org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter
- onMessage(Message, Channel) - Method in interface org.springframework.amqp.rabbit.listener.api.ChannelAwareBatchMessageListener
- onMessage(Message, Channel) - Method in interface org.springframework.amqp.rabbit.listener.api.ChannelAwareMessageListener
-
Callback for processing a received Rabbit message.
- onMessageBatch(List<Message>) - Method in interface org.springframework.amqp.core.BatchMessageListener
- onMessageBatch(List<Message>) - Method in interface org.springframework.amqp.core.MessageListener
-
Delivers a batch of messages.
- onMessageBatch(List<Message>, Channel) - Method in class org.springframework.amqp.rabbit.listener.adapter.BatchMessagingMessageListenerAdapter
- onMessageBatch(List<Message>, Channel) - Method in interface org.springframework.amqp.rabbit.listener.api.ChannelAwareBatchMessageListener
- onMessageBatch(List<Message>, Channel) - Method in interface org.springframework.amqp.rabbit.listener.api.ChannelAwareMessageListener
- onShutDown(ShutdownSignalException) - Method in interface org.springframework.amqp.rabbit.connection.ChannelListener
-
Called when the underlying RabbitMQ channel is closed for any reason.
- onShutDown(ShutdownSignalException) - Method in class org.springframework.amqp.rabbit.connection.CompositeChannelListener
- onShutDown(ShutdownSignalException) - Method in class org.springframework.amqp.rabbit.connection.CompositeConnectionListener
- onShutDown(ShutdownSignalException) - Method in interface org.springframework.amqp.rabbit.connection.ConnectionListener
-
Called when a connection is force closed.
- onShutDown(ShutdownSignalException) - Method in interface org.springframework.amqp.rabbit.connection.ShutDownChannelListener
- onStreamMessage(Message, MessageHandler.Context) - Method in class org.springframework.rabbit.stream.listener.adapter.StreamMessageListenerAdapter
- onStreamMessage(Message, MessageHandler.Context) - Method in interface org.springframework.rabbit.stream.listener.StreamMessageListener
-
Process a message.
- ORDER - Static variable in class org.springframework.amqp.rabbit.config.NamespaceUtils
- org.springframework.amqp - package org.springframework.amqp
-
Base package for Spring AMQP.
- org.springframework.amqp.core - package org.springframework.amqp.core
-
Provides core classes for the spring AMQP abstraction.
- org.springframework.amqp.event - package org.springframework.amqp.event
-
Classes related to application events
- org.springframework.amqp.rabbit - package org.springframework.amqp.rabbit
-
Provides top-level classes for Spring Rabbit.
- org.springframework.amqp.rabbit.annotation - package org.springframework.amqp.rabbit.annotation
-
Annotations and supporting classes for declarative Rabbit listener endpoint
- org.springframework.amqp.rabbit.batch - package org.springframework.amqp.rabbit.batch
-
Provides classes for message batching.
- org.springframework.amqp.rabbit.config - package org.springframework.amqp.rabbit.config
-
Provides classes supporting the Rabbit XML namespace.
- org.springframework.amqp.rabbit.connection - package org.springframework.amqp.rabbit.connection
-
Provides classes related to connections.
- org.springframework.amqp.rabbit.core - package org.springframework.amqp.rabbit.core
-
Provides core classes for Spring Rabbit.
- org.springframework.amqp.rabbit.junit - package org.springframework.amqp.rabbit.junit
-
Provides support classes (Rules etc.
- org.springframework.amqp.rabbit.listener - package org.springframework.amqp.rabbit.listener
-
Provides classes for message listener containers.
- org.springframework.amqp.rabbit.listener.adapter - package org.springframework.amqp.rabbit.listener.adapter
-
Provides classes for adapting listeners.
- org.springframework.amqp.rabbit.listener.api - package org.springframework.amqp.rabbit.listener.api
-
Provides Additional APIs for listeners.
- org.springframework.amqp.rabbit.listener.exception - package org.springframework.amqp.rabbit.listener.exception
-
Provides classes for listener exceptions.
- org.springframework.amqp.rabbit.listener.support - package org.springframework.amqp.rabbit.listener.support
-
Provides support classes for listeners.
- org.springframework.amqp.rabbit.log4j2 - package org.springframework.amqp.rabbit.log4j2
-
Provides classes supporting Log4j 2 appenders.
- org.springframework.amqp.rabbit.logback - package org.springframework.amqp.rabbit.logback
-
Provides classes supporting Logback appenders.
- org.springframework.amqp.rabbit.retry - package org.springframework.amqp.rabbit.retry
-
Provides classes supporting retries.
- org.springframework.amqp.rabbit.support - package org.springframework.amqp.rabbit.support
-
Provides support classes for Spring Rabbit.
- org.springframework.amqp.rabbit.test - package org.springframework.amqp.rabbit.test
-
Classes for testing Spring AMQP applications.
- org.springframework.amqp.rabbit.test.context - package org.springframework.amqp.rabbit.test.context
-
Provides classes relating to the test application context.
- org.springframework.amqp.rabbit.test.mockito - package org.springframework.amqp.rabbit.test.mockito
-
Mockito extensions for testing Spring AMQP applications.
- org.springframework.amqp.rabbit.transaction - package org.springframework.amqp.rabbit.transaction
-
Provides classes supporting transactions in Spring Rabbit.
- org.springframework.amqp.remoting.client - package org.springframework.amqp.remoting.client
-
Provides classes for the client side of Spring Remoting over AMQP.
- org.springframework.amqp.remoting.service - package org.springframework.amqp.remoting.service
-
Provides classes for the service side of Spring Remoting over AMQP.
- org.springframework.amqp.support - package org.springframework.amqp.support
-
Package for Spring AMQP support classes.
- org.springframework.amqp.support.converter - package org.springframework.amqp.support.converter
-
Provides classes for supporting message conversion.
- org.springframework.amqp.support.postprocessor - package org.springframework.amqp.support.postprocessor
-
Package for Spring AMQP message post processors.
- org.springframework.amqp.utils - package org.springframework.amqp.utils
-
Provides utility classes to support Spring AMQP.
- org.springframework.amqp.utils.test - package org.springframework.amqp.utils.test
- org.springframework.rabbit.stream.config - package org.springframework.rabbit.stream.config
-
Provides classes for stream listener configuration.
- org.springframework.rabbit.stream.listener - package org.springframework.rabbit.stream.listener
-
Provides classes for stream listeners.
- org.springframework.rabbit.stream.listener.adapter - package org.springframework.rabbit.stream.listener.adapter
-
Provides classes for stream listener adapters.
- org.springframework.rabbit.stream.producer - package org.springframework.rabbit.stream.producer
-
Provides classes for stream producers.
- org.springframework.rabbit.stream.support - package org.springframework.rabbit.stream.support
-
Provides support classes.
- org.springframework.rabbit.stream.support.converter - package org.springframework.rabbit.stream.support.converter
-
Provides classes for message conversion.
- ORIGINAL_DEFAULT_LISTENER_METHOD - Static variable in class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter
-
Out-of-the-box value for the default listener method: "handleMessage".
- overflow(QueueBuilder.Overflow) - Method in class org.springframework.amqp.core.QueueBuilder
-
Set the overflow mode when messages are dropped due to max messages or max message size is exceeded.
P
- parseBinding(String, Element, ParserContext) - Method in class org.springframework.amqp.rabbit.config.AbstractExchangeParser
- parseBinding(String, Element, ParserContext) - Method in class org.springframework.amqp.rabbit.config.DirectExchangeParser
- parseBinding(String, Element, ParserContext) - Method in class org.springframework.amqp.rabbit.config.FanoutExchangeParser
- parseBinding(String, Element, ParserContext) - Method in class org.springframework.amqp.rabbit.config.HeadersExchangeParser
- parseBinding(String, Element, ParserContext) - Method in class org.springframework.amqp.rabbit.config.TopicExchangeParser
- parseBindings(Element, ParserContext, BeanDefinitionBuilder, String) - Method in class org.springframework.amqp.rabbit.config.AbstractExchangeParser
- parseBooleanProperty(String) - Static method in class org.springframework.amqp.rabbit.junit.JUnitUtils
-
Return the parsed value if the provided property exists in the environment or system properties.
- parseContainer(Element, ParserContext) - Static method in class org.springframework.amqp.rabbit.config.RabbitNamespaceUtils
- parseDeclarationControls(Element, BeanDefinitionBuilder) - Static method in class org.springframework.amqp.rabbit.config.NamespaceUtils
-
Parses 'auto-declare' and 'declared-by' attributes.
- parseDestination(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.amqp.rabbit.config.AbstractExchangeParser
- password() - Method in annotation type org.springframework.amqp.rabbit.test.context.SpringRabbitTest
-
Set the password when not using
RabbitAvailable
. - PendingConfirm - Class in org.springframework.amqp.rabbit.connection
-
Instances of this object track pending publisher confirms.
- PendingConfirm(CorrelationData, long) - Constructor for class org.springframework.amqp.rabbit.connection.PendingConfirm
- PERSISTENT - org.springframework.amqp.core.MessageDeliveryMode
-
Persistent.
- PooledChannelConnectionFactory - Class in org.springframework.amqp.rabbit.connection
-
A very simple connection factory that caches channels using Apache Pool2
GenericObjectPool
s (one for transactional and one for non-transactional channels). - PooledChannelConnectionFactory(ConnectionFactory) - Constructor for class org.springframework.amqp.rabbit.connection.PooledChannelConnectionFactory
-
Construct an instance.
- pop(Object) - Static method in class org.springframework.amqp.rabbit.connection.SimpleResourceHolder
-
Unbind the current value and bind the head of the stack if present.
- port() - Method in annotation type org.springframework.amqp.rabbit.test.context.SpringRabbitTest
-
Set the port when not using
RabbitAvailable
. - postProcess(Message, CorrelationData) - Method in interface org.springframework.amqp.rabbit.core.CorrelationDataPostProcessor
-
Update or replace the correlation data provided in the send method.
- postProcessAfterInitialization(Object, String) - Method in class org.springframework.amqp.rabbit.annotation.RabbitListenerAnnotationBeanPostProcessor
- postProcessBeforeInitialization(Object, String) - Method in class org.springframework.amqp.rabbit.annotation.RabbitListenerAnnotationBeanPostProcessor
- postProcessChannel(Channel, Message) - Method in class org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener
-
Post-process the given message before sending the response.
- postProcessMessage(Message) - Method in interface org.springframework.amqp.core.MessagePostProcessor
-
Change (or replace) the message.
- postProcessMessage(Message) - Method in class org.springframework.amqp.support.postprocessor.AbstractCompressingPostProcessor
- postProcessMessage(Message) - Method in class org.springframework.amqp.support.postprocessor.AbstractDecompressingPostProcessor