Make JdbcLockRegistry.pathFor protected to allow overriding

Signed-off-by: Steffen Nießing <[email protected]>

Author: zUniQueX

spring-integration-jdbc/src/main/java/org/springframework/integration/jdbc/lock/JdbcLockRegistry.java

@@ -151,7 +151,7 @@ public DistributedLock obtain(Object lockKey) {
 		}
 	}
 
-	private String pathFor(String input) {
+	protected String pathFor(String input) {
 		return UUIDConverter.getUUID(input).toString();
 	}
 

spring-integration-jdbc/src/test/java/org/springframework/integration/jdbc/lock/JdbcLockRegistryTests.java

@@ -613,6 +613,26 @@ void testUnlockAfterLockStatusHasBeenExpiredAndDeleted() throws Exception {
 				.isThrownBy(lock::unlock);
 	}
 
+	@Test
+	void testPathForCanBeOverridden() {
+		DefaultLockRepository client = new DefaultLockRepository(dataSource);
+		client.setApplicationContext(this.context);
+		client.afterPropertiesSet();
+		client.afterSingletonsInstantiated();
+		JdbcLockRegistry registry = new JdbcLockRegistry(client) {
+			@Override
+			protected String pathFor(String input) {
+				return input;
+			}
+		};
+
+		final String lockKey = "foo";
+		Lock lock = registry.obtain(lockKey);
+		String lockPath = TestUtils.getPropertyValue(lock, "path", String.class);
+
+		assertThat(lockPath).isEqualTo(lockKey);
+	}
+
 	@SuppressWarnings("unchecked")
 	private static Map<String, Lock> getRegistryLocks(JdbcLockRegistry registry) {
 		return TestUtils.getPropertyValue(registry, "locks", Map.class);