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 f4f01af77a..e5f9b08a71 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 @@ -1,5 +1,5 @@ /* - * Copyright 2016-2022 the original author or authors. + * Copyright 2016-2023 the original author or authors. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. @@ -54,6 +54,7 @@ import org.springframework.util.Assert; * @author Olivier Hubaut * @author Fran Aranda * @author Unseok Kim + * @author Myeonghyeon Lee * * @since 4.3 */ @@ -310,7 +311,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 df2fb6e209..e23d4dd10e 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 @@ -83,6 +83,7 @@ import org.springframework.util.ReflectionUtils; * @author Unseok Kim * @author Anton Gabov * @author Eddie Cho + * @author Myeonghyeon Lee * * @since 4.0 * @@ -502,8 +503,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