diff options
| author | Michael Klishin <mklishin@pivotal.io> | 2019-10-25 09:16:58 +0300 |
|---|---|---|
| committer | Michael Klishin <mklishin@pivotal.io> | 2019-10-25 09:16:58 +0300 |
| commit | 7138c748b317a23cf103687cf03d57aed8feb400 (patch) | |
| tree | 3a46d8564735b48bcc3485c5f8f3c73de7efe9a6 | |
| parent | 8687c1bb5b36bce4a2ce781bc4aae2d7f10dfe9e (diff) | |
| download | rabbitmq-server-git-7138c748b317a23cf103687cf03d57aed8feb400.tar.gz | |
Correctly pass Ra leader here
| -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 |