aboutsummaryrefslogtreecommitdiffstats
path: root/zkfacade
diff options
context:
space:
mode:
authorHarald Musum <musum@yahoo-inc.com>2016-11-02 09:53:24 +0100
committerHarald Musum <musum@yahoo-inc.com>2016-11-02 09:53:24 +0100
commit5a0ec04187543b9b064a43e707c5832b84d1d71d (patch)
treebe1ef2afd9699e14a839f5550fd17866ad64f359 /zkfacade
parent28e0cb5324d154fc0eeada4823361291b2fa31d5 (diff)
Add back unintentionally removed code
Diffstat (limited to 'zkfacade')
-rw-r--r--zkfacade/src/main/java/com/yahoo/vespa/curator/mock/MockCurator.java9
1 files changed, 9 insertions, 0 deletions
diff --git a/zkfacade/src/main/java/com/yahoo/vespa/curator/mock/MockCurator.java b/zkfacade/src/main/java/com/yahoo/vespa/curator/mock/MockCurator.java
index c7a24c14a4d..80f5a120364 100644
--- a/zkfacade/src/main/java/com/yahoo/vespa/curator/mock/MockCurator.java
+++ b/zkfacade/src/main/java/com/yahoo/vespa/curator/mock/MockCurator.java
@@ -73,6 +73,7 @@ public class MockCurator extends Curator {
private boolean shouldTimeoutOnEnter = false;
private int monotonicallyIncreasingNumber = 0;
private final boolean stableOrdering;
+ private String connectionSpec = "";
/** The file system used by this mock to store zookeeper files and directories */
private final MemoryFileSystem fileSystem = new MemoryFileSystem();
@@ -116,6 +117,14 @@ public class MockCurator extends Curator {
return Optional.ofNullable(atomicCounters.get(path));
}
+ /**
+ * Assigns the connection string, which must be on the form host1:port,host2:port ...
+ */
+ public void setConnectionSpec(String connectionSpec) { this.connectionSpec = connectionSpec; }
+
+ @Override
+ public String connectionSpec() { return connectionSpec; }
+
// ----- Start of adaptor methods from Curator to the mock file system -----
/** Creates a node below the given directory root */