diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2012-11-22 11:24:25 +0000 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2012-11-22 11:24:25 +0000 |
| commit | 9ddbcb935c21304fbd40e22714afe62b9c4c4b6b (patch) | |
| tree | aa4f22d9aafe7bad32ca6e81cb60a17064834a10 | |
| parent | 626e654987a95b8cfb0e85079899de4e0dee2d33 (diff) | |
| parent | 4e4ca168d5a40c091a5bd52ef4098a2094b83994 (diff) | |
| download | rabbitmq-server-9ddbcb935c21304fbd40e22714afe62b9c4c4b6b.tar.gz | |
merge bug25301 into stable
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index f87f5777..68bd1c6c 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -485,9 +485,11 @@ deliver_msg_to_consumer(DeliverFun, {Stop, State1}. deliver_from_queue_deliver(AckRequired, State) -> - {{Message, IsDelivered, AckTag, Remaining}, State1} = + {{Message, IsDelivered, AckTag, _Remaining}, State1} = fetch(AckRequired, State), - {{Message, IsDelivered, AckTag}, 0 == Remaining, State1}. + State2 = #q{backing_queue = BQ, backing_queue_state = BQS} = + drop_expired_messages(State1), + {{Message, IsDelivered, AckTag}, BQ:is_empty(BQS), State2}. confirm_messages([], State) -> State; |