diff options
| -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 |