public void stateChanged()

in phoenix-queryserver-orchestrator/src/main/java/org/apache/phoenix/queryserver/orchestrator/TestExecutorClient.java [89:110]

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

    public void stateChanged(CuratorFramework client, ConnectionState newState) {
        LOGGER.info("ZK Connection State Changed to [{}]", newState.name());
        switch(newState) {
            case CONNECTED:
                LOGGER.info("The host is connected at" +System.currentTimeMillis());
                break;
            case LOST:
                LOGGER.info("The host lost connection at "+ System.currentTimeMillis());
                isRunning = false;
                throw new CancelLeadershipException();
            case READ_ONLY:
                LOGGER.info("The connection state is Read only since "+ System.currentTimeMillis());
                break;
            case RECONNECTED:
                LOGGER.info("Reconnected to the ZK Path at " +System.currentTimeMillis());
                break;
            case SUSPENDED:
                isRunning = false;
                throw new CancelLeadershipException();
            default:
        }
    }