From ba0a14676fac200232ecb658966eb7bfa9b3138e Mon Sep 17 00:00:00 2001 From: Michael Reiche <48999328+mikereiche@users.noreply.github.com> Date: Fri, 17 Feb 2023 15:15:23 -0800 Subject: [PATCH] Add test file missed in #1661. (#1675) 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 ea1686fc..78e37875 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 @@ package org.springframework.data.couchbase.util; 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;