diff options
author | Harald Musum <musum@verizonmedia.com> | 2021-01-01 21:55:19 +0100 |
---|---|---|
committer | Harald Musum <musum@verizonmedia.com> | 2021-01-01 21:55:19 +0100 |
commit | ce949de73b8ee009740bc3e4f62954c82a9d6dfc (patch) | |
tree | ff2f403e0e6c690bc8e3b7b54dfab2647cf59d8e /zkfacade | |
parent | 9ab7a397bacbae98501137a349786d7461a8aa29 (diff) |
Fix newWatcherRemoveCuratorFramework()
Diffstat (limited to 'zkfacade')
-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) { |