See: Description
Interface | Description |
---|---|
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.
|
RabbitListenerContainerFactory<C extends MessageListenerContainer> |
Factory of
MessageListenerContainer s. |
RabbitListenerEndpoint |
Model for a Rabbit listener endpoint.
|
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 ListenerExecutionFailedException s. |
MethodRabbitListenerEndpoint |
A
RabbitListenerEndpoint providing the method to invoke to process
an incoming message for this endpoint. |
MultiMethodRabbitListenerEndpoint | |
RabbitListenerEndpointRegistrar |
Helper bean for registering
RabbitListenerEndpoint with
a RabbitListenerEndpointRegistry . |
RabbitListenerEndpointRegistry |
Creates the necessary
MessageListenerContainer instances for the
registered endpoints. |
SimpleMessageListenerContainer |
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.
|