diff options
| -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 81347cf74a..ec1a9b778d 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -551,12 +551,11 @@ deliver_or_enqueue(Delivery = #delivery{message = Message, ensure_ttl_timer(State2#q{backing_queue_state = BQS1}) end. -requeue_and_run(AckTags, State = #q{backing_queue = BQ, ttl=TTL}) -> - run_backing_queue( - BQ, fun (M, BQS) -> - {_MsgIds, BQS1} = M:requeue(AckTags, BQS), - BQS1 - end, State). +requeue_and_run(AckTags, State = #q{backing_queue = BQ}) -> + run_backing_queue(BQ, fun (M, BQS) -> + {_MsgIds, BQS1} = M:requeue(AckTags, BQS), + BQS1 + end, State). fetch(AckRequired, State = #q{backing_queue_state = BQS, backing_queue = BQ}) -> |