diff --git a/netty-socketio-core/src/test/java/com/socketio4j/socketio/integration/DistributedClusterIntegrationSupport.java b/netty-socketio-core/src/test/java/com/socketio4j/socketio/integration/DistributedClusterIntegrationSupport.java
index 647635a8..ca97445a 100644
--- a/netty-socketio-core/src/test/java/com/socketio4j/socketio/integration/DistributedClusterIntegrationSupport.java
+++ b/netty-socketio-core/src/test/java/com/socketio4j/socketio/integration/DistributedClusterIntegrationSupport.java
@@ -16,6 +16,7 @@
  */
 package com.socketio4j.socketio.integration;
 
+import java.net.ServerSocket;
 import java.util.Arrays;
 import java.util.List;
 import java.util.Map;
@@ -35,7 +36,11 @@ final class DistributedClusterIntegrationSupport {
 
     private DistributedClusterIntegrationSupport() {
     }
-
+    static int findAvailablePort() throws Exception {
+        try (ServerSocket socket = new ServerSocket(0)) {
+            return socket.getLocalPort();
+        }
+    }
     static void applyReuseListenAddress(Configuration configuration) {
         configuration.getSocketConfig().setReuseAddress(true);
     }
diff --git a/netty-socketio-core/src/test/java/com/socketio4j/socketio/integration/DistributedRedissonClusterSuite.java b/netty-socketio-core/src/test/java/com/socketio4j/socketio/integration/DistributedRedissonClusterSuite.java
index 3b486c0f..7c01d5e9 100644
--- a/netty-socketio-core/src/test/java/com/socketio4j/socketio/integration/DistributedRedissonClusterSuite.java
+++ b/netty-socketio-core/src/test/java/com/socketio4j/socketio/integration/DistributedRedissonClusterSuite.java
@@ -16,8 +16,6 @@
  */
 package com.socketio4j.socketio.integration;
 
-import java.net.ServerSocket;
-
 import org.junit.jupiter.api.AfterAll;
 import org.junit.jupiter.api.BeforeAll;
 import org.junit.jupiter.api.Nested;
@@ -34,6 +32,8 @@
 import com.socketio4j.socketio.store.redis_reliable.RedisPubSubReliableEventStore;
 import com.socketio4j.socketio.store.redis_stream.RedisStreamEventStore;
 
+import static com.socketio4j.socketio.integration.DistributedClusterIntegrationSupport.findAvailablePort;
+
 /**
  * Runs {@link DistributedCommonTest} against all Redisson-backed cluster variants while sharing
  * one Redis Testcontainer.
@@ -43,12 +43,6 @@ public class DistributedRedissonClusterSuite {
     @SuppressWarnings("resource")
     static final CustomizedRedisContainer REDIS = new CustomizedRedisContainer().withReuse(false);
 
-    private static int findAvailablePort() throws Exception {
-        try (ServerSocket socket = new ServerSocket(0)) {
-            return socket.getLocalPort();
-        }
-    }
-
     @BeforeAll
     static void startRedis() {
         REDIS.start();