use standard test retry
Project: http://git-wip-us.apache.org/repos/asf/curator/repo Commit: http://git-wip-us.apache.org/repos/asf/curator/commit/ab6ad24e Tree: http://git-wip-us.apache.org/repos/asf/curator/tree/ab6ad24e Diff: http://git-wip-us.apache.org/repos/asf/curator/diff/ab6ad24e Branch: refs/heads/master Commit: ab6ad24ef368da6921c2aedcb866f4f41ee06d8a Parents: 9a487e2 Author: randgalt <randg...@apache.org> Authored: Sun Jan 4 19:38:18 2015 -0500 Committer: randgalt <randg...@apache.org> Committed: Sun Jan 4 19:38:18 2015 -0500 ---------------------------------------------------------------------- .../org/apache/curator/x/discovery/TestServiceDiscovery.java | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/curator/blob/ab6ad24e/curator-x-discovery/src/test/java/org/apache/curator/x/discovery/TestServiceDiscovery.java ---------------------------------------------------------------------- diff --git a/curator-x-discovery/src/test/java/org/apache/curator/x/discovery/TestServiceDiscovery.java b/curator-x-discovery/src/test/java/org/apache/curator/x/discovery/TestServiceDiscovery.java index a9a8896..4188a70 100644 --- a/curator-x-discovery/src/test/java/org/apache/curator/x/discovery/TestServiceDiscovery.java +++ b/curator-x-discovery/src/test/java/org/apache/curator/x/discovery/TestServiceDiscovery.java @@ -20,14 +20,13 @@ package org.apache.curator.x.discovery; import com.google.common.collect.Lists; import com.google.common.collect.Sets; -import org.apache.curator.test.BaseClassForTests; -import org.apache.curator.utils.CloseableUtils; import org.apache.curator.framework.CuratorFramework; import org.apache.curator.framework.CuratorFrameworkFactory; -import org.apache.curator.retry.RetryNTimes; import org.apache.curator.retry.RetryOneTime; +import org.apache.curator.test.BaseClassForTests; import org.apache.curator.test.KillSession; import org.apache.curator.test.Timing; +import org.apache.curator.utils.CloseableUtils; import org.apache.curator.x.discovery.details.JsonInstanceSerializer; import org.apache.curator.x.discovery.details.ServiceDiscoveryImpl; import org.testng.Assert; @@ -272,7 +271,7 @@ public class TestServiceDiscovery extends BaseClassForTests List<Closeable> closeables = Lists.newArrayList(); try { - CuratorFramework client = CuratorFrameworkFactory.newClient(server.getConnectString(), new RetryNTimes(0,1000)); + CuratorFramework client = CuratorFrameworkFactory.newClient(server.getConnectString(), new RetryOneTime(1)); closeables.add(client); client.start();