private void verifyConsulAgentRunning()

in mode/cluster/repository/consul/src/main/java/org/apache/shardingsphere/mode/repository/cluster/consul/ConsulRepository.java [249:254]

• 6 lines of code
• 2 McCabe index (conditional complexity)

    private void verifyConsulAgentRunning() {
        HttpResponse httpResponse = consulClient.getRawClient().makeGetRequest("/v1/status/leader");
        if (HttpStatus.SC_OK != httpResponse.getStatusCode()) {
            throw new RuntimeException("Unable to connect to Consul Agent and StatusCode is " + httpResponse.getStatusCode() + ".");
        }
    }