format

Author: ggivo

pom.xml

@@ -340,6 +340,7 @@
 						<include>src/main/java/redis/clients/jedis/annots/*.java</include>
 						<include>src/main/java/redis/clients/jedis/mcf/*.java</include>
 						<include>src/test/java/redis/clients/jedis/failover/*.java</include>
+						<include>src/test/java/redis/clients/jedis/mcf/*.java</include>
 						<include>src/test/java/redis/clients/jedis/misc/AutomaticFailoverTest.java</include>
 						<include>src/main/java/redis/clients/jedis/providers/MultiClusterPooledConnectionProvider.java</include>
 						<include>src/main/java/redis/clients/jedis/MultiClusterClientConfig.java</include>

src/test/java/redis/clients/jedis/mcf/HealthCheckIntegrationTest.java

@@ -93,7 +93,7 @@ private MultiClusterPooledConnectionProvider getMCCF(MultiClusterClientConfig.St
         Function<ClusterConfig.Builder, ClusterConfig.Builder> modifier = builder -> strategySupplier == null
             ? builder.healthCheckEnabled(false)
             : builder.healthCheckStrategySupplier(strategySupplier);
-            
+
         List<ClusterConfig> clusterConfigs = Arrays
             .stream(new EndpointConfig[] { endpoint1 }).map(e -> modifier
                 .apply(MultiClusterClientConfig.ClusterConfig.builder(e.getHostAndPort(), clientConfig)).build())

src/test/java/redis/clients/jedis/mcf/HealthCheckTest.java

@@ -275,14 +275,11 @@ void testEchoStrategyDefaultSupplier() {
     void testNewFieldLocations() {
         // Test new field locations in ClusterConfig and MultiClusterClientConfig
         MultiClusterClientConfig.ClusterConfig clusterConfig = MultiClusterClientConfig.ClusterConfig
-            .builder(testEndpoint, testConfig)
-            .weight(2.5f)
-            .build();
+            .builder(testEndpoint, testConfig).weight(2.5f).build();
 
-        MultiClusterClientConfig multiConfig = new MultiClusterClientConfig.Builder(new MultiClusterClientConfig.ClusterConfig[]{clusterConfig})
-            .retryOnFailover(true)
-            .failbackSupported(false)
-            .build();
+        MultiClusterClientConfig multiConfig = new MultiClusterClientConfig.Builder(
+            new MultiClusterClientConfig.ClusterConfig[] { clusterConfig }).retryOnFailover(true)
+                .failbackSupported(false).build();
 
         assertEquals(2.5f, clusterConfig.getWeight());
         assertTrue(multiConfig.isRetryOnFailover());
@@ -293,15 +290,15 @@ void testNewFieldLocations() {
     void testDefaultValues() {
         // Test default values in ClusterConfig
         MultiClusterClientConfig.ClusterConfig clusterConfig = MultiClusterClientConfig.ClusterConfig
-            .builder(testEndpoint, testConfig)
-            .build();
+            .builder(testEndpoint, testConfig).build();
 
         assertEquals(1.0f, clusterConfig.getWeight()); // Default weight
-        assertEquals(EchoStrategy.DEFAULT, clusterConfig.getHealthCheckStrategySupplier()); // Default is null (no health check)
+        assertEquals(EchoStrategy.DEFAULT, clusterConfig.getHealthCheckStrategySupplier()); // Default is null (no
+                                                                                            // health check)
 
         // Test default values in MultiClusterClientConfig
-        MultiClusterClientConfig multiConfig = new MultiClusterClientConfig.Builder(new MultiClusterClientConfig.ClusterConfig[]{clusterConfig})
-            .build();
+        MultiClusterClientConfig multiConfig = new MultiClusterClientConfig.Builder(
+            new MultiClusterClientConfig.ClusterConfig[] { clusterConfig }).build();
 
         assertFalse(multiConfig.isRetryOnFailover()); // Default is false
         assertTrue(multiConfig.isFailbackSupported()); // Default is true
@@ -314,9 +311,7 @@ void testClusterConfigWithHealthCheckStrategy() {
         MultiClusterClientConfig.StrategySupplier supplier = (hostAndPort, jedisClientConfig) -> customStrategy;
 
         MultiClusterClientConfig.ClusterConfig clusterConfig = MultiClusterClientConfig.ClusterConfig
-            .builder(testEndpoint, testConfig)
-            .healthCheckStrategySupplier(supplier)
-            .build();
+            .builder(testEndpoint, testConfig).healthCheckStrategySupplier(supplier).build();
 
         assertNotNull(clusterConfig.getHealthCheckStrategySupplier());
         HealthCheckStrategy result = clusterConfig.getHealthCheckStrategySupplier().get(testEndpoint, testConfig);
@@ -330,9 +325,7 @@ void testClusterConfigWithStrategySupplier() {
         };
 
         MultiClusterClientConfig.ClusterConfig clusterConfig = MultiClusterClientConfig.ClusterConfig
-            .builder(testEndpoint, testConfig)
-            .healthCheckStrategySupplier(customSupplier)
-            .build();
+            .builder(testEndpoint, testConfig).healthCheckStrategySupplier(customSupplier).build();
 
         assertEquals(customSupplier, clusterConfig.getHealthCheckStrategySupplier());
     }
@@ -344,9 +337,7 @@ void testClusterConfigWithEchoStrategy() {
         };
 
         MultiClusterClientConfig.ClusterConfig clusterConfig = MultiClusterClientConfig.ClusterConfig
-            .builder(testEndpoint, testConfig)
-            .healthCheckStrategySupplier(echoSupplier)
-            .build();
+            .builder(testEndpoint, testConfig).healthCheckStrategySupplier(echoSupplier).build();
 
         MultiClusterClientConfig.StrategySupplier supplier = clusterConfig.getHealthCheckStrategySupplier();
         assertNotNull(supplier);
@@ -356,8 +347,7 @@ void testClusterConfigWithEchoStrategy() {
     @Test
     void testClusterConfigWithDefaultHealthCheck() {
         MultiClusterClientConfig.ClusterConfig clusterConfig = MultiClusterClientConfig.ClusterConfig
-            .builder(testEndpoint, testConfig)
-            .build(); // Should use default EchoStrategy
+            .builder(testEndpoint, testConfig).build(); // Should use default EchoStrategy
 
         assertNotNull(clusterConfig.getHealthCheckStrategySupplier());
         assertEquals(EchoStrategy.DEFAULT, clusterConfig.getHealthCheckStrategySupplier());
@@ -366,19 +356,15 @@ void testClusterConfigWithDefaultHealthCheck() {
     @Test
     void testClusterConfigWithDisabledHealthCheck() {
         MultiClusterClientConfig.ClusterConfig clusterConfig = MultiClusterClientConfig.ClusterConfig
-            .builder(testEndpoint, testConfig)
-            .healthCheckEnabled(false)
-            .build();
+            .builder(testEndpoint, testConfig).healthCheckEnabled(false).build();
 
         assertNull(clusterConfig.getHealthCheckStrategySupplier());
     }
 
     @Test
     void testClusterConfigHealthCheckEnabledExplicitly() {
         MultiClusterClientConfig.ClusterConfig clusterConfig = MultiClusterClientConfig.ClusterConfig
-            .builder(testEndpoint, testConfig)
-            .healthCheckEnabled(true)
-            .build();
+            .builder(testEndpoint, testConfig).healthCheckEnabled(true).build();
 
         assertNotNull(clusterConfig.getHealthCheckStrategySupplier());
         assertEquals(EchoStrategy.DEFAULT, clusterConfig.getHealthCheckStrategySupplier());
@@ -391,6 +377,7 @@ void testHealthCheckRecoversAfterException() throws InterruptedException {
         // Create a mock strategy that alternates between healthy and throwing an exception
         HealthCheckStrategy alternatingStrategy = new HealthCheckStrategy() {
             volatile boolean isHealthy = true;
+
             @Override
             public int getInterval() {
                 return 1;