diff options
Diffstat (limited to 'deps/rabbit/src/rabbit_quorum_queue.erl')
-rw-r--r-- | deps/rabbit/src/rabbit_quorum_queue.erl | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/deps/rabbit/src/rabbit_quorum_queue.erl b/deps/rabbit/src/rabbit_quorum_queue.erl index 2f4ab807dd..9075ec1df1 100644 --- a/deps/rabbit/src/rabbit_quorum_queue.erl +++ b/deps/rabbit/src/rabbit_quorum_queue.erl @@ -104,7 +104,6 @@ -define(TICK_TIMEOUT, 5000). %% the ra server tick time -define(DELETE_TIMEOUT, 5000). -define(ADD_MEMBER_TIMEOUT, 5000). --define(TRANSFER_TIMEOUT, 60000). %%----------- rabbit_queue_type --------------------------------------------- @@ -1174,7 +1173,7 @@ transfer_leadership(Q, Destination) -> {RaName, _} = Pid = amqqueue:get_pid(Q), case ra:transfer_leadership(Pid, {RaName, Destination}) of ok -> - case ra:members(Pid, ?TRANSFER_TIMEOUT) of + case ra:members(Pid) of {_, _, {_, NewNode}} -> {migrated, NewNode}; {timeout, _} -> |