Examples of ZooKeeperRegistrar

com.spotify.helios.servicescommon.ZooKeeperRegistrar
Common logic to have agents and masters register their "up" nodes in ZK, and to keep trying if ZK is down.

Examples of com.spotify.helios.servicescommon.ZooKeeperRegistrar

                                                              config.getZooKeeperClusterId());
    client.start();


    // Register the agent
    zkRegistrar =
        new ZooKeeperRegistrar(client, new AgentZooKeeperRegistrar(this, config.getName(), id));


    return client;
  }

View Full Code Here

Examples of com.spotify.helios.servicescommon.ZooKeeperRegistrar

        zooKeeperRetryPolicy,
        config.getZooKeeperNamespace());
    final ZooKeeperClient client = new DefaultZooKeeperClient(curator,
                                                              config.getZooKeeperClusterId());
    client.start();
    zkRegistrar = new ZooKeeperRegistrar(client, new MasterZooKeeperRegistrar(config.getName()));


    return client;
  }

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.