From f3f347fd4f42a1c9f2513684504ee559af9d40a8 Mon Sep 17 00:00:00 2001 From: vladimir-bukhtoyarov Date: Wed, 20 Mar 2024 23:20:44 +0300 Subject: [PATCH] fix test --- .../MySQLSelectForUpdateLockBasedTransactionTest.java | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) 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); + } ) ); }