diff options
| author | Arnaud Cogoluègnes <acogoluegnes@gmail.com> | 2021-04-27 11:52:29 +0200 |
|---|---|---|
| committer | Arnaud Cogoluègnes <acogoluegnes@gmail.com> | 2021-04-27 11:52:29 +0200 |
| commit | 4b71c349273b5bab6c413c8511fce062f68a5598 (patch) | |
| tree | e1022a2659a1f1bff436b354a060dd068b6fad38 | |
| parent | d963e036de8f16dd93c0b2fe0e8a68082e607d02 (diff) | |
| download | rabbitmq-server-git-osiris-tracking-types.tar.gz | |
Make tracking status more genericosiris-tracking-types
Type and value won't always be offset.
| -rw-r--r-- | deps/rabbit/src/rabbit_stream_queue.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/deps/rabbit/src/rabbit_stream_queue.erl b/deps/rabbit/src/rabbit_stream_queue.erl index 547624ed3a..4067410c7c 100644 --- a/deps/rabbit/src/rabbit_stream_queue.erl +++ b/deps/rabbit/src/rabbit_stream_queue.erl @@ -554,10 +554,10 @@ tracking_status(Vhost, QueueName) -> {ok, Q} when ?amqqueue_is_stream(Q) -> Leader = amqqueue:get_pid(Q), Map = osiris:read_tracking(Leader), - maps:fold(fun(K, {Type, OffsetValue}, Acc) -> + maps:fold(fun(K, {Type, Value}, Acc) -> [[{reference, K}, {type, Type}, - {offset, OffsetValue}] | Acc] + {value, Value}] | Acc] end, [], Map); {error, not_found} = E-> E |