diff options
| author | Diana Corbacho <diana@rabbitmq.com> | 2019-08-01 16:44:21 +0100 |
|---|---|---|
| committer | Diana Corbacho <diana@rabbitmq.com> | 2019-08-01 16:44:21 +0100 |
| commit | f85ad885735a0913aaa3f85508549146f245ce14 (patch) | |
| tree | 214fc28006f36df6dabc3ed5699b7b04d8872978 /src | |
| parent | ebb6d11472878e71fd008c20bab1f305d990541b (diff) | |
| download | rabbitmq-server-git-f85ad885735a0913aaa3f85508549146f245ce14.tar.gz | |
Publish persistent stats for quorum queues
[#167649915]
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), |