Skip to content

Commit 8b2fccc

Browse files
committed
Fix rabbit_amqqueue:list_local_followers/1
To ensure it only returns followers for queues that actually have a local member.
1 parent 74121d7 commit 8b2fccc

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

deps/rabbit/src/rabbit_amqqueue.erl

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1260,8 +1260,8 @@ list_local_followers() ->
12601260
[Q
12611261
|| Q <- list(),
12621262
amqqueue:is_quorum(Q),
1263-
amqqueue:get_state(Q) =/= crashed,
12641263
amqqueue:get_leader(Q) =/= node(),
1264+
lists:member(node(), get_quorum_nodes(Q)),
12651265
rabbit_quorum_queue:is_recoverable(Q)
12661266
].
12671267

0 commit comments

Comments
 (0)