diff options
Diffstat (limited to 'zkfacade/src/main/java/com/yahoo/vespa/curator/mock/MockCuratorFramework.java')
-rw-r--r-- | zkfacade/src/main/java/com/yahoo/vespa/curator/mock/MockCuratorFramework.java | 17 |
1 files changed, 15 insertions, 2 deletions
diff --git a/zkfacade/src/main/java/com/yahoo/vespa/curator/mock/MockCuratorFramework.java b/zkfacade/src/main/java/com/yahoo/vespa/curator/mock/MockCuratorFramework.java index 401c6e90cd8..f447ca155a0 100644 --- a/zkfacade/src/main/java/com/yahoo/vespa/curator/mock/MockCuratorFramework.java +++ b/zkfacade/src/main/java/com/yahoo/vespa/curator/mock/MockCuratorFramework.java @@ -222,7 +222,20 @@ public class MockCuratorFramework implements CuratorFramework { public RemoveWatchesBuilder watches() { throw new UnsupportedOperationException("Not implemented in MockCurator"); } @Override - public WatcherRemoveCuratorFramework newWatcherRemoveCuratorFramework() { throw new UnsupportedOperationException("Not implemented in MockCurator"); } + public WatcherRemoveCuratorFramework newWatcherRemoveCuratorFramework() { + class MockWatcherRemoveCuratorFramework extends MockCuratorFramework implements WatcherRemoveCuratorFramework { + + public MockWatcherRemoveCuratorFramework(boolean stableOrdering, boolean shouldTimeoutOnEnter) { + super(stableOrdering, shouldTimeoutOnEnter); + } + + @Override + public void removeWatchers() { + + } + } + return new MockWatcherRemoveCuratorFramework(true, true); + } @Override public ConnectionStateErrorPolicy getConnectionStateErrorPolicy() { throw new UnsupportedOperationException("Not implemented in MockCurator"); } @@ -1176,7 +1189,7 @@ public class MockCuratorFramework implements CuratorFramework { } /** Allows addition of directoryListeners which are never called */ - private class MockListenable<T> implements Listenable<T> { + private static class MockListenable<T> implements Listenable<T> { @Override public void addListener(T t) { |