Direct reply-to is a feature that allows RPC (request/reply) clients with a design similar to that demonstrated in tutorial 6 to avoid declaring a response queue per request.
RPC (request/reply) is a popular pattern to implement with a messaging broker
like RabbitMQ. Tutorial 6 demonstrates its implementation
with a variety of clients. The typical way to do this is for RPC clients to
send requests that are routed to a long lived (known) server queue. The RPC server(s)
consume requests from this queue and then send replies to each client
using the queue named by the client in the
Where does the client’s queue come from? The client can declare a single-use queue for each request-response pair. But this is inefficient; even a transient unmirrored queue can be expensive to create and then delete (compared with the cost of sending a message). This is especially true in a cluster as all cluster nodes need to agree that the queue has been created, even if it is unmirrored.
So alternatively the client can create a long-lived queue for its replies. But this can be fiddly to manage, especially if the client itself is not long-lived.
The direct reply-to feature allows RPC clients to receive replies directly from their RPC server, without going through a reply queue. “Directly” here still means going through the same connection and a RabbitMQ node; there is no direct network connection between RPC client and RPC server processes.
To use direct reply-to, an RPC client should:
Consume from the pseudo-queue
amq.rabbitmq.reply-toin no-ack mode. There is no need to declare this “queue” first, although the client can do so if it wants.
reply-toproperty in their request message to
The RPC server will then see a
with a generated name. It should publish to the default exchange
"") with the routing key set to this value (i.e. just as if
it were sending to a reply queue as usual). The message will
then be sent straight to the client consumer.
If the RPC server is going to perform some expensive computation
it might wish to check if the client has gone away. To do this
the server can declare the generated reply name first on a
disposable channel in order to determine whether it still
exists. Note that even if you declare the “queue” with
passive=false there is no way to create it; the
declare will just succeed (with 0 messages ready and 1 consumer)
- The RPC client must consume in the automatic acknowledgement mode. This is because there is no queue for the reply message to be returned to if the client disconnects or rejects the reply message.
- Reply messages sent using this mechanism are in general not fault-tolerant; they will be discarded if the client that published the original request subsequently disconnects. The assumption is that an RPC client will reconnect and submit another request in this case.
amq.rabbitmq.reply-tois used in
reply-toproperty as if it were a queue; however it is not. It cannot be deleted, and does not appear in the management plugin or
If the RPC server publishes with the mandatory flag set then
amq.rabbitmq.reply-to.*is treated as not a queue; i.e. if the server only publishes to this name then the message will be considered “not routed”; a
basic.returnwill be sent if the mandatory flag was set.