Package org.springframework.amqp.rabbit.listener
@NonNullApi
package org.springframework.amqp.rabbit.listener
Provides classes for message listener containers.
-
ClassDescriptionA handler for
Erroron 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).ErrorHandlerthat conditionally wraps the Exception in anAmqpRejectAndDontRequeueExceptionif the configured rejection strategy determines that the message is fatal and should not be requeued.Default implementation ofFatalExceptionStrategy.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.A strategy interface for theConditionalRejectingErrorHandlerto decide whether an exception should be considered to be fatal and the message should not be requeued.Published 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.Internal abstraction used by the framework representing a message listener container.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.Factory ofMessageListenerContainers.Model for a Rabbit listener endpoint.Helper bean for registeringRabbitListenerEndpointwith aRabbitListenerEndpointRegistry.Creates the necessaryMessageListenerContainerinstances for the registered endpoints.