diff options
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index 35a28b6bac..8ba9b4d2bd 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -471,12 +471,12 @@ deliver_msg_to_consumer(DeliverFun, E = {ChPid, Consumer}, State) -> Limiter2 -> AC1 = queue:in(E, State#q.active_consumers), deliver_msg_to_consumer( - DeliverFun, Limiter2, Consumer, C, + DeliverFun, Consumer, C#cr{limiter = Limiter2}, State#q{active_consumers = AC1}) end end. -deliver_msg_to_consumer(DeliverFun, NewLimiter, +deliver_msg_to_consumer(DeliverFun, #consumer{tag = ConsumerTag, ack_required = AckRequired}, C = #cr{ch_pid = ChPid, @@ -492,7 +492,6 @@ deliver_msg_to_consumer(DeliverFun, NewLimiter, false -> ChAckTags end, update_ch_record(C#cr{acktags = ChAckTags1, - limiter = NewLimiter, unsent_message_count = Count + 1}), {Stop, State1}. |