Skip to content

Commit 198d2e9

Browse files
authored
Merge pull request #2063 from rabbitmq/qq-persistent-stats
Publish persistent stats for quorum queues
2 parents 8c6a531 + f85ad88 commit 198d2e9

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

src/rabbit_quorum_queue.erl

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -252,14 +252,17 @@ handle_tick(QName,
252252
Infos = [{consumers, C}, {consumer_utilisation, Util},
253253
{message_bytes_ready, MsgBytesReady},
254254
{message_bytes_unacknowledged, MsgBytesUnack},
255-
{message_bytes, MsgBytesReady + MsgBytesUnack}
255+
{message_bytes, MsgBytesReady + MsgBytesUnack},
256+
{message_bytes_persistent, MsgBytesReady + MsgBytesUnack}
257+
256258
| infos(QName)],
257259
rabbit_core_metrics:queue_stats(QName, Infos),
258260
rabbit_event:notify(queue_stats,
259261
Infos ++ [{name, QName},
260262
{messages, M},
261263
{messages_ready, MR},
262264
{messages_unacknowledged, MU},
265+
{messages_persistent, M},
263266
{reductions, R}]),
264267
ok = repair_leader_record(QName, Self),
265268
ExpectedNodes = rabbit_mnesia:cluster_nodes(all),

0 commit comments

Comments
 (0)