Examples of ZooKeeperGroup

io.fabric8.groups.internal.ZooKeeperGroup

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.

Examples of io.fabric8.groups.internal.ZooKeeperGroup


    @Activate
    void activate(Map<String, ?> configuration) {
        //this.realm =  properties != null && properties.containsKey(REALM_PROPERTY_NAME) ? properties.get(REALM_PROPERTY_NAME) : DEFAULT_REALM;
        //this.role =  properties != null && properties.containsKey(ROLE_PROPERTY_NAME) ? properties.get(ROLE_PROPERTY_NAME) : DEFAULT_ROLE;
        group = new ZooKeeperGroup(curator.get(), ZkPath.OPENSHIFT.getPath(), ControllerNode.class);
        group.add(this);
        group.update(createState());
        group.start();
        activateComponent();
    }

View Full Code Here

Examples of io.fabric8.groups.internal.ZooKeeperGroup

        //Create SRV Records for Services
        CuratorFramework curator = fabricService.get().adapt(CuratorFramework.class);
        for (String groupName : groups) {
            Group<SrvNode> group = activeGroups.get(groupName);
            if (group == null) {
                group = new ZooKeeperGroup(curator, "/fabric/registry/clusters/" + groupName, SrvNode.class);
                group.add(groupListener);
                group.start();
                activeGroups.put(groupName, group);
            }
        }

View Full Code Here

TOP

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.