Remove one time closed flag since might need to reconnect as necessary

Commonjava · Oct 22, 2024 · b793719 · b793719
1 parent 1247339
commit b793719
Showing 1 changed file with 1 addition and 4 deletions.
diff --git a/src/main/java/org/commonjava/indy/service/tracking/data/cassandra/CassandraClient.java b/src/main/java/org/commonjava/indy/service/tracking/data/cassandra/CassandraClient.java
@@ -48,8 +48,6 @@ public class CassandraClient
 
     private Cluster cluster;
 
-    private volatile boolean closed;
-
     public CassandraClient()
     {
     }
@@ -118,14 +116,13 @@ public Session getSession( String keyspace )
 
     public void close()
     {
-        if ( !closed && cluster != null )
+        if ( cluster != null )
         {
             logger.info( "Close cassandra client" );
             sessions.forEach( ( key, value ) -> value.close() );
             sessions.clear();
             cluster.close();
             cluster = null;
-            closed = true;
         }
     }