diff options
| author | kjnilsson <knilsson@pivotal.io> | 2019-01-04 11:39:22 +0000 |
|---|---|---|
| committer | kjnilsson <knilsson@pivotal.io> | 2019-01-04 11:39:22 +0000 |
| commit | 65e6979810a16605e37c585d3c4817fab03ee178 (patch) | |
| tree | 68052c1e82fc03e6a3db00565bb4d6e11b2e3519 /src | |
| parent | 16728ecbc56c4a200a4d86ff99f4527b2e8dbec7 (diff) | |
| download | rabbitmq-server-git-65e6979810a16605e37c585d3c4817fab03ee178.tar.gz | |
Update with Ra server supervision changes
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_fifo.erl | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/rabbit_fifo.erl b/src/rabbit_fifo.erl index e89f4a9e22..dcf8d071d5 100644 --- a/src/rabbit_fifo.erl +++ b/src/rabbit_fifo.erl @@ -533,7 +533,8 @@ state_enter(leader, #state{consumers = Cons, Pids = lists:usort(maps:keys(Enqs) ++ [P || {_, P} <- maps:keys(Cons)]), Mons = [{monitor, process, P} || P <- Pids], Nots = [{send_msg, P, leader_change, ra_event} || P <- Pids], - Effects = Mons ++ Nots, + NodeMons = lists:usort([{monitor, node, node(P)} || P <- Pids]), + Effects = Mons ++ Nots ++ NodeMons, case BLH of undefined -> Effects; |