diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_quorum_queue.erl | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/src/rabbit_quorum_queue.erl b/src/rabbit_quorum_queue.erl index eb34b9db9f..405f82269e 100644 --- a/src/rabbit_quorum_queue.erl +++ b/src/rabbit_quorum_queue.erl @@ -252,7 +252,9 @@ handle_tick(QName, Infos = [{consumers, C}, {consumer_utilisation, Util}, {message_bytes_ready, MsgBytesReady}, {message_bytes_unacknowledged, MsgBytesUnack}, - {message_bytes, MsgBytesReady + MsgBytesUnack} + {message_bytes, MsgBytesReady + MsgBytesUnack}, + {message_bytes_persistent, MsgBytesReady + MsgBytesUnack} + | infos(QName)], rabbit_core_metrics:queue_stats(QName, Infos), rabbit_event:notify(queue_stats, @@ -260,6 +262,7 @@ handle_tick(QName, {messages, M}, {messages_ready, MR}, {messages_unacknowledged, MU}, + {messages_persistent, M}, {reductions, R}]), ok = repair_leader_record(QName, Self), ExpectedNodes = rabbit_mnesia:cluster_nodes(all), |