diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2013-08-21 12:11:22 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2013-08-21 12:11:22 +0100 |
| commit | 847153c5a3351fa3f01cd8a906d73adaabfe0aca (patch) | |
| tree | 4f9ceb8487491eae240d7666e1d589cce970dfdb /src/rabbit_amqqueue_process.erl | |
| parent | 4c602c8642924d966738eebb1e05b906d43ffec9 (diff) | |
| download | rabbitmq-server-847153c5a3351fa3f01cd8a906d73adaabfe0aca.tar.gz | |
Slightly clearer?
Diffstat (limited to 'src/rabbit_amqqueue_process.erl')
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 20 |
1 files changed, 10 insertions, 10 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index 5ddd14a9..e8011133 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -461,12 +461,12 @@ deliver_msgs_to_consumers(DeliverFun, false, {false, State}; {{value, QEntry, Priority}, Tail} -> {Stop, State1} = deliver_msg_to_consumer( - DeliverFun, {QEntry, Priority}, + DeliverFun, QEntry, Priority, State#q{active_consumers = Tail}), deliver_msgs_to_consumers(DeliverFun, Stop, State1) end. -deliver_msg_to_consumer(DeliverFun, {E = {ChPid, Consumer}, Priority}, State) -> +deliver_msg_to_consumer(DeliverFun, E = {ChPid, Consumer}, Priority, State) -> C = lookup_ch(ChPid), case is_ch_blocked(C) of true -> block_consumer(C, E, State), @@ -480,19 +480,19 @@ deliver_msg_to_consumer(DeliverFun, {E = {ChPid, Consumer}, Priority}, State) -> {continue, Limiter} -> AC1 = priority_queue:in(E, Priority, State#q.active_consumers), - deliver_msg_to_consumer( + deliver_msg_to_consumer0( DeliverFun, Consumer, C#cr{limiter = Limiter}, State#q{active_consumers = AC1}) end end. -deliver_msg_to_consumer(DeliverFun, - #consumer{tag = ConsumerTag, - ack_required = AckRequired}, - C = #cr{ch_pid = ChPid, - acktags = ChAckTags, - unsent_message_count = Count}, - State = #q{q = #amqqueue{name = QName}}) -> +deliver_msg_to_consumer0(DeliverFun, + #consumer{tag = ConsumerTag, + ack_required = AckRequired}, + C = #cr{ch_pid = ChPid, + acktags = ChAckTags, + unsent_message_count = Count}, + State = #q{q = #amqqueue{name = QName}}) -> {{Message, IsDelivered, AckTag}, Stop, State1} = DeliverFun(AckRequired, State), rabbit_channel:deliver(ChPid, ConsumerTag, AckRequired, |