1. paulj
  2. rabbitmq-bql

Commits

Paul Jones  committed 512e5eb

We don't want to have to ack responses

  • Participants
  • Parent commits ad16c03
  • Branches bug22237

Comments (0)

Files changed (1)

File src/bql_amqp_rpc_client.erl

View file
  • Ignore whitespace
 %% Registers this RPC client instance as a consumer to handle rpc responses
 setup_consumer(#rpc_c_state{channel = Channel,
                             reply_queue = Q}) ->
-    amqp_channel:call(Channel, #'basic.consume'{queue = Q}).
+    amqp_channel:call(Channel, #'basic.consume'{queue = Q, no_ack = true}).
 
 %% Publishes to the broker, stores the From address against
 %% the correlation id and increments the correlationid for