#654 Make metric changes thread safe

swisspost · Jan 13, 2025 · df9c2ff · df9c2ff
1 parent cdc3849
commit df9c2ff
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/gateleen-kafka/src/main/java/org/swisspush/gateleen/kafka/KafkaMessageSender.java b/gateleen-kafka/src/main/java/org/swisspush/gateleen/kafka/KafkaMessageSender.java
@@ -71,7 +71,7 @@ private Future<Void> sendMessage(KafkaProducer<String, String> kafkaProducer, Ka
         });
     }
 
-    private void incrementSuccessCount(String topic) {
+    private synchronized void incrementSuccessCount(String topic) {
         Counter counter = successSendCounterMap.get(topic);
         if(counter != null) {
             counter.increment();
@@ -88,7 +88,7 @@ private void incrementSuccessCount(String topic) {
         }
     }
 
-    private void incrementFailCount1(String topic) {
+    private synchronized void incrementFailCount1(String topic) {
         Counter counter = failSendCounterMap.get(topic);
         if(counter != null) {
             counter.increment();