diff options
| author | Diana Corbacho <diana@rabbitmq.com> | 2019-08-05 14:57:23 +0100 |
|---|---|---|
| committer | Diana Corbacho <diana@rabbitmq.com> | 2019-08-05 14:57:23 +0100 |
| commit | d6071b2cf77d41eec1c8d38f6f86b9e030c770e1 (patch) | |
| tree | 27dca4e991a28d200b47ff8951fd1a4b35ab959d | |
| parent | f6ca77aa207d9b688bb605263717fc16eaca6efb (diff) | |
| download | rabbitmq-server-git-d6071b2cf77d41eec1c8d38f6f86b9e030c770e1.tar.gz | |
Publish messages_persistent
They were only sent on the event
[#167649915]
| -rw-r--r-- | src/rabbit_quorum_queue.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_quorum_queue.erl b/src/rabbit_quorum_queue.erl index 405f82269e..88b6e6aad4 100644 --- a/src/rabbit_quorum_queue.erl +++ b/src/rabbit_quorum_queue.erl @@ -253,7 +253,8 @@ handle_tick(QName, {message_bytes_ready, MsgBytesReady}, {message_bytes_unacknowledged, MsgBytesUnack}, {message_bytes, MsgBytesReady + MsgBytesUnack}, - {message_bytes_persistent, MsgBytesReady + MsgBytesUnack} + {message_bytes_persistent, MsgBytesReady + MsgBytesUnack}, + {messages_persistent, M} | infos(QName)], rabbit_core_metrics:queue_stats(QName, Infos), @@ -262,7 +263,6 @@ 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), |