diff options
| author | Karl Nilsson <kjnilsson@gmail.com> | 2019-08-02 10:43:18 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2019-08-02 10:43:18 +0100 |
| commit | 198d2e9d887c0f6d4e8bfdf33830773176808f79 (patch) | |
| tree | 1b0084f55ad08e475f261a094e1f40b6626daf52 | |
| parent | 8c6a531cd6255198d78e860a726eed0bb5c12e0b (diff) | |
| parent | f85ad885735a0913aaa3f85508549146f245ce14 (diff) | |
| download | rabbitmq-server-git-198d2e9d887c0f6d4e8bfdf33830773176808f79.tar.gz | |
Merge pull request #2063 from rabbitmq/qq-persistent-stats
Publish persistent stats for quorum queues
| -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), |