diff options
Diffstat (limited to 'src/rabbit_amqqueue_process.erl')
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index d6ce5c8f..f05fc336 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -1032,7 +1032,7 @@ handle_cast({deliver, Delivery = #delivery{sender = Sender}, Flow}, State) -> undefined -> put(Key, erlang:monitor(process, Sender)); _ -> ok end, - credit_flow:ack(Sender, ?CREDIT_CPU_BOUND); + credit_flow:ack(Sender); noflow -> ok end, noreply(deliver_or_enqueue(Delivery, State)); |