diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2013-02-20 14:57:53 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2013-02-20 14:57:53 +0000 |
| commit | b23d6f0e56009abecc1943803e0ca8bd89d41313 (patch) | |
| tree | 3b0a50e2edd51c5008cc4cea1a9ef1d701236c70 | |
| parent | df110e0e138f9c6aa615f48cd344c9c7c13103c2 (diff) | |
| download | rabbitmq-server-git-b23d6f0e56009abecc1943803e0ca8bd89d41313.tar.gz | |
Neatness
| -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}. |