@NonNullApi

Package org.springframework.amqp.rabbit.listener

Provides classes for message listener containers.

Interface Summary

Interface	Description
AbstractMessageListenerContainer.JavaLangErrorHandler	A handler for Error on the container thread(s).
FatalExceptionStrategy	A strategy interface for the ConditionalRejectingErrorHandler to decide whether an exception should be considered to be fatal and the message should not be requeued.
MessageListenerContainer	Internal abstraction used by the framework representing a message listener container.
MethodRabbitListenerEndpoint.AdapterProvider	Provider of listener adapters.
RabbitListenerContainerFactory<C extends MessageListenerContainer>	Factory of MessageListenerContainers.
RabbitListenerEndpoint	Model for a Rabbit listener endpoint.

Class Summary

Class	Description
AbstractMessageListenerContainer
AbstractRabbitListenerEndpoint	Base model for a Rabbit listener endpoint.
AsyncConsumerRestartedEvent	An event that is published whenever a consumer is restarted.
AsyncConsumerStartedEvent	An event that is published whenever a new consumer is started.
AsyncConsumerStoppedEvent	An event that is published whenever a consumer is stopped (and not restarted).
BlockingQueueConsumer	Specialized consumer encapsulating knowledge of the broker connections and having its own lifecycle (start and stop).
ConditionalRejectingErrorHandler	ErrorHandler that conditionally wraps the Exception in an AmqpRejectAndDontRequeueException if the configured rejection strategy determines that the message is fatal and should not be requeued.
ConditionalRejectingErrorHandler.DefaultExceptionStrategy	Default implementation of FatalExceptionStrategy.
ConsumeOkEvent	An AmqpEvent emitted by the listener container when consumer is subscribed to the queue.
DirectMessageListenerContainer	The SimpleMessageListenerContainer is not so simple.
DirectReplyToMessageListenerContainer	Listener container for Direct ReplyTo only listens to the pseudo queue Address.AMQ_RABBITMQ_REPLY_TO.
DirectReplyToMessageListenerContainer.ChannelHolder	Holder for a channel; contains a consumer epoch used to prevent inappropriate release of the consumer after it has been allocated for reuse.
ListenerContainerConsumerFailedEvent	Published when a listener consumer fails.
ListenerContainerConsumerTerminatedEvent	Published when a listener consumer is terminated.
ListenerContainerIdleEvent	An event that is emitted when a container is idle if the container is configured to do so.
ListenerFailedRuleBasedTransactionAttribute	Subclass of RuleBasedTransactionAttribute that is aware that listener exceptions are wrapped in ListenerExecutionFailedExceptions.
MethodRabbitListenerEndpoint	A RabbitListenerEndpoint providing the method to invoke to process an incoming message for this endpoint.
MissingQueueEvent	Event published when a missing queue is detected.
MultiMethodRabbitListenerEndpoint
RabbitListenerEndpointRegistrar	Helper bean for registering RabbitListenerEndpoint with a RabbitListenerEndpointRegistry.
RabbitListenerEndpointRegistry	Creates the necessary MessageListenerContainer instances for the registered endpoints.
SimpleMessageListenerContainer

Exception Summary

Exception	Description
AbstractMessageListenerContainer.SharedConnectionNotInitializedException	Exception that indicates that the initial setup of this container's shared Rabbit Connection failed.
AbstractMessageListenerContainer.WrappedTransactionException	A runtime exception to wrap a Throwable.
QueuesNotAvailableException	This exception indicates that a consumer could not be started because none of its queues are available for listening.