diff options
| author | Matthias Radestock <matthias@lshift.net> | 2010-02-10 09:07:18 +0000 |
|---|---|---|
| committer | Matthias Radestock <matthias@lshift.net> | 2010-02-10 09:07:18 +0000 |
| commit | 709069603086704267055ea50b22a19b47c748aa (patch) | |
| tree | 28e18d0dd4e33159936e8ef1ba4254b37489b62e /src | |
| parent | 2db11990abb85ce83c114dda76961b9e244b1af7 (diff) | |
| download | rabbitmq-server-git-709069603086704267055ea50b22a19b47c748aa.tar.gz | |
osmetic
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 11 |
1 files changed, 5 insertions, 6 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index 996fe52b39..d4de6bfdf4 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -248,12 +248,11 @@ record_current_channel_tx(ChPid, Txn) -> %% that wasn't happening already) store_ch_record((ch_record(ChPid))#cr{txn = Txn}). -deliver_msgs_to_consumers( - Funs = {PredFun, DeliverFun}, FunAcc, - State = #q{q = #amqqueue{name = QName}, - active_consumers = ActiveConsumers, - blocked_consumers = BlockedConsumers, - next_msg_id = NextId}) -> +deliver_msgs_to_consumers(Funs = {PredFun, DeliverFun}, FunAcc, + State = #q{q = #amqqueue{name = QName}, + active_consumers = ActiveConsumers, + blocked_consumers = BlockedConsumers, + next_msg_id = NextId}) -> case queue:out(ActiveConsumers) of {{value, QEntry = {ChPid, #consumer{tag = ConsumerTag, ack_required = AckRequired}}}, |