diff options
| author | kjnilsson <knilsson@pivotal.io> | 2021-01-12 12:14:42 +0000 |
|---|---|---|
| committer | kjnilsson <knilsson@pivotal.io> | 2021-01-12 12:14:42 +0000 |
| commit | dfa077591425b67093b2c3f3773b374d3b8bf801 (patch) | |
| tree | f76323889b64a7c97b6142863208e8ed5822872d | |
| parent | 43ee7d45b57ff068c351540abdd2b3433abd07c8 (diff) | |
| download | rabbitmq-server-git-dfa077591425b67093b2c3f3773b374d3b8bf801.tar.gz | |
Remove unused valuestream-coordinator-restart-failure
| -rw-r--r-- | deps/rabbit/src/rabbit_stream_coordinator.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/deps/rabbit/src/rabbit_stream_coordinator.erl b/deps/rabbit/src/rabbit_stream_coordinator.erl index 4b58abc26f..93053bc04e 100644 --- a/deps/rabbit/src/rabbit_stream_coordinator.erl +++ b/deps/rabbit/src/rabbit_stream_coordinator.erl @@ -747,7 +747,7 @@ phase_stop_replicas(#{replica_nodes := Replicas, ra:pipeline_command({?MODULE, node()}, {replicas_stopped, StreamId}) end). -phase_start_new_leader(#{name := StreamId, leader_node := Node, leader_pid := LPid} = Conf) -> +phase_start_new_leader(#{name := StreamId, leader_node := Node} = Conf) -> spawn(fun() -> osiris_replica:stop(Node, Conf), osiris_writer:stop(Conf), |