diff options
| author | Karl Nilsson <kjnilsson@gmail.com> | 2022-01-07 12:30:03 +0000 |
|---|---|---|
| committer | Karl Nilsson <kjnilsson@gmail.com> | 2022-01-07 12:30:03 +0000 |
| commit | 82470e9d1c8f2019ff9b3d5054a36d9357f8f90a (patch) | |
| tree | f114d98e3f4c19d82e685bb88a8e1cb648e32163 | |
| parent | 9a5d0f9d85bda218124c0b95edc37fc717cb8cc5 (diff) | |
| download | rabbitmq-server-git-82470e9d1c8f2019ff9b3d5054a36d9357f8f90a.tar.gz | |
Stream coordinator: handle machine_version commandtomyouyou-stream_select_leader
| -rw-r--r-- | deps/rabbit/src/rabbit_stream_coordinator.erl | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/deps/rabbit/src/rabbit_stream_coordinator.erl b/deps/rabbit/src/rabbit_stream_coordinator.erl index 39f5300641..82e93da876 100644 --- a/deps/rabbit/src/rabbit_stream_coordinator.erl +++ b/deps/rabbit/src/rabbit_stream_coordinator.erl @@ -438,6 +438,8 @@ apply(Meta, {nodeup, Node} = Cmd, end, {Streams0, Effects0}, Streams0), return(Meta, State#?MODULE{monitors = Monitors, streams = Streams}, ok, Effects); +apply(Meta, {machine_version, _From, _To}, State) -> + return(Meta, State, ok, []); apply(Meta, UnkCmd, State) -> rabbit_log:debug("~s: unknown command ~W", [?MODULE, UnkCmd, 10]), |