System message statistics are not collected

rmqtt · Aug 9, 2023 · 0caf0e6 · 0caf0e6
1 parent dd0015d
commit 0caf0e6
Showing 1 changed file with 8 additions and 4 deletions.
diff --git a/rmqtt-plugins/rmqtt-counter/src/lib.rs b/rmqtt-plugins/rmqtt-counter/src/lib.rs
@@ -220,11 +220,15 @@ impl Handler for CounterHandler {
                 // }
                 self.metrics.messages_publish_inc();
             }
-            Parameter::MessageDelivered(_session, _client, _f, _p) => {
-                self.metrics.messages_delivered_inc();
+            Parameter::MessageDelivered(_session, _client, from, _p) => {
+                if !from.is_system() {
+                    self.metrics.messages_delivered_inc();
+                }
             }
-            Parameter::MessageAcked(_session, _client, _f, _p) => {
-                self.metrics.messages_acked_inc();
+            Parameter::MessageAcked(_session, _client, from, _p) => {
+                if !from.is_system() {
+                    self.metrics.messages_acked_inc();
+                }
             }
             Parameter::MessageDropped(_to, _from, _p, _r) => {
                 self.metrics.messages_dropped_inc(); //@TODO ... elaboration