Consul consul = Consul.builder().build(); // connect to Consul on localhost
AgentClient agentClient = consul.agentClient();

String serviceName = "MyService";
String serviceId = "1";

agentClient.register(8080, 3L, serviceName, serviceId); // registers with a TTL of 3 seconds
agentClient.pass(serviceId); // check in with Consul, serviceId required only.  client will prepend "service:" for service level checks.
// Note that you need to continually check in before the TTL expires, otherwise your service's state will be marked as "critical".

Consul consul = Consul.builder().build(); // connect to Consul on localhost
HealthClient healthClient = consul.healthClient();

List<ServiceHealth> nodes = healthClient.getHealthyServiceInstances("DataService").getResponse(); // discover only "passing" nodes

Consul consul = Consul.builder().build(); // connect to Consul on localhost
KeyValueClient kvClient = consul.keyValueClient();

kvClient.putValue("foo", "bar");

String value = kvClient.getValueAsString("foo").get(); // bar

// Set a read timeout to a larger value then we will block.
Consul consul = Consul.builder()
    .withReadTimeoutMillis(TimeUnit.SECONDS.toMillis(315))
    .build();
final KeyValueClient kvClient = consul.keyValueClient();

kvClient.putValue("foo", "bar");

ConsulResponseCallback<Optional<Value>> callback = new ConsulResponseCallback<Optional<Value>>() {

    AtomicReference<BigInteger> index = new AtomicReference<BigInteger>(null);

    @Override
    public void onComplete(ConsulResponse<Optional<Value>> consulResponse) {

        if (consulResponse.getResponse().isPresent()) {
            Value v = consulResponse.getResponse().get();
            LOGGER.info("Value is: {}", v.getValue());
        }

	index.set(consulResponse.getIndex());
        watch();
    }

    void watch() {
        kvClient.getValue("foo", QueryOptions.blockMinutes(5, index.get()).build(), this);
    }

    @Override
        public void onFailure(Throwable throwable) {
            LOGGER.error("Error encountered", throwable);
            watch();
        }
    };

    kvClient.getValue("foo", QueryOptions.blockMinutes(5, new BigInteger("0")).build(), callback);

Agent agent = client.agentClient().getAgent();
String serviceName = "my-service";

ServiceHealthCache svHealth = ServiceHealthCache.newCache(healthClient, serviceName);

svHealth.addListener(new ConsulCache.Listener<HostAndPort, ServiceHealth>() {
    @Override
    public void notify(Map<HostAndPort, ServiceHealth> newValues) {
        // do Something with updated server map
    }
});
svHealth.start();

StatusClient statusClient = Consul.builder().build().statusClient();

for(String peer : statusClient.getPeers()) {
	System.out.println(peer); // 127.0.0.1:8300
}

StatusClient statusClient = Consul.builder().build().statusClient();

System.out.println(statusClient.getLeader()); // 127.0.0.1:8300