public void persistEphemeral()

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

• 9 lines of code
• 1 McCabe index (conditional complexity)

    public void persistEphemeral(final String key, final String value) {
        Response<String> response = consulClient.sessionCreate(createNewSession(key), QueryParams.DEFAULT);
        String sessionId = response.getValue();
        PutParams putParams = new PutParams();
        putParams.setAcquireSession(sessionId);
        consulClient.setKVValue(key, value, putParams);
        generatorFlushSessionTtlTask(consulClient, sessionId);
        verifyConsulAgentRunning();
    }