diff options
| author | Arnaud Cogoluègnes <acogoluegnes@gmail.com> | 2021-02-26 12:14:21 +0100 |
|---|---|---|
| committer | Arnaud Cogoluègnes <acogoluegnes@gmail.com> | 2021-02-26 12:14:21 +0100 |
| commit | 26566c10e20d5eda90445c68508f10a13dbf47bc (patch) | |
| tree | b9787f1bf3f505bf01d2347816bac3c5cc06a912 | |
| parent | a807027adfc6f061dcac5b73fd982596f5b92d65 (diff) | |
| download | rabbitmq-server-git-26566c10e20d5eda90445c68508f10a13dbf47bc.tar.gz | |
Add comment
| -rw-r--r-- | deps/rabbitmq_stream/src/rabbit_stream_manager.erl | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/deps/rabbitmq_stream/src/rabbit_stream_manager.erl b/deps/rabbitmq_stream/src/rabbit_stream_manager.erl index 3e7d97abb8..ced9f35b8b 100644 --- a/deps/rabbitmq_stream/src/rabbit_stream_manager.erl +++ b/deps/rabbitmq_stream/src/rabbit_stream_manager.erl @@ -372,6 +372,7 @@ handle_call({partitions, VirtualHost, SuperStream}, _From, State) -> rabbit_exchange:lookup_or_die(ExchangeName), %% FIXME make sure queue is a stream %% TODO bindings could be sorted by partition number, by using a binding argument + %% this would make the spreading of messages stable {ok, lists:foldl(fun (#binding{destination = #resource{kind = queue, name = Q}}, |