All Classes
| Class | Description |
|---|---|
| AbstractAmqpChannel | |
| AbstractAmqpOutboundEndpoint | |
| AbstractAmqpOutboundEndpoint.CorrelationDataWrapper | |
| AbstractMessageListenerContainerSpec<S extends AbstractMessageListenerContainerSpec<S,C>,C extends org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer> |
Base class for container specs.
|
| Amqp |
Factory class for AMQP components.
|
| AmqpAsyncOutboundGatewaySpec | |
| AmqpBaseInboundChannelAdapterSpec<S extends AmqpBaseInboundChannelAdapterSpec<S>> |
The base
MessageProducerSpec implementation for a AmqpInboundChannelAdapter. |
| AmqpBaseInboundGatewaySpec<S extends AmqpBaseInboundGatewaySpec<S>> |
A base
MessagingGatewaySpec implementation for AmqpInboundGateway endpoint options. |
| AmqpBaseOutboundEndpointSpec<S extends AmqpBaseOutboundEndpointSpec<S,E>,E extends AbstractAmqpOutboundEndpoint> |
The base
MessageHandlerSpec for AbstractAmqpOutboundEndpoints. |
| AmqpChannelFactoryBean |
If point-to-point, we send to the default exchange with the routing key
equal to "[beanName]" and we declare that same Queue and register a listener
if message-driven or poll explicitly otherwise.
|
| AmqpChannelParser |
Parser for the 'channel' and 'publish-subscribe-channel' elements of the
Spring Integration AMQP namespace.
|
| AmqpHeaderMapper |
A convenience interface that extends
RequestReplyHeaderMapper,
parameterized with MessageProperties. |
| AmqpInboundChannelAdapter |
Adapter that receives Messages from an AMQP Queue, converts them into
Spring Integration Messages, and sends the results to a Message Channel.
|
| AmqpInboundChannelAdapter.BatchMode |
Defines the payload type when the listener container is configured with consumerBatchEnabled.
|
| AmqpInboundChannelAdapterDMLCSpec |
Spec for an inbound channel adapter with a
DirectMessageListenerContainer. |
| AmqpInboundChannelAdapterParser |
Parser for the AMQP 'inbound-channel-adapter' element.
|
| AmqpInboundChannelAdapterSMLCSpec |
Spec for an inbound channel adapter with a
SimpleMessageListenerContainer. |
| AmqpInboundChannelAdapterSpec<S extends AmqpInboundChannelAdapterSpec<S,C>,C extends org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer> |
A
MessageProducerSpec for
AmqpInboundChannelAdapters. |
| AmqpInboundGateway |
Adapter that receives Messages from an AMQP Queue, converts them into
Spring Integration Messages, and sends the results to a Message Channel.
|
| AmqpInboundGatewayDMLCSpec |
Spec for a gateway with a
DirectMessageListenerContainer. |
| AmqpInboundGatewayParser |
Parser for the AMQP 'inbound-gateway' element.
|
| AmqpInboundGatewaySMLCSpec |
Spec for a gateway with a
SimpleMessageListenerContainer. |
| AmqpInboundGatewaySpec<S extends AmqpInboundGatewaySpec<S,C>,C extends org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer> |
An
AmqpBaseInboundGatewaySpec implementation for a AmqpInboundGateway. |
| AmqpInboundPolledChannelAdapterSpec |
Spec for a polled AMQP inbound channel adapter.
|
| AmqpMessageChannelSpec<S extends AmqpMessageChannelSpec<S,T>,T extends AbstractAmqpChannel> |
An
AmqpPollableMessageChannelSpec for a message-driven
PointToPointSubscribableAmqpChannel. |
| AmqpMessageHeaderErrorMessageStrategy |
An
ErrorMessageStrategy extension that adds the raw AMQP message as
a header to the ErrorMessage. |
| AmqpMessageSource |
A pollable
MessageSource for RabbitMQ. |
| AmqpMessageSource.AmqpAckCallback | |
| AmqpMessageSource.AmqpAckCallbackFactory | |
| AmqpMessageSource.AmqpAckInfo |
Information for building an AmqpAckCallback.
|
| AmqpNamespaceHandler |
Namespace handler for the AMQP schema.
|
| AmqpOutboundChannelAdapterParser |
Parser for the AMQP 'outbound-channel-adapter' element.
|
| AmqpOutboundChannelAdapterSpec |
Spec for an outbound AMQP channel adapter
|
| AmqpOutboundEndpoint |
Adapter that converts and sends Messages to an AMQP Exchange.
|
| AmqpOutboundEndpointSpec<S extends AmqpOutboundEndpointSpec<S>> |
Base spec for outbound AMQP endpoints.
|
| AmqpOutboundGatewayParser |
Parser for the AMQP 'outbound-channel-adapter' element.
|
| AmqpOutboundGatewaySpec |
Spec for an outbound AMQP gateway.
|
| AmqpPollableMessageChannelSpec<S extends AmqpPollableMessageChannelSpec<S,T>,T extends AbstractAmqpChannel> |
A
MessageChannelSpec for a AbstractAmqpChannels. |
| AmqpPublishSubscribeMessageChannelSpec | |
| AsyncAmqpOutboundGateway |
An outbound gateway where the sending thread is released immediately and the reply
is sent on the async template's listener container thread.
|
| BoundRabbitChannelAdvice |
An advice that causes all downstream
RabbitOperations operations to be executed
on the same channel, as long as there are no thread handoffs, since the channel is
bound to the thread. |
| DefaultAmqpHeaderMapper |
Default implementation of
AmqpHeaderMapper. |
| DirectMessageListenerContainerSpec |
Spec for a
DirectMessageListenerContainer. |
| EndpointUtils |
Utility methods for messaging endpoints.
|
| ManualAckListenerExecutionFailedException |
A
ListenerExecutionFailedException enhanced with the channel and delivery tag. |
| MappingUtils |
Utility methods used during message mapping.
|
| NackedAmqpMessageException |
An exception representing a negatively acknowledged message from a
publisher confirm.
|
| PointToPointSubscribableAmqpChannel | |
| PollableAmqpChannel |
A
PollableChannel implementation that is backed by an AMQP Queue. |
| PublishSubscribeAmqpChannel |
The
AbstractSubscribableAmqpChannel extension for pub-sub semantics based on the FanoutExchange. |
| ReturnedAmqpMessageException |
A MessagingException for a returned message.
|
| SimpleMessageListenerContainerSpec |
Spec for a
SimpleMessageListenerContainer. |