diff options
| author | Diana Corbacho <diana@rabbitmq.com> | 2018-12-03 14:53:43 +0000 |
|---|---|---|
| committer | Diana Corbacho <diana@rabbitmq.com> | 2018-12-03 14:53:43 +0000 |
| commit | 08121376120e3ec936344bf39d80aa9448218d80 (patch) | |
| tree | b1ba627512dba892ab0968f378480a4cd1c86926 | |
| parent | 0c6fbcf6c00b6907c1525e1f3678979cf4f1476c (diff) | |
| download | rabbitmq-server-git-08121376120e3ec936344bf39d80aa9448218d80.tar.gz | |
Use ra nodes to intialise rabbit_fifo_client
| -rw-r--r-- | src/rabbit_quorum_queue.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_quorum_queue.erl b/src/rabbit_quorum_queue.erl index f6fabb40bb..6de9ed7818 100644 --- a/src/rabbit_quorum_queue.erl +++ b/src/rabbit_quorum_queue.erl @@ -99,7 +99,7 @@ init_state({Name, _}, QName) -> {ok, #amqqueue{pid = Leader, quorum_nodes = Nodes0}} = rabbit_amqqueue:lookup(QName), %% Ensure the leader is listed first - Nodes = [Leader | lists:delete(Leader, Nodes0)], + Nodes = [Leader | lists:delete(Leader, [{Name, N} || N <- Nodes0])], rabbit_fifo_client:init(QName, Nodes, SoftLimit, fun() -> credit_flow:block(Name), ok end, fun() -> credit_flow:unblock(Name), ok end). |