Make RPC client response queues auto-delete and exclusive

Patch by Witeman Zheng.
rabbitmq · Aug 14, 2014 · 7b05def · 7b05def
1 parent c578799
commit 7b05def
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/amqp_rpc_client.erl b/src/amqp_rpc_client.erl
@@ -88,7 +88,8 @@ call(RpcClient, Payload) ->
 %% Sets up a reply queue for this client to listen on
 setup_reply_queue(State = #state{channel = Channel}) ->
     #'queue.declare_ok'{queue = Q} =
-        amqp_channel:call(Channel, #'queue.declare'{}),
+        amqp_channel:call(Channel, #'queue.declare'{exclusive   = true,
+                                                    auto_delete = true}),
     State#state{reply_queue = Q}.
 
 %% Registers this RPC client instance as a consumer to handle rpc responses