diff options
| author | Matthew Sackman <matthew@rabbitmq.com> | 2010-07-08 16:58:29 +0100 |
|---|---|---|
| committer | Matthew Sackman <matthew@rabbitmq.com> | 2010-07-08 16:58:29 +0100 |
| commit | b8c7d7e3d7629b9bc7eeba9c9ec45a556708b493 (patch) | |
| tree | 7ea5e7b53c1da3568a8e52c6d1912e878e8c397f /src | |
| parent | 8fa063bd998c2f03a966c995e3016af22e69bc8d (diff) | |
| download | rabbitmq-server-git-b8c7d7e3d7629b9bc7eeba9c9ec45a556708b493.tar.gz | |
Expose the persistent count in the vq status
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_variable_queue.erl | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index c176f68294..625c34513e 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -660,7 +660,8 @@ status(#vqstate { q1 = Q1, q2 = Q2, delta = Delta, q3 = Q3, q4 = Q4, ram_index_count = RamIndexCount, avg_egress_rate = AvgEgressRate, avg_ingress_rate = AvgIngressRate, - next_seq_id = NextSeqId }) -> + next_seq_id = NextSeqId, + persistent_count = PersistentCount }) -> [ {q1 , queue:len(Q1)}, {q2 , bpqueue:len(Q2)}, {delta , Delta}, @@ -673,7 +674,8 @@ status(#vqstate { q1 = Q1, q2 = Q2, delta = Delta, q3 = Q3, q4 = Q4, {ram_index_count , RamIndexCount}, {avg_egress_rate , AvgEgressRate}, {avg_ingress_rate , AvgIngressRate}, - {next_seq_id , NextSeqId} ]. + {next_seq_id , NextSeqId}, + {persistent_count , PersistentCount} ]. %%---------------------------------------------------------------------------- %% Minor helpers |