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 2f54687124..18a15ae19a 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 @@ -52,11 +52,13 @@ import org.springframework.util.Assert; */ public class JdbcLockRegistry implements ExpirableLockRegistry { + private static final int DEFAULT_IDLE = 100; + private final Map locks = new ConcurrentHashMap<>(); private final LockRepository client; - private Duration idleBetweenTries = Duration.ofMillis(100); + private Duration idleBetweenTries = Duration.ofMillis(DEFAULT_IDLE); public JdbcLockRegistry(LockRepository client) { this.client = client;