diff options
| -rw-r--r-- | deps/rabbit/src/rabbit_stream_queue.erl | 21 |
1 files changed, 13 insertions, 8 deletions
diff --git a/deps/rabbit/src/rabbit_stream_queue.erl b/deps/rabbit/src/rabbit_stream_queue.erl index c99268e6ba..d518714c24 100644 --- a/deps/rabbit/src/rabbit_stream_queue.erl +++ b/deps/rabbit/src/rabbit_stream_queue.erl @@ -515,14 +515,19 @@ i(_, _) -> ''. readers(QName) -> - Data = osiris_counters:overview(), - Readers = case maps:get({osiris_writer, QName}, Data, not_found) of - not_found -> - maps:get(readers, maps:get({osiris_replica, QName}, Data, #{}), 0); - Map -> - maps:get(readers, Map, 0) - end, - {node(), Readers}. + try + Data = osiris_counters:overview(), + Readers = case maps:get({osiris_writer, QName}, Data, not_found) of + not_found -> + maps:get(readers, maps:get({osiris_replica, QName}, Data, #{}), 0); + Map -> + maps:get(readers, Map, 0) + end, + {node(), Readers} + catch + _:_ -> + {node(), 0} + end. init(Q) when ?is_amqqueue(Q) -> Leader = amqqueue:get_pid(Q), |