diff --git a/bucket4j-mysql/src/test/java/io/github/bucket4j/mysql/MySQLSelectForUpdateLockBasedTransactionTest.java b/bucket4j-mysql/src/test/java/io/github/bucket4j/mysql/MySQLSelectForUpdateLockBasedTransactionTest.java index 0c14c1ed..41c7afdf 100644 --- a/bucket4j-mysql/src/test/java/io/github/bucket4j/mysql/MySQLSelectForUpdateLockBasedTransactionTest.java +++ b/bucket4j-mysql/src/test/java/io/github/bucket4j/mysql/MySQLSelectForUpdateLockBasedTransactionTest.java @@ -39,15 +39,18 @@ public static void initializeInstance() throws SQLException { statement.execute(query); } } - SQLProxyConfiguration configuration = SQLProxyConfiguration.builder() - .withTableSettings(tableSettings) - .build(dataSource); specs = Arrays.asList( new ProxyManagerSpec<>( "MySQLSelectForUpdateBasedProxyManager", () -> ThreadLocalRandom.current().nextLong(1_000_000_000), - clientConfig -> new MySQLSelectForUpdateBasedProxyManager<>(configuration) + clientConfig -> { + SQLProxyConfiguration configuration = SQLProxyConfiguration.builder() + .withTableSettings(tableSettings) + .withClientSideConfig(clientConfig) + .build(dataSource); + return new MySQLSelectForUpdateBasedProxyManager<>(configuration); + } ) ); }