public synchronized void close()

in common/src/main/java/org/apache/cassandra/sidecar/common/CQLSessionProvider.java [129:151]

• 23 lines of code
• 5 McCabe index (conditional complexity)

    public synchronized void close()
    {
        if (localSession != null)
        {
            try
            {
                localSession.getCluster().closeAsync().get(1, TimeUnit.MINUTES);
            }
            catch (InterruptedException e)
            {
                Thread.currentThread().interrupt();
            }
            catch (TimeoutException e)
            {
                logger.warn("Unable to close session after 1 minute for provider {}", this, e);
            }
            catch (ExecutionException e)
            {
                throw propagateCause(e);
            }
            localSession = null;
        }
    }