diff options
| -rw-r--r-- | src/rabbit_stream_coordinator.erl | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/src/rabbit_stream_coordinator.erl b/src/rabbit_stream_coordinator.erl index 8a1205b9af..9e4890c894 100644 --- a/src/rabbit_stream_coordinator.erl +++ b/src/rabbit_stream_coordinator.erl @@ -115,7 +115,9 @@ delete_replica(StreamId, Node) -> process_command({delete_replica, #{stream_id => StreamId, node => Node}}). process_command(Cmd) -> + global:set_lock(?STREAM_COORDINATOR_STARTUP), Servers = ensure_coordinator_started(), + global:del_lock(?STREAM_COORDINATOR_STARTUP), process_command(Servers, Cmd). process_command([], _Cmd) -> |