CODEWITHSUNDEEP
rabbitmqspring-amqpspring-rabbit
bstick12
bstick12

Reputation: 1749

Retrieve name of RabbitMQ Queue where message was consumed from

Using a SimpleMessageListenerContainer that is attached to multiple queues and configured with a ChannelAwareMessageListener. Is it possible to determine which queue a message has been consumed from? In particular if the message was routed to the queue from an Exchange.

It looks that if a message is sent directly to a queue that the MessageProperties#getReceivedRoutingKey will contain the queue name but if the message is routed to a queue via an Exchange then this information contains the routing key that was used.

I'm looking for a mechanism that would allow this information to be extracted correctly regardless of how the message was delivered to the queue. Or a mechanism to enrich the information with a header containing this information on the RabbitMQ side.

Upvotes: 1

Views: 2462

Answers (1)

Adam Gent
Adam Gent

Reputation: 49095

I had a similar issue where I wanted to add the queue name to slf4j MDC context.

The only solution I have found is to subclass SimpleMessageListenerContainer and set a ThreadLocal variable for the queue name or in my case the MDC context (which is basically threadlocals).

Because SimpleMessageListenerContainer still doesn't know exactly which queue (you can bind multiple queues to a container) you will have to allow only single queue per container which in my opinion is what you should do regardless.

In my companies own code base we have a magical SimpleMessageListenerContainerFactory that does the creation of custom SimpleMessageListenerContainer based on routing annotations (think spring mvc @RequestMapping for amqp). If there is interest perhaps we can expedite opensourcing it.

Upvotes: 3

Related Questions