fix test

bucket4j · Mar 20, 2024 · f3f347f · f3f347f
1 parent 06a5019
commit f3f347f
Showing 1 changed file with 7 additions and 4 deletions.
diff --git a/.../src/test/java/io/github/bucket4j/mysql/MySQLSelectForUpdateLockBasedTransactionTest.java b/.../src/test/java/io/github/bucket4j/mysql/MySQLSelectForUpdateLockBasedTransactionTest.java
@@ -39,15 +39,18 @@ public static void initializeInstance() throws SQLException {
                 statement.execute(query);
             }
         }
-        SQLProxyConfiguration<Long> 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<Long> configuration = SQLProxyConfiguration.builder()
+                            .withTableSettings(tableSettings)
+                            .withClientSideConfig(clientConfig)
+                            .build(dataSource);
+                    return new MySQLSelectForUpdateBasedProxyManager<>(configuration);
+                }
             )
         );
     }