diff --git a/src/test/java/org/springframework/data/couchbase/util/UnmanagedTestCluster.java b/src/test/java/org/springframework/data/couchbase/util/UnmanagedTestCluster.java index ea1686fc3..78e378756 100644 --- a/src/test/java/org/springframework/data/couchbase/util/UnmanagedTestCluster.java +++ b/src/test/java/org/springframework/data/couchbase/util/UnmanagedTestCluster.java @@ -17,6 +17,7 @@ import static java.nio.charset.StandardCharsets.UTF_8; +import com.couchbase.client.core.util.ConnectionString; import okhttp3.Credentials; import okhttp3.FormBody; import okhttp3.OkHttpClient; @@ -61,7 +62,7 @@ public class UnmanagedTestCluster extends TestCluster { seedPort = 18091; EventBus eventBus = new SimpleEventBus(false); eventBus.subscribe(event -> System.err.println("Event: " + event)); - Collection seedNodes = ConnectionStringUtil.seedNodesFromConnectionString("couchbases://" + seed, true, + Collection seedNodes = ConnectionStringUtil.seedNodesFromConnectionString(ConnectionString.create("couchbases://" + seed), true, true, eventBus); hostname = seedNodes.stream().filter((node) -> node.kvPort() != null).findFirst().get().address().toString(); seedHost = "couchbases://" + seed;