Index
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form
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 Interface in org.springframework.amqp.rabbit.annotation
-
Enable Rabbit listener annotated endpoints that are created under the cover by a
RabbitListenerContainerFactory
. - enhancedObjectMapper() - Static method in class org.springframework.amqp.support.converter.JacksonUtils
-
Factory for
ObjectMapper
instances with registered well-known modules and disabledMapperFeature.DEFAULT_VIEW_INCLUSION
andDeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES
features. - 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.amqp.rabbit.listener.DirectMessageListenerContainer.SimpleConsumer
- equals(Object) - Method in class org.springframework.rabbit.stream.support.StreamMessageProperties
- errorExchangeNameExpression - Variable in class org.springframework.amqp.rabbit.retry.RepublishMessageRecoverer
- errorHandler() - Element in annotation interface org.springframework.amqp.rabbit.annotation.RabbitListener
-
Set an
RabbitListenerErrorHandler
to invoke if the listener method throws an exception. - errorRoutingKeyExpression - 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
- evaluationContext - Variable in class org.springframework.amqp.rabbit.retry.RepublishMessageRecoverer
- 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.DirectExchangeRoutingKeyConfigurer
- exchange - Variable in class org.springframework.amqp.core.BindingBuilder.HeadersExchangeMapConfigurer
- exchange() - Element in annotation interface org.springframework.amqp.rabbit.annotation.QueueBinding
- Exchange - Interface in org.springframework.amqp.core
-
Interface for all exchanges.
- Exchange - Annotation Interface in org.springframework.amqp.rabbit.annotation
-
An exchange to which to bind a
RabbitListener
queue. - EXCHANGE - Enum constant in enum class 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() - Element in annotation interface org.springframework.amqp.rabbit.annotation.Queue
-
Specifies if this queue should be exclusive.
- exclusive() - Element in annotation interface 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. - exclusiveAccesssRefused(Exception) - Static method in class org.springframework.amqp.rabbit.connection.RabbitUtils
-
Determine whether the exception is due to an access refused for an exclusive consumer.
- 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).
- executeListenerAndHandleException(Channel, Object) - Method in class org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer
- executor() - Element in annotation interface 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
.
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form