diff options
Diffstat (limited to 'src/rabbit_amqqueue.erl')
-rw-r--r-- | src/rabbit_amqqueue.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl index 21383905..94a99a49 100644 --- a/src/rabbit_amqqueue.erl +++ b/src/rabbit_amqqueue.erl @@ -535,7 +535,7 @@ deliver(Qs, Delivery = #delivery{mandatory = false, immediate = false}, Flow) -> %% case below. QPids = qpids(Qs), case Flow of - flow -> [credit_flow:send(QPid, ?CREDIT_CPU_BOUND) || QPid <- QPids]; + flow -> [credit_flow:send(QPid) || QPid <- QPids]; noflow -> ok end, delegate:invoke_no_result( |