patch: fix log timing for rotation flow

OpenSrcerer · Apr 16, 2024 · 71bd6ab · 71bd6ab
1 parent 59090b8
commit 71bd6ab
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/src/main/kotlin/online/danielstefani/paddy/security/mqtt/MqttAuthorizationController.kt b/src/main/kotlin/online/danielstefani/paddy/security/mqtt/MqttAuthorizationController.kt
@@ -55,9 +55,11 @@ class MqttAuthorizationController(
 
             // Remove element from deduplication set after 60s
             Mono.just(true)
-                .doOnSubscribe { Log.info("[JWT-ROTATOR] Removing <$sub> from deduplication set.") }
                 .delayElement(Duration.ofSeconds(60))
-                .doOnSuccess { rotationDeduplicationSet.remove(sub) }
+                .doOnSuccess {
+                    Log.info("[JWT-ROTATOR] Removing <$sub> from deduplication set.")
+                    rotationDeduplicationSet.remove(sub)
+                }
                 .subscribe()
         }