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 e5f9b08a71..46b52f5c96 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 @@ -65,7 +65,7 @@ public class JdbcLockRegistry implements ExpirableLockRegistry, RenewableLockReg private static final int DEFAULT_CAPACITY = 100_000; private final Map locks = - new LinkedHashMap(16, 0.75F, true) { + new LinkedHashMap<>(16, 0.75F, true) { @Override protected boolean removeEldestEntry(Entry eldest) { @@ -311,7 +311,7 @@ public class JdbcLockRegistry implements ExpirableLockRegistry, RenewableLockReg } public boolean isAcquiredInThisProcess() { - return delegate.isLocked(); + return this.delegate.isLocked(); } public boolean renew() {