From a04e744db6b04c5e8ac6fd73f6d5d50cc6cf3f09 Mon Sep 17 00:00:00 2001 From: Johan Haleby Date: Sat, 15 Feb 2025 10:56:17 +0100 Subject: [PATCH] Improved logging --- .../MongoLeaseCompetingConsumerStrategySupport.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/subscription/mongodb/common/blocking/competing-consumer-strategy/src/main/java/org/occurrent/subscription/mongodb/blocking/ccs/internal/MongoLeaseCompetingConsumerStrategySupport.java b/subscription/mongodb/common/blocking/competing-consumer-strategy/src/main/java/org/occurrent/subscription/mongodb/blocking/ccs/internal/MongoLeaseCompetingConsumerStrategySupport.java index bf5529932..c2872cbce 100644 --- a/subscription/mongodb/common/blocking/competing-consumer-strategy/src/main/java/org/occurrent/subscription/mongodb/blocking/ccs/internal/MongoLeaseCompetingConsumerStrategySupport.java +++ b/subscription/mongodb/common/blocking/competing-consumer-strategy/src/main/java/org/occurrent/subscription/mongodb/blocking/ccs/internal/MongoLeaseCompetingConsumerStrategySupport.java @@ -99,13 +99,13 @@ public boolean registerCompetingConsumer(MongoCollection 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;