All Classes and Interfaces

Class
Description
The base AbstractMessageChannel implementation for AMQP.
A base AbstractReplyProducingMessageHandler extension for AMQP message handlers.
 
AbstractMessageListenerContainerSpec<S extends AbstractMessageListenerContainerSpec<S,C>,C extends org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer>
Base class for container specs.
Factory class for AMQP components.
 
The base MessageProducerSpec implementation for a AmqpInboundChannelAdapter.
A base MessagingGatewaySpec implementation for AmqpInboundGateway endpoint options.
The base MessageHandlerSpec for AbstractAmqpOutboundEndpoints.
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.
Parser for the 'channel' and 'publish-subscribe-channel' elements of the Spring Integration AMQP namespace.
A convenience interface that extends RequestReplyHeaderMapper, parameterized with MessageProperties.
Adapter that receives Messages from an AMQP Queue, converts them into Spring Integration Messages, and sends the results to a Message Channel.
Defines the payload type when the listener container is configured with consumerBatchEnabled.
Spec for an inbound channel adapter with a DirectMessageListenerContainer.
Parser for the AMQP 'inbound-channel-adapter' element.
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.
Adapter that receives Messages from an AMQP Queue, converts them into Spring Integration Messages, and sends the results to a Message Channel.
Spec for a gateway with a DirectMessageListenerContainer.
Parser for the AMQP 'inbound-gateway' element.
Spec for a gateway with a SimpleMessageListenerContainer.
AmqpInboundGatewaySpec<S extends AmqpInboundGatewaySpec<S,C>,C extends org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer>
Spec for a polled AMQP inbound channel adapter.
An ErrorMessageStrategy extension that adds the raw AMQP message as a header to the ErrorMessage.
A pollable MessageSource for RabbitMQ.
 
 
Information for building an AmqpAckCallback.
Namespace handler for the AMQP schema.
Parser for the AMQP 'outbound-channel-adapter' element.
Spec for an outbound AMQP channel adapter.
Adapter that converts and sends Messages to an AMQP Exchange.
Base spec for outbound AMQP endpoints.
Parser for the AMQP 'outbound-channel-adapter' element.
Spec for an outbound AMQP gateway.
A MessageChannelSpec for a AbstractAmqpChannels.
An outbound gateway where the sending thread is released immediately and the reply is sent on the async template's listener container thread.
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.
Default implementation of AmqpHeaderMapper.
Spec for a DirectMessageListenerContainer.
Utility methods for messaging endpoints.
A ListenerExecutionFailedException enhanced with the channel and delivery tag.
Utility methods used during message mapping.
An exception representing a negatively acknowledged message from a publisher confirm.
The AbstractSubscribableAmqpChannel implementation for one-to-one subscription over AMQP queue.
A PollableChannel implementation that is backed by an AMQP Queue.
The AbstractSubscribableAmqpChannel extension for pub-sub semantics based on the FanoutExchange.
A MessagingException for a returned message.
Spec for a SimpleMessageListenerContainer.