diff options
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index b61e450bd0..81dea02789 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -178,9 +178,11 @@ deliver_queue(Fun, FunAcc0, unsent_message_count = Count, unacked_messages = UAM} = ch_record(ChPid), IsMsgReady = Fun(is_message_ready, FunAcc0, State), - case not(AckRequired) orelse - ( IsMsgReady andalso - rabbit_limiter:can_send( LimiterPid, self()) + case IsMsgReady + andalso + ( (not AckRequired) + orelse + rabbit_limiter:can_send( LimiterPid, self() ) ) of true -> case Fun(AckRequired, FunAcc0, State) of |