Don't print message rates until > 0

This prevents printing zeros every second if the clients can't even connect
rabbitmq · Nov 30, 2024 · c8ebc8f · c8ebc8f
1 parent 18d67ed
commit c8ebc8f
Showing 1 changed file with 8 additions and 7 deletions.
diff --git a/pkg/metrics/metrics.go b/pkg/metrics/metrics.go
@@ -169,13 +169,14 @@ func (m *MetricsServer) PrintMessageRates(ctx context.Context) {
 				published := MessagesPublished.Get()
 				consumed := MessagesConsumedNormalPriority.Get() + MessagesConsumedHighPriority.Get()
 
-				log.Print("",
-					"published", fmt.Sprintf("%v/s", published-previouslyPublished),
-					"consumed", fmt.Sprintf("%v/s", consumed-previouslyConsumed))
-
-				previouslyPublished = published
-				previouslyConsumed = consumed
-
+				if published > 0 || consumed > 0 {
+					log.Print("",
+						"published", fmt.Sprintf("%v/s", published-previouslyPublished),
+						"consumed", fmt.Sprintf("%v/s", consumed-previouslyConsumed))
+
+					previouslyPublished = published
+					previouslyConsumed = consumed
+				}
 			}
 		}
 	}()