Repository: incubator-twill Updated Branches: refs/heads/feature/TWILL-153 8eaefad2b -> d956f2a90
WIP5 Project: http://git-wip-us.apache.org/repos/asf/incubator-twill/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-twill/commit/d956f2a9 Tree: http://git-wip-us.apache.org/repos/asf/incubator-twill/tree/d956f2a9 Diff: http://git-wip-us.apache.org/repos/asf/incubator-twill/diff/d956f2a9 Branch: refs/heads/feature/TWILL-153 Commit: d956f2a906d33978ff91458f8663a2a31be9d7f9 Parents: 8eaefad Author: Terence Yim <[email protected]> Authored: Wed Sep 23 01:00:24 2015 -0700 Committer: Terence Yim <[email protected]> Committed: Wed Sep 23 01:00:24 2015 -0700 ---------------------------------------------------------------------- .../src/test/java/org/apache/twill/zookeeper/ZKClientTest.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-twill/blob/d956f2a9/twill-zookeeper/src/test/java/org/apache/twill/zookeeper/ZKClientTest.java ---------------------------------------------------------------------- diff --git a/twill-zookeeper/src/test/java/org/apache/twill/zookeeper/ZKClientTest.java b/twill-zookeeper/src/test/java/org/apache/twill/zookeeper/ZKClientTest.java index d6e4c36..7b0ccae 100644 --- a/twill-zookeeper/src/test/java/org/apache/twill/zookeeper/ZKClientTest.java +++ b/twill-zookeeper/src/test/java/org/apache/twill/zookeeper/ZKClientTest.java @@ -193,11 +193,12 @@ public class ZKClientTest { final BlockingQueue<Watcher.Event.EventType> events = new LinkedBlockingQueue<Watcher.Event.EventType>(); client.exists("/expireRewatch", new Watcher() { @Override - public void process(WatchedEvent event) { + public void process(final WatchedEvent event) { Futures.addCallback(client.exists("/expireRewatch", this), new FutureCallback<Stat>() { @Override public void onSuccess(Stat result) { LOG.info("re exists call succeeded"); + events.add(event.getType()); } @Override @@ -205,7 +206,6 @@ public class ZKClientTest { LOG.info("re exists call failed", t); } }); - events.add(event.getType()); } });
