diff options
| author | Karl Nilsson <kjnilsson@gmail.com> | 2019-01-08 10:26:02 +0000 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2019-01-08 10:26:02 +0000 |
| commit | 07e914a08e64a86d4e8e44f9aeae7cb6eb8fec01 (patch) | |
| tree | baf4210748df32384b1b78fd6005e56e16197dde /src | |
| parent | 91d01e77669903463efa3f562fd214431783adb3 (diff) | |
| parent | 65e6979810a16605e37c585d3c4817fab03ee178 (diff) | |
| download | rabbitmq-server-git-07e914a08e64a86d4e8e44f9aeae7cb6eb8fec01.tar.gz | |
Merge pull request #1817 from rabbitmq/ra_server_supervision
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; |