Merge pull request #13088 from rabbitmq/mergify/bp/v4.0.x/pr-13087

Fix return value of `rabbit_priority_queue:delete_crashed/1` (backport #13087)
rabbitmq · Jan 16, 2025 · de236f5 · de236f5
2 parents 0cd2b3e + e4a1395
commit de236f5
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/deps/rabbit/src/rabbit_priority_queue.erl b/deps/rabbit/src/rabbit_priority_queue.erl
@@ -187,7 +187,9 @@ delete_crashed(Q) ->
     BQ = bq(),
     case priorities(Q) of
         none -> BQ:delete_crashed(Q);
-        Ps   -> [BQ:delete_crashed(mutate_name(P, Q)) || P <- Ps]
+        Ps   ->
+            [ok = BQ:delete_crashed(mutate_name(P, Q)) || P <- Ps],
+            ok
     end.
 
 purge(State = #state{bq = BQ}) ->