Package org.springframework.amqp.rabbit.listener
@NullMarked
package org.springframework.amqp.rabbit.listener
Provides classes for message listener containers.
-
ClassDescriptionDefault implementation of
ConditionalExceptionLoggerfor logging exclusive consumer failures.A handler forErroron the container thread(s).Exception that indicates that the initial setup of this container's shared Rabbit Connection failed.A runtime exception to wrap aThrowable.Base model for a Rabbit listener endpoint.An event that is published whenever a consumer is restarted.An event that is published whenever a new consumer is started.An event that is published whenever a consumer is stopped (and not restarted).Specialized consumer encapsulating knowledge of the broker connections and having its own lifecycle (start and stop).Deprecated, for removal: This API element is subject to removal in a future version.AnAmqpEventemitted by the listener container when consumer is subscribed to the queue.TheSimpleMessageListenerContaineris not so simple.Listener container for Direct ReplyTo only listens to the pseudo queueAddress.AMQ_RABBITMQ_REPLY_TO.Holder for a channel; contains a consumer epoch used to prevent inappropriate release of the consumer after it has been allocated for reuse.Deprecated, for removal: This API element is subject to removal in a future version.in favor ofFatalExceptionStrategyPublished when a listener consumer fails.Published when a listener consumer is terminated.An event that is emitted when a container is idle if the container is configured to do so.Subclass ofRuleBasedTransactionAttributethat is aware that listener exceptions are wrapped inListenerExecutionFailedExceptions.A listener for message ack when usingAcknowledgeMode.AUTO.Deprecated, for removal: This API element is subject to removal in a future version.since 4.1 in favor ofMessageListenerContainer.ARabbitListenerEndpointproviding the method to invoke to process an incoming message for this endpoint.Provider of listener adapters.Abstraction to avoid hard reference to Micrometer.Event published when a missing queue is detected.This exception indicates that a consumer could not be started because none of its queues are available for listening.RabbitListenerContainerFactory<C extends org.springframework.amqp.core.MessageListenerContainer>Factory ofMessageListenerContainers.Model for a Rabbit listener endpoint.Helper bean for registeringRabbitListenerEndpointwith aRabbitListenerEndpointRegistry.Creates the necessaryMessageListenerContainerinstances for the registered endpoints.
ConditionalRejectingErrorHandler