Merge pull request #155 from yma96/main

Update Cassandra reconnect policy and default delay value
Commonjava · Oct 15, 2024 · ba4f2d0 · ba4f2d0
2 parents c817c50 + 8a0c291
commit ba4f2d0
Show file tree

Hide file tree

Showing 2 changed files with 17 additions and 0 deletions.
diff --git a/src/main/java/org/commonjava/indy/service/repository/data/cassandra/CassandraClient.java b/src/main/java/org/commonjava/indy/service/repository/data/cassandra/CassandraClient.java
@@ -18,6 +18,7 @@
 import com.datastax.driver.core.Cluster;
 import com.datastax.driver.core.Session;
 import com.datastax.driver.core.SocketOptions;
+import com.datastax.driver.core.policies.ConstantReconnectionPolicy;
 import io.quarkus.runtime.Startup;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -75,6 +76,8 @@ public void init()
         socketOptions.setReadTimeoutMillis( config.getReadTimeoutMillis() );
         Cluster.Builder builder = Cluster.builder()
                                          .withoutJMXReporting()
+                                         .withReconnectionPolicy(
+                                                 new ConstantReconnectionPolicy( config.getConstantDelayMs() ) )
                                          .withRetryPolicy( new ConfigurableRetryPolicy( config.getReadRetries(),
                                                                                         config.getWriteRetries() ) )
                                          .addContactPoint( host )

diff --git a/...in/java/org/commonjava/indy/service/repository/data/cassandra/CassandraConfiguration.java b/...in/java/org/commonjava/indy/service/repository/data/cassandra/CassandraConfiguration.java
@@ -65,6 +65,10 @@ public class CassandraConfiguration
     @ConfigProperty( name = "cassandra.retries.write", defaultValue = "3" )
     int writeRetries;
 
+    @Inject
+    @ConfigProperty( name = "cassandra.reconnect.delay", defaultValue = "60000" )
+    long constantDelayMs;
+
     @Inject
     @ConfigProperty( name = "cassandra.keyspace" )
     Optional<String> keyspace;
@@ -167,6 +171,16 @@ public void setWriteRetries( int writeRetries )
         this.writeRetries = writeRetries;
     }
 
+    public long getConstantDelayMs()
+    {
+        return constantDelayMs;
+    }
+
+    public void setConstantDelayMs( long constantDelayMs )
+    {
+        this.constantDelayMs = constantDelayMs;
+    }
+
     public String getKeyspace()
     {
         return keyspace.orElse( "" );