Skip to content

Commit 2043c43

Browse files
committed
rabbit_amqqueue: Accept stream queues in forget_node_for_queue/2
1 parent 81d5eac commit 2043c43

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

deps/rabbit/src/rabbit_amqqueue.erl

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1757,6 +1757,9 @@ forget_all_durable(Node) ->
17571757
forget_node_for_queue(_DeadNode, Q)
17581758
when ?amqqueue_is_quorum(Q) ->
17591759
ok;
1760+
forget_node_for_queue(_DeadNode, Q)
1761+
when ?amqqueue_is_stream(Q) ->
1762+
ok;
17601763
forget_node_for_queue(DeadNode, Q) ->
17611764
RS = amqqueue:get_recoverable_slaves(Q),
17621765
forget_node_for_queue(DeadNode, RS, Q).

0 commit comments

Comments
 (0)