This is an automated email from the ASF dual-hosted git repository. randgalt pushed a commit to branch curator-v2-recipe in repository https://gitbox.apache.org/repos/asf/curator.git
commit 56b011200cdb59cdfb2174393f0387ce85f2f64c Author: randgalt <[email protected]> AuthorDate: Sat Nov 2 11:40:44 2019 -0500 wip - new module that will be used to support features in ZK 3.6+ while maintaining background compatability with previous versions of ZK in the other modules. At some point in the future, this can be merged into the main modules and then removed --- .../java/org/apache/curator/framework/api/AddWatchBuilder2.java | 2 +- .../src/test/java/org/apache/curator/v2/TestFrameworkV2.java | 7 ++++--- 2 files changed, 5 insertions(+), 4 deletions(-) diff --git a/curator-v2/src/main/java/org/apache/curator/framework/api/AddWatchBuilder2.java b/curator-v2/src/main/java/org/apache/curator/framework/api/AddWatchBuilder2.java index 9114c00..92b3107 100644 --- a/curator-v2/src/main/java/org/apache/curator/framework/api/AddWatchBuilder2.java +++ b/curator-v2/src/main/java/org/apache/curator/framework/api/AddWatchBuilder2.java @@ -24,4 +24,4 @@ public interface AddWatchBuilder2 extends AddWatchable<Pathable<Void>>, Pathable<Void> { -} \ No newline at end of file +} diff --git a/curator-v2/src/test/java/org/apache/curator/v2/TestFrameworkV2.java b/curator-v2/src/test/java/org/apache/curator/v2/TestFrameworkV2.java index f939e1c..511658b 100644 --- a/curator-v2/src/test/java/org/apache/curator/v2/TestFrameworkV2.java +++ b/curator-v2/src/test/java/org/apache/curator/v2/TestFrameworkV2.java @@ -16,6 +16,7 @@ * specific language governing permissions and limitations * under the License. */ + package org.apache.curator.v2; import org.apache.curator.framework.CuratorFrameworkFactory; @@ -33,11 +34,10 @@ import static org.apache.curator.v2.CuratorFrameworkV2.wrap; public class TestFrameworkV2 extends CuratorTestBase { - @Test public void testPersistentRecursiveWatch() throws Exception { - try ( CuratorFrameworkV2 client = wrap(CuratorFrameworkFactory.newClient(server.getConnectString(), new RetryOneTime(1))) ) + try (CuratorFrameworkV2 client = wrap(CuratorFrameworkFactory.newClient(server.getConnectString(), new RetryOneTime(1)))) { client.start(); client.blockUntilConnected(); @@ -55,6 +55,7 @@ public class TestFrameworkV2 extends CuratorTestBase Assert.assertTrue(timing.awaitLatch(latch)); } } + @Test public void testPersistentRecursiveDefaultWatch() throws Exception { @@ -66,7 +67,7 @@ public class TestFrameworkV2 extends CuratorTestBase }; return new ZooKeeper(connectString, sessionTimeout, actualWatcher); }; - try (CuratorFrameworkV2 client = wrap(CuratorFrameworkFactory.builder().connectString(server.getConnectString()).retryPolicy(new RetryOneTime(1)).zookeeperFactory(zookeeperFactory).build()) ) + try (CuratorFrameworkV2 client = wrap(CuratorFrameworkFactory.builder().connectString(server.getConnectString()).retryPolicy(new RetryOneTime(1)).zookeeperFactory(zookeeperFactory).build())) { client.start(); client.blockUntilConnected();
