diff options
author | Harald Musum <musum@yahoo-inc.com> | 2016-11-02 09:53:24 +0100 |
---|---|---|
committer | Harald Musum <musum@yahoo-inc.com> | 2016-11-02 09:53:24 +0100 |
commit | 5a0ec04187543b9b064a43e707c5832b84d1d71d (patch) | |
tree | be1ef2afd9699e14a839f5550fd17866ad64f359 /zkfacade | |
parent | 28e0cb5324d154fc0eeada4823361291b2fa31d5 (diff) |
Add back unintentionally removed code
Diffstat (limited to 'zkfacade')
-rw-r--r-- | zkfacade/src/main/java/com/yahoo/vespa/curator/mock/MockCurator.java | 9 |
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 */ |