Skip to content

Commit 78745a6

Browse files
michaelklishinmergify[bot]
authored andcommitted
is_recoverable/1: improve guards
(cherry picked from commit 8dfcc9c) (cherry picked from commit 2f312d8)
1 parent d6f5dbf commit 78745a6

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

deps/rabbit/src/rabbit_classic_queue.erl

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -115,7 +115,7 @@ delete(Q, IfUnused, IfEmpty, ActingUser) when ?amqqueue_is_classic(Q) ->
115115
{ok, 0}
116116
end.
117117

118-
is_recoverable(Q) when ?is_amqqueue(Q) ->
118+
is_recoverable(Q) when ?is_amqqueue(Q) and ?amqqueue_is_classic(Q) ->
119119
Node = node(),
120120
Node =:= amqqueue:qnode(Q) andalso
121121
%% Terminations on node down will not remove the rabbit_queue

deps/rabbit/src/rabbit_quorum_queue.erl

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -560,7 +560,7 @@ reductions(Name) ->
560560
0
561561
end.
562562

563-
is_recoverable(Q) ->
563+
is_recoverable(Q) when ?is_amqqueue(Q) and ?amqqueue_is_quorum(Q) ->
564564
Node = node(),
565565
Nodes = get_nodes(Q),
566566
lists:member(Node, Nodes).

0 commit comments

Comments
 (0)