diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2013-02-13 11:21:35 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2013-02-13 11:21:35 +0000 |
| commit | 24710f5ea4a567e06ea44394300b28a0b14c886d (patch) | |
| tree | c6ed1d01bc61b7a68f14f329df4eeace58f01a73 | |
| parent | eae2569cdced54ac44f2119cf4e7ffb876347cb6 (diff) | |
| parent | f5dc2b4f9860bacc5cde307c405f7e5f3fc66f53 (diff) | |
| download | rabbitmq-server-24710f5ea4a567e06ea44394300b28a0b14c886d.tar.gz | |
stable to default
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 9 |
1 files changed, 4 insertions, 5 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index 3bae4cfb..00a3a85a 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -470,10 +470,9 @@ deliver_msg_to_consumer(DeliverFun, {Stop, State1}. deliver_from_queue_deliver(AckRequired, State) -> - {Result, State1} = fetch(AckRequired, State), - State2 = #q{backing_queue = BQ, backing_queue_state = BQS} = - drop_expired_msgs(State1), - {Result, BQ:is_empty(BQS), State2}. + {Result, State1 = #q{backing_queue = BQ, backing_queue_state = BQS}} = + fetch(AckRequired, State), + {Result, BQ:is_empty(BQS), State1}. confirm_messages([], State) -> State; @@ -573,7 +572,7 @@ requeue_and_run(AckTags, State = #q{backing_queue = BQ, fetch(AckRequired, State = #q{backing_queue = BQ, backing_queue_state = BQS}) -> {Result, BQS1} = BQ:fetch(AckRequired, BQS), - {Result, State#q{backing_queue_state = BQS1}}. + {Result, drop_expired_msgs(State#q{backing_queue_state = BQS1})}. ack(AckTags, ChPid, State) -> subtract_acks(ChPid, AckTags, State, |