diff --git a/src/main/java/com/github/cassandra/jdbc/provider/datastax/DataStaxSessionWrapper.java b/src/main/java/com/github/cassandra/jdbc/provider/datastax/DataStaxSessionWrapper.java index d58d5fb..85a1c80 100644 --- a/src/main/java/com/github/cassandra/jdbc/provider/datastax/DataStaxSessionWrapper.java +++ b/src/main/java/com/github/cassandra/jdbc/provider/datastax/DataStaxSessionWrapper.java @@ -86,19 +86,24 @@ boolean isClosed() { return session == null || session.isClosed(); } + /*** + * https://www.datastax.com/dev/blog/4-simple-rules-when-using-the-datastax-drivers-for-cassandra + */ public void close() throws Exception { if (session == null || references.decrementAndGet() <= 0) { if (session != null) { Cluster cluster = session.getCluster(); if (DataStaxClusterHelper.hasLiveSessions(cluster)) { - cluster.closeAsync().force(); - Logger.info("Closing cluster@{} and all sessions underneath", cluster.hashCode()); + Logger.info("Having Live Sesssions : " + DataStaxClusterHelper.hasLiveSessions(cluster)); + //cluster.closeAsync().force(); + //Logger.info("Closing cluster@{} and all sessions underneath", cluster.hashCode()); } else { session.close(); + cluster.closeAsync().force(); Logger.info("Session@{} is closed", session.hashCode()); } session = null; } } } -} +} \ No newline at end of file