import org.apache.curator.framework.CuratorFramework;

import org.apache.curator.framework.CuratorFrameworkFactory;

import org.apache.curator.framework.recipes.shared.SharedCount;

import org.apache.curator.framework.recipes.shared.SharedCountListener;

import org.apache.curator.framework.recipes.shared.SharedCountReader;

import org.apache.curator.framework.state.ConnectionState;

import org.apache.curator.retry.ExponentialBackoffRetry;

public class SharedCounterDemo {

    private static CuratorFramework client = CuratorFrameworkFactory.newClient("localhost:2181", new ExponentialBackoffRetry(3000, 2));

    private static String path = "/shared/counter/0001";

    private static SharedCount count = new SharedCount(client, path, 0);

    static {

        client.start();

    }

    public static void main(String[] args) throws Exception {

        count.start();

        count.addListener(new SharedCountListener() {

            @Override

            public void countHasChanged(SharedCountReader sharedCountReader, int i) throws Exception {

                System.out.println("count changed value is " + i);

            }

            @Override

            public void stateChanged(CuratorFramework curatorFramework, ConnectionState connectionState) {

                System.out.println("stateChanged isConnected: " + connectionState.isConnected());

            }

        });

        count.setCount(10);

        System.out.println("count: " + count.getCount());

        Thread.sleep(50000);

        client.close();

    }

}