Reputation: 97
I found this RabbitMQ "extension" listed here: http://www.rabbitmq.com/direct-reply-to.html, I set the RabbitTemplate
's "replyQueue" with amq.rabbitmq.reply-to
I tried it with an already function RPC call, and it had functioned, but now it just times out.
Any help is appreciated!
Upvotes: 2
Views: 4524
Reputation: 174554
When using a fixed reply queue (whether user-specified or the amq.rabbitmq.reply-to
) you have to configure a <reply-listener/>
- see the Spring AMQP documentation. for the amq.rabbitmq.reply-to
you should set the reply container's acknowledge to NONE
(which is no-ack in RabbitMQ speak).
CORRECTION: The RabbitTemplate
does not currently support Direct reply-to for sendAndReceive()
operations; you can, however, specify a fixed reply queue (with a reply-listener). Or you can use rabbitTemplate.execute()
with a ChannelCallback
to consume the reply from that "queue" (and publish).
I have created a JIRA issue if you wish to track it.
1.4.1 and above now supports direct reply-to.
Upvotes: 4