[SDCISA-13736, SDCISA-10974] Log less if lock already taken.

swisspost · Jan 5, 2024 · c2dc144 · c2dc144
1 parent db495db
commit c2dc144
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/src/main/java/org/swisspush/reststorage/redis/RedisStorage.java b/src/main/java/org/swisspush/reststorage/redis/RedisStorage.java
@@ -138,10 +138,14 @@ private void startPeriodicStorageCleanup(long intervalMs) {
         vertx.setPeriodic(intervalMs, event -> lock.acquireLock(STORAGE_CLEANUP_TASK_LOCK,
                         token(STORAGE_CLEANUP_TASK_LOCK), lockExpiry(resourceCleanupIntervalSec))
                 .onComplete(lockEvent -> {
-                    if( lockEvent.failed() || !lockEvent.result() ){
+                    if( lockEvent.failed() ){
                         log.error("Could not acquire lock '{}'.", STORAGE_CLEANUP_TASK_LOCK, lockEvent.cause());
                         return;
                     }
+                    if( !lockEvent.result() ){
+                        log.debug("Lock already taken '{}'", STORAGE_CLEANUP_TASK_LOCK);
+                        return;
+                    }
                     cleanup(cleanupEvent -> {
                             if (cleanupEvent.error) {
                                 log.warn("cleanup(): {}", cleanupEvent.errorMessage);