@@ -81,11 +81,17 @@ public class DseConfiguration {
8181 @ Value ("#{environment.KILLRVIDEO_DSE_PASSWORD}" )
8282 public Optional < String > dsePassword ;
8383
84- @ Value ("${KILLRVIDEO_DSE_INIT_RETRY: 50}" )
84+ @ Value ("${killrvideo.cassandra.maxNumberOfTries: 50}" )
8585 private Integer maxNumberOfTries ;
86-
87- @ Value ("${KILLRVIDEO_DSE_INIT_RETRY_DELAY:3}" )
86+
87+ @ Value ("#{environment.KILLRVIDEO_MAX_NUMBER_RETRY}" )
88+ private Optional < Integer > maxNumberOfTriesFromEnvVar ;
89+
90+ @ Value ("${killrvideo.cassandra.delayBetweenTries: 3}" )
8891 private Integer delayBetweenTries ;
92+
93+ @ Value ("#{environment.KILLRVIDEO_DELAY_BETWEEN_RETRY}" )
94+ private Optional < Integer > delayBetweenTriesFromEnvVar ;
8995
9096 @ Value ("${killrvideo.ssl.CACertFileLocation: cassandra.cert}" )
9197 private String sslCACertFileLocation ;
@@ -133,6 +139,14 @@ public DseSession initializeDSE() {
133139 return clusterConfig .build ().connect (CommonConstants .KILLRVIDEO_KEYSPACE );
134140 };
135141
142+ if (!maxNumberOfTriesFromEnvVar .isEmpty ()) {
143+ maxNumberOfTries = maxNumberOfTriesFromEnvVar .get ();
144+ }
145+
146+ if (!delayBetweenTriesFromEnvVar .isEmpty ()) {
147+ delayBetweenTries = delayBetweenTriesFromEnvVar .get ();
148+ }
149+
136150 // Connecting to DSE with a retry mechanism :
137151 /* In docker deployments we may have to wait until all components are up and running. */
138152 RetryConfig config = new RetryConfigBuilder ()
0 commit comments