diff options
| -rw-r--r-- | src/rabbit_amqqueue.erl | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl index 02a20367d9..5654986ce5 100644 --- a/src/rabbit_amqqueue.erl +++ b/src/rabbit_amqqueue.erl @@ -1085,7 +1085,8 @@ is_unresponsive(Q, Timeout) when ?amqqueue_is_classic(Q) -> end; is_unresponsive(Q, Timeout) when ?amqqueue_is_quorum(Q) -> try - case rabbit_fifo_client:stat(Q, Timeout) of + Leader = amqqueue:get_pid(Q), + case rabbit_fifo_client:stat(Leader, Timeout) of {ok, _, _} -> false; {timeout, _} -> true; {error, _} -> true |