Ignore timeout errors from deleting transient queues on node down

rabbitmq · Apr 30, 2024 · 3207119 · 3207119
1 parent eac133d
commit 3207119
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/deps/rabbit/src/rabbit_amqqueue.erl b/deps/rabbit/src/rabbit_amqqueue.erl
@@ -1995,7 +1995,12 @@ maybe_clear_recoverable_node(Node) ->
 on_node_down(Node) ->
     {Time, Ret} = timer:tc(fun() -> rabbit_db_queue:delete_transient(filter_transient_queues_to_delete(Node)) end),
     case Ret of
-        ok -> ok;
+        {error, timeout} ->
+            %% This type of failure is only possible with Khepri but transient
+            %% entities are going away as Khepri stabilizes.
+            rabbit_log:warning("Failed to delete transient queues on node "
+                               "down due to a timeout"),
+            ok;
         {QueueNames, Deletions} ->
             case length(QueueNames) of
                 0 -> ok;