Improved logging

johanhaleby · Feb 15, 2025 · a04e744 · a04e744
1 parent 82bf104
commit a04e744
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/...ubscription/mongodb/blocking/ccs/internal/MongoLeaseCompetingConsumerStrategySupport.java b/...ubscription/mongodb/blocking/ccs/internal/MongoLeaseCompetingConsumerStrategySupport.java
@@ -99,13 +99,13 @@ public boolean registerCompetingConsumer(MongoCollection<BsonDocument> collectio
         CompetingConsumer competingConsumer = new CompetingConsumer(subscriptionId, subscriberId);
         Status oldStatus = competingConsumers.get(competingConsumer);
         boolean acquired = MongoListenerLockService.acquireOrRefreshFor(collection, clock, retryStrategy, leaseTime, subscriptionId, subscriberId).isPresent();
-        logDebug("oldStatus={} acquired lock={} (subscriberId={}, subscriptionId={})", oldStatus, acquired, subscriberId, subscriptionId);
+        logDebug("registerCompetingConsumer: oldStatus={} acquired lock={} (subscriberId={}, subscriptionId={})", oldStatus, acquired, subscriberId, subscriptionId);
         competingConsumers.put(competingConsumer, acquired ? Status.LOCK_ACQUIRED : Status.LOCK_NOT_ACQUIRED);
         if (oldStatus != Status.LOCK_ACQUIRED && acquired) {
-            logDebug("Consumption granted (subscriberId={}, subscriptionId={})", subscriberId, subscriptionId);
+            logDebug("registerCompetingConsumer: Consumption granted (subscriberId={}, subscriptionId={})", subscriberId, subscriptionId);
             competingConsumerListeners.forEach(listener -> listener.onConsumeGranted(subscriptionId, subscriberId));
         } else if (oldStatus == Status.LOCK_ACQUIRED && !acquired) {
-            logDebug("Consumption prohibited (subscriberId={}, subscriptionId={})", subscriberId, subscriptionId);
+            logDebug("registerCompetingConsumer: Consumption prohibited (subscriberId={}, subscriptionId={})", subscriberId, subscriptionId);
             competingConsumerListeners.forEach(listener -> listener.onConsumeProhibited(subscriptionId, subscriberId));
         }
         return acquired;