Class RabbitAmqpMessageListenerAdapter

java.lang.Object

org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener

org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter

org.springframework.amqp.rabbitmq.client.listener.RabbitAmqpMessageListenerAdapter

All Implemented Interfaces:

MessageListener, ChannelAwareMessageListener, RabbitAmqpMessageListener

public class RabbitAmqpMessageListenerAdapter
extends MessagingMessageListenerAdapter
implements RabbitAmqpMessageListener

A MessagingMessageListenerAdapter extension for the RabbitAmqpMessageListener. Provides these arguments for the MessagingMessageListenerAdapter.getHandlerAdapter() invocation:

• Message - the native AMQP 1.0 message without any conversions
• Message - Spring AMQP message abstraction as conversion result from the native AMQP 1.0 message
• Message - Spring Messaging abstraction as conversion result from the Spring AMQP message
• Consumer.Context - RabbitMQ AMQP client consumer settlement API.
• AmqpAcknowledgment - Spring AMQP acknowledgment abstraction: delegates to the Consumer.Context

This class reuses the MessagingMessageListenerAdapter as much as possible just to avoid duplication. The Channel abstraction from AMQP Client 0.9.1 is out use and present here just for API compatibility and to follow DRY principle. Can be reworked eventually, when this AMQP 1.0 client won't be based on spring-rabbit dependency.

Since:

4.0

Author:

Artem Bilan

Nested Class Summary

Nested classes/interfaces inherited from class org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter

MessagingMessageListenerAdapter.MessagingMessageConverterAdapter

Nested classes/interfaces inherited from class org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener

AbstractAdaptableMessageListener.ReplyExpressionRoot

Field Summary

Fields inherited from class org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter

errorHandler, messagingMessageConverter, returnExceptions

Fields inherited from class org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener

logger

Constructor Summary

Constructors

Constructor	Description
RabbitAmqpMessageListenerAdapter(@Nullable Object bean, @Nullable Method method, boolean returnExceptions, @Nullable RabbitListenerErrorHandler errorHandler, boolean batch)

Method Summary

Modifier and Type	Method	Description
protected void	asyncFailure(Message request, @Nullable com.rabbitmq.client.Channel channel, Throwable t, @Nullable Object source)
protected void	basicAck(Message request, @Nullable com.rabbitmq.client.Channel channel)
void	onAmqpMessage(com.rabbitmq.client.amqp.Message amqpMessage, @Nullable com.rabbitmq.client.amqp.Consumer.Context context)	Process an AMQP message.
void	onMessageBatch(List<Message> messages)	Delivers a batch of messages.
protected void	sendResponse(@Nullable com.rabbitmq.client.Channel channel, Address replyTo, Message messageIn)	Send the given response message to the given destination.
void	setAfterReceivePostProcessors(Collection<MessagePostProcessor> afterReceivePostProcessors)
void	setConnectionFactory(AmqpConnectionFactory connectionFactory)	Set a AmqpConnectionFactory for publishing replies from this adapter.

Methods inherited from class org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter

buildMessage, getHandlerAdapter, getMessagingMessageConverter, handleException, invokeHandler, invokeHandlerAndProcessResult, isAsyncReplies, onMessage, setHandlerAdapter, setHeaderMapper, setMessageConverter, toMessagingMessage

Methods inherited from class org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener

containerAckMode, convert, doHandleResult, doPublish, extractMessage, getBeforeSendReplyPostProcessors, getEncoding, getMessageConverter, getReceivedExchange, getReplyContentType, getReplyToAddress, handleListenerException, handleResult, handleResult, isConverterWinsContentType, isDefaultRequeueRejected, isManualAck, postProcessChannel, postProcessResponse, setBeanResolver, setBeforeSendReplyPostProcessors, setConverterWinsContentType, setDefaultRequeueRejected, setEncoding, setMandatoryPublish, setRecoveryCallback, setReplyContentType, setReplyPostProcessor, setResponseAddress, setResponseExchange, setResponseRoutingKey, setRetryTemplate

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.springframework.amqp.rabbit.listener.api.ChannelAwareMessageListener

onMessage, onMessageBatch

Methods inherited from interface org.springframework.amqp.core.MessageListener

containerAckMode, isAsyncReplies

Constructor Details

RabbitAmqpMessageListenerAdapter

public RabbitAmqpMessageListenerAdapter(@Nullable Object bean,
 @Nullable Method method,
 boolean returnExceptions,
 @Nullable RabbitListenerErrorHandler errorHandler,
 boolean batch)

Method Details

setAfterReceivePostProcessors

public void setAfterReceivePostProcessors(Collection<MessagePostProcessor> afterReceivePostProcessors)

setConnectionFactory

public void setConnectionFactory(AmqpConnectionFactory connectionFactory)

Set a AmqpConnectionFactory for publishing replies from this adapter.

Parameters:

connectionFactory - the AmqpConnectionFactory for replies.

onAmqpMessage

public void onAmqpMessage(com.rabbitmq.client.amqp.Message amqpMessage,
 @Nullable com.rabbitmq.client.amqp.Consumer.Context context)

Description copied from interface: RabbitAmqpMessageListener

Process an AMQP message.

Specified by:

onAmqpMessage in interface RabbitAmqpMessageListener

Parameters:

amqpMessage - the message to process.

context - the consumer context to settle message. Null if container is configured for autoSettle.

asyncFailure

protected void asyncFailure(Message request,
 @Nullable com.rabbitmq.client.Channel channel,
 Throwable t,
 @Nullable Object source)

Overrides:

asyncFailure in class MessagingMessageListenerAdapter

sendResponse

protected void sendResponse(@Nullable com.rabbitmq.client.Channel channel,
 Address replyTo,
 Message messageIn)

Description copied from class: AbstractAdaptableMessageListener

Send the given response message to the given destination.

Overrides:

sendResponse in class AbstractAdaptableMessageListener

Parameters:

channel - the Rabbit channel to operate on

replyTo - the Rabbit ReplyTo string to use when sending. Currently interpreted to be the routing key.

messageIn - the Rabbit message to send

See Also:

• AbstractAdaptableMessageListener.postProcessResponse(Message, Message)
• AbstractAdaptableMessageListener.setReplyPostProcessor(ReplyPostProcessor)

basicAck

protected void basicAck(Message request,
 @Nullable com.rabbitmq.client.Channel channel)

Overrides:

basicAck in class AbstractAdaptableMessageListener

onMessageBatch

public void onMessageBatch(List<Message> messages)

Description copied from interface: MessageListener

Delivers a batch of messages.

Specified by:

onMessageBatch in interface MessageListener

Parameters:

messages - the messages.