Repository: curator Updated Branches: refs/heads/master 6d36a4793 -> b63559663
Add a simple TreeCacheExample Project: http://git-wip-us.apache.org/repos/asf/curator/repo Commit: http://git-wip-us.apache.org/repos/asf/curator/commit/b6355966 Tree: http://git-wip-us.apache.org/repos/asf/curator/tree/b6355966 Diff: http://git-wip-us.apache.org/repos/asf/curator/diff/b6355966 Branch: refs/heads/master Commit: b6355966347b91d96af6fdbcb0af0407f1afdd46 Parents: 6d36a47 Author: Scott Blum <[email protected]> Authored: Wed Dec 20 18:36:07 2017 -0500 Committer: Scott Blum <[email protected]> Committed: Wed Dec 20 18:36:07 2017 -0500 ---------------------------------------------------------------------- .../src/main/java/cache/TreeCacheExample.java | 57 ++++++++++++++++++++ 1 file changed, 57 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/curator/blob/b6355966/curator-examples/src/main/java/cache/TreeCacheExample.java ---------------------------------------------------------------------- diff --git a/curator-examples/src/main/java/cache/TreeCacheExample.java b/curator-examples/src/main/java/cache/TreeCacheExample.java new file mode 100644 index 0000000..73421f8 --- /dev/null +++ b/curator-examples/src/main/java/cache/TreeCacheExample.java @@ -0,0 +1,57 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ +package cache; + +import framework.CreateClientExamples; +import org.apache.curator.framework.CuratorFramework; +import org.apache.curator.framework.recipes.cache.TreeCache; +import java.io.BufferedReader; +import java.io.InputStreamReader; + +public class TreeCacheExample +{ + public static void main(String[] args) throws Exception + { + CuratorFramework client = CreateClientExamples.createSimple("127.0.0.1:2181"); + client.getUnhandledErrorListenable().addListener((message, e) -> { + System.err.println("error=" + message); + e.printStackTrace(); + }); + client.getConnectionStateListenable().addListener((c, newState) -> { + System.out.println("state=" + newState); + }); + client.start(); + + TreeCache cache = TreeCache.newBuilder(client, "/").setCacheData(false).build(); + cache.getListenable().addListener((c, event) -> { + if ( event.getData() != null ) + { + System.out.println("type=" + event.getType() + " path=" + event.getData().getPath()); + } + else + { + System.out.println("type=" + event.getType()); + } + }); + cache.start(); + + BufferedReader in = new BufferedReader(new InputStreamReader(System.in)); + in.readLine(); + } +}
