Skip to content

Commit 61a2fd7

Browse files
Merge pull request #10163 from Ayanda-D/log-on-queue-expiry
Add log on queue expiry
2 parents 5eb4eef + 7c53677 commit 61a2fd7

File tree

1 file changed

+5
-2
lines changed

1 file changed

+5
-2
lines changed

deps/rabbit/src/rabbit_amqqueue_process.erl

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1716,9 +1716,12 @@ handle_cast({sync_start, _, _}, State = #q{q = Q}) ->
17161716
Name, "Stopping after receiving sync_start from another master", []),
17171717
stop(State).
17181718

1719-
handle_info({maybe_expire, Vsn}, State = #q{args_policy_version = Vsn}) ->
1719+
handle_info({maybe_expire, Vsn}, State = #q{q = Q, expires = Expiry, args_policy_version = Vsn}) ->
17201720
case is_unused(State) of
1721-
true -> stop(State);
1721+
true ->
1722+
QResource = rabbit_misc:rs(amqqueue:get_name(Q)),
1723+
rabbit_log_queue:debug("Deleting 'classic ~ts' on expiry after ~tp milliseconds", [QResource, Expiry]),
1724+
stop(State);
17221725
false -> noreply(State#q{expiry_timer_ref = undefined})
17231726
end;
17241727

0 commit comments

Comments
 (0)