Merge pull request #18 from telekom/fix-loop-detection

Fix loop detection
telekom · Aug 23, 2024 · 9cb2ef0 · 9cb2ef0
2 parents f758295 + 719c2aa
commit 9cb2ef0
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/.gitignore b/.gitignore
@@ -9,7 +9,7 @@ build/
 !gradle/wrapper/gradle-wrapper.jar
 !**/src/main/**/build/
 !**/src/test/**/build/
-application-dev.yaml
+application-dev*.yaml
 
 ### STS ###
 .apt_generated

diff --git a/gradle.properties b/gradle.properties
@@ -1,5 +1,5 @@
 awaitilityVersion=4.2.0
 httpClientVersion=4.5.14
 mockitoInlineVersion=5.2.0
-horizonParentVersion=4.2.0
+horizonParentVersion=4.2.1
 wiremockStandaloneVersion=3.3.1
diff --git a/src/main/java/de/telekom/horizon/comet/service/CircuitBreakerCacheService.java b/src/main/java/de/telekom/horizon/comet/service/CircuitBreakerCacheService.java
@@ -81,7 +81,7 @@ public void openCircuitBreaker(String subscriptionId, String eventType, String o
             if (result.isPresent()) {
                 CircuitBreakerMessage existingCircuitBreakerMessage = result.get();
                 newCircuitBreakerMessage.setLoopCounter(existingCircuitBreakerMessage.getLoopCounter());
-                newCircuitBreakerMessage.setLastOpened(Date.from(Instant.now()));
+                newCircuitBreakerMessage.setLastOpened(existingCircuitBreakerMessage.getLastOpened());
             }
             circuitBreakerCache.set(subscriptionId, newCircuitBreakerMessage);
         } catch (JsonCacheException e) {