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 0d20200341..cae7d922d7 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 @@ -68,7 +68,7 @@ public class JdbcLockRegistry implements ExpirableLockRegistry, RenewableLockReg private final Lock lock = new ReentrantLock(); private final Map locks = - new LinkedHashMap(16, 0.75F, true) { + new LinkedHashMap<>(16, 0.75F, true) { @Override protected boolean removeEldestEntry(Entry eldest) { @@ -327,7 +327,7 @@ public class JdbcLockRegistry implements ExpirableLockRegistry, RenewableLockReg } public boolean isAcquiredInThisProcess() { - return delegate.isLocked(); + return this.delegate.isLocked(); } public boolean renew() {