Examples of com.datastax.driver.core.Cluster.register()

com.datastax.driver.core.Cluster.register()
Registers the provided listener to be notified on hosts up/down/added/removed events.
Registering the same listener multiple times is a no-op.
Note that while {@link LoadBalancingPolicy} implements{@code Host.StateListener}, the configured load balancing does not need to (and should not) be registered through this method to received host related events. @param listener the new {@link Host.StateListener} to register. @return this {@code Cluster} object;

        poolingOptions.setCoreConnectionsPerHost(HostDistance.LOCAL, 24);
        poolingOptions.setCoreConnectionsPerHost(HostDistance.REMOTE, 24);
        poolingOptions.setMaxConnectionsPerHost(HostDistance.LOCAL, 32);
        poolingOptions.setMaxConnectionsPerHost(HostDistance.REMOTE, 32);


        cluster.register(new Host.StateListener() {
            @Override
            public void onAdd(Host host) {
                log.info("host " + host + " added");
            }

View Full Code Here

            .addContactPoints("127.0.0.1")
//            .withCredentials("cassandra", "cassandra")
            .withCredentials("rhqadmin", "rhqadmin")
            .build();


        cluster.register(new Host.StateListener() {
            @Override
            public void onAdd(Host host) {
                log.info("host " + host + " ADDED");
            }

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.