[AMQ-8354] Fix TPS calculation.

amazon-mq · Aug 7, 2024 · 8cd2a82 · 8cd2a82
1 parent 0459be6
commit 8cd2a82
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/activemq-broker/src/main/java/org/apache/activemq/replica/ReplicaStatistics.java b/activemq-broker/src/main/java/org/apache/activemq/replica/ReplicaStatistics.java
@@ -25,6 +25,8 @@
 
 public class ReplicaStatistics {
 
+    private static final int TPS_UPDATE_PERIOD = 60;
+
     private AtomicLong replicationTps;
     private AtomicLong tpsCounter;
     private AtomicLong lastTpsCounter;
@@ -47,12 +49,12 @@ public ReplicaStatistics() {
             if (replicationTps == null) {
                 replicationTps = new AtomicLong();
             }
-            replicationTps.set((c - lastTpsCounter.get()) / 10);
             if (lastTpsCounter == null) {
                 lastTpsCounter = new AtomicLong();
             }
+            replicationTps.set((c - lastTpsCounter.get()) / TPS_UPDATE_PERIOD);
             lastTpsCounter.set(c);
-        }, 60, 60, TimeUnit.SECONDS);
+        }, TPS_UPDATE_PERIOD, TPS_UPDATE_PERIOD, TimeUnit.SECONDS);
     }
 
     public void reset() {