curator-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From randg...@apache.org
Subject [1/3] git commit: Updated for changes in connection state logic
Date Thu, 06 Feb 2014 19:30:49 GMT
Updated Branches:
  refs/heads/master f5384e5be -> 1ecaef657


Updated for changes in connection state logic


Project: http://git-wip-us.apache.org/repos/asf/curator/repo
Commit: http://git-wip-us.apache.org/repos/asf/curator/commit/e55a98fc
Tree: http://git-wip-us.apache.org/repos/asf/curator/tree/e55a98fc
Diff: http://git-wip-us.apache.org/repos/asf/curator/diff/e55a98fc

Branch: refs/heads/master
Commit: e55a98fc66e363eaa981dcac5b60ee8bd88e5fc4
Parents: f5384e5
Author: randgalt <randgalt@apache.org>
Authored: Wed Feb 5 14:06:59 2014 -0500
Committer: randgalt <randgalt@apache.org>
Committed: Wed Feb 5 14:06:59 2014 -0500

----------------------------------------------------------------------
 .../java/org/apache/curator/framework/imps/TestNeverConnected.java | 2 ++
 1 file changed, 2 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/curator/blob/e55a98fc/curator-framework/src/test/java/org/apache/curator/framework/imps/TestNeverConnected.java
----------------------------------------------------------------------
diff --git a/curator-framework/src/test/java/org/apache/curator/framework/imps/TestNeverConnected.java
b/curator-framework/src/test/java/org/apache/curator/framework/imps/TestNeverConnected.java
index 6445d7b..ecfd8b4 100644
--- a/curator-framework/src/test/java/org/apache/curator/framework/imps/TestNeverConnected.java
+++ b/curator-framework/src/test/java/org/apache/curator/framework/imps/TestNeverConnected.java
@@ -58,6 +58,8 @@ public class TestNeverConnected
             client.create().inBackground().forPath("/");
 
             ConnectionState polled = queue.poll(timing.forWaiting().seconds(), TimeUnit.SECONDS);
+            Assert.assertEquals(polled, ConnectionState.SUSPENDED);
+            polled = queue.poll(timing.forWaiting().seconds(), TimeUnit.SECONDS);
             Assert.assertEquals(polled, ConnectionState.LOST);
         }
         finally


Mime
View raw message