diff --git a/spring-integration-redis/src/main/java/org/springframework/integration/redis/util/RedisLockRegistry.java b/spring-integration-redis/src/main/java/org/springframework/integration/redis/util/RedisLockRegistry.java index 713c2f17cf..df7ac58b46 100644 --- a/spring-integration-redis/src/main/java/org/springframework/integration/redis/util/RedisLockRegistry.java +++ b/spring-integration-redis/src/main/java/org/springframework/integration/redis/util/RedisLockRegistry.java @@ -84,6 +84,7 @@ import org.springframework.util.ReflectionUtils; * @author Anton Gabov * @author Eddie Cho * @author Myeonghyeon Lee + * @author Roman Zabaluev * * @since 4.0 * @@ -421,11 +422,14 @@ public final class RedisLockRegistry implements ExpirableLockRegistry, Disposabl } private boolean tryRedisLock(long time) throws ExecutionException, InterruptedException { - final boolean result = tryRedisLockInner(time); - if (result) { + final boolean acquired = tryRedisLockInner(time); + if (acquired) { + if (LOGGER.isDebugEnabled()) { + LOGGER.debug("Acquired lock; " + this); + } this.lockedAt = System.currentTimeMillis(); } - return result; + return acquired; } protected final Boolean obtainLock() {