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.AmqpBaseOutboundEndpointSpec<S extends AmqpBaseOutboundEndpointSpec<S,E>,E extends AbstractAmqpOutboundEndpoint>
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>
An
AmqpBaseInboundGatewaySpec implementation for a AmqpInboundGateway.Spec for a polled AMQP inbound channel adapter.
An
AmqpPollableMessageChannelSpec for a message-driven
PointToPointSubscribableAmqpChannel.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.
AmqpPollableMessageChannelSpec<S extends AmqpPollableMessageChannelSpec<S,T>,T extends AbstractAmqpChannel>
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.