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

Set lastOpened in loop detection
telekom · Aug 23, 2024 · f55fd52 · f55fd52
2 parents 3c18490 + 76072cf
commit f55fd52
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/internal/circuitbreaker/circuitbreaker.go b/internal/circuitbreaker/circuitbreaker.go
@@ -130,6 +130,8 @@ func checkForCircuitBreakerLoop(cbMessage *message.CircuitBreakerMessage) error
 		cbMessage.LoopCounter = 0
 		log.Debug().Msgf("Circuit breaker opened outside loop detection period. Reseted loop counter for subscription %s: %v", cbMessage.SubscriptionId, cbMessage.LoopCounter)
 	}
+	// set last opened for the next loop detection
+	cbMessage.LastOpened = cbMessage.LastModified
 	cbMessage.LastModified = types.NewTimestamp(time.Now().UTC())
 
 	err := cache.CircuitBreakerCache.Put(config.Current.Hazelcast.Caches.CircuitBreakerCache, cbMessage.SubscriptionId, *cbMessage)