Examples of org.apache.curator.framework.recipes.cache.TreeCache

Package org.apache.curator.framework.recipes.cache

Examples of org.apache.curator.framework.recipes.cache.TreeCache

org.apache.curator.framework.recipes.cache.TreeCache

A utility that attempts to keep all data from all children of a ZK path locally cached. This class will watch the ZK path, respond to update/create/delete events, pull down the data, etc. You can register a listener that will get notified when changes occur.

IMPORTANT - it's not possible to stay transactionally in sync. Users of this class must be prepared for false-positives and false-negatives. Additionally, always use the version number when updating data to avoid overwriting another process' change.

    }




    public void init() throws Exception {
        if (active.compareAndSet(false, true)) {
            treeCache = new TreeCache(curator, zooKeeperPath, true, false, true, treeCacheExecutor);
            treeCache.start(TreeCache.StartMode.NORMAL);
            treeCache.getListenable().addListener(treeListener);
            LOG.info("Started listening to ZK path " + zooKeeperPath);
        }
    }

View Full Code Here

    }




    public void init() throws Exception {
        if (active.compareAndSet(false, true)) {
            treeCache = new TreeCache(curator, zkPath, true, false, true, treeCacheExecutor);
            treeCache.start(TreeCache.StartMode.NORMAL);
            treeCache.getListenable().addListener(treeListener);
            LOG.info("Started a group listener for " + zkPath);
            for (TcpGateway gateway : gateways) {
                gateway.init();

View Full Code Here

        deactivateComponent();
        deactivateInternal();
    }
    
    private void activateInternal() throws Exception {
        configCache = new TreeCache(curator.get(), ZkPath.CONFIGS.getPath(), true, false, true, cacheExecutor);
        configCache.start(TreeCache.StartMode.NORMAL);
        configCache.getListenable().addListener(this);


        containerCache = new TreeCache(curator.get(), ZkPath.CONTAINERS.getPath(), true, false, true, cacheExecutor);
        containerCache.start(TreeCache.StartMode.NORMAL);
        containerCache.getListenable().addListener(this);


    }

View Full Code Here

        try {
            create(curator, DOSGI_REGISTRY, CreateMode.PERSISTENT);
        } catch (KeeperException.NodeExistsException e) {
            // The node already exists, that's fine
        }
        this.tree = new TreeCache(curator,  DOSGI_REGISTRY, true);
        this.tree.getListenable().addListener(this);
        this.tree.start();
        // UUID
        this.uuid = Utils.getUUID(this.bundleContext);
        // Service listener filter

View Full Code Here

    }




    public void init() throws Exception {
        if (active.compareAndSet(false, true)) {
            treeCache = new TreeCache(curator, zkPath, true, false, true, treeCacheExecutor);
            treeCache.getListenable().addListener(treeListener);
            treeCache.start(TreeCache.StartMode.NORMAL);
            LOG.info("Started a group listener for " + zkPath);
        }
    }

View Full Code Here

TOP

Related Classes of org.apache.curator.framework.recipes.cache.TreeCache

io.fabric8.dosgi.impl.Manager

io.fabric8.gateway.fabric.detecting.GatewayServiceTreeCache

io.fabric8.gateway.fabric.mq.GatewayServiceTreeCache

io.fabric8.gateway.fabric.support.http.HttpMappingZooKeeperTreeCache

io.fabric8.service.ZkDataStoreImpl

org.apache.curator.utils.CloseableExecutorService

org.apache.zookeeper.data.Stat

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.