From c909c5e7f91c7596bacec6816368224253ba7287 Mon Sep 17 00:00:00 2001 From: mikereiche Date: Fri, 17 Feb 2023 15:14:17 -0800 Subject: [PATCH] Add test file missed in #1661. Closes #1674. --- .../data/couchbase/util/UnmanagedTestCluster.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) 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;