diff --git a/spring-integration-jdbc/src/main/java/org/springframework/integration/jdbc/lock/JdbcLockRegistry.java b/spring-integration-jdbc/src/main/java/org/springframework/integration/jdbc/lock/JdbcLockRegistry.java index 215f89875c..0d20200341 100644 --- a/spring-integration-jdbc/src/main/java/org/springframework/integration/jdbc/lock/JdbcLockRegistry.java +++ b/spring-integration-jdbc/src/main/java/org/springframework/integration/jdbc/lock/JdbcLockRegistry.java @@ -55,6 +55,7 @@ import org.springframework.util.Assert; * @author Fran Aranda * @author Unseok Kim * @author Christian Tzolov + * @author Myeonghyeon Lee * * @since 4.3 */ @@ -326,7 +327,7 @@ public class JdbcLockRegistry implements ExpirableLockRegistry, RenewableLockReg } public boolean isAcquiredInThisProcess() { - return this.mutex.isAcquired(this.path); + return delegate.isLocked(); } public boolean renew() { 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 31150b74b4..d0fa41ba26 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 Christian Tzolov * @author Eddie Cho + * @author Myeonghyeon Lee * * @since 4.0 * @@ -514,8 +515,7 @@ public final class RedisLockRegistry implements ExpirableLockRegistry, Disposabl } public final boolean isAcquiredInThisProcess() { - return RedisLockRegistry.this.clientId.equals( - RedisLockRegistry.this.redisTemplate.boundValueOps(this.lockKey).get()); + return this.localLock.isLocked(); } @Override