diff options
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index 8770ff3281..4aa3eb8f4b 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -602,7 +602,7 @@ drop_expired_messages(State = #q{backing_queue_state = BQS, backing_queue = BQ}) -> Now = now_millis(), BQS1 = BQ:dropwhile( - fun (_MsgProperties = #message_properties{expiry = Expiry}) -> + fun (#message_properties{expiry = Expiry}) -> Now > Expiry end, BQS), ensure_ttl_timer(State #q{backing_queue_state = BQS1}). |