diff options
| author | Arnaud Cogoluègnes <acogoluegnes@gmail.com> | 2023-01-31 16:49:48 +0100 |
|---|---|---|
| committer | Arnaud Cogoluègnes <acogoluegnes@gmail.com> | 2023-01-31 16:49:48 +0100 |
| commit | f558d80e3de322d129f4b65715eca59aa6665c85 (patch) | |
| tree | eb317bdd28682995e49f41fcfdbacbfb98642de0 | |
| parent | 1425e5cb02d22688b8a87343e81b1aa5e3c9e5bd (diff) | |
| download | rabbitmq-server-git-f558d80e3de322d129f4b65715eca59aa6665c85.tar.gz | |
Activate stream delivery v2 correctly
As soon as v2 is supported, whatever the min supported
version is.
| -rw-r--r-- | deps/rabbitmq_stream/src/rabbit_stream_reader.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/deps/rabbitmq_stream/src/rabbit_stream_reader.erl b/deps/rabbitmq_stream/src/rabbit_stream_reader.erl index 39ab2f0d12..642aa90bd3 100644 --- a/deps/rabbitmq_stream/src/rabbit_stream_reader.erl +++ b/deps/rabbitmq_stream/src/rabbit_stream_reader.erl @@ -2721,7 +2721,7 @@ process_client_command_versions(C, []) -> process_client_command_versions(C, [H | T]) -> process_client_command_versions(process_client_command_api(C, H), T). -process_client_command_api(C, {deliver, ?VERSION_1, ?VERSION_2}) -> +process_client_command_api(C, {deliver, _, ?VERSION_2}) -> C#stream_connection{deliver_version = ?VERSION_2}; process_client_command_api(C, _) -> C. |