Author: btellier
Date: Wed Nov 25 10:49:20 2015
New Revision: 1716349
URL: http://svn.apache.org/viewvc?rev=1716349&view=rev
Log:
JAMES-1635 Increase Cassandra timeout and max retry
Modified:
james/project/trunk/backends-common/cassandra/src/test/java/org/apache/james/backends/cassandra/CassandraCluster.java
Modified:
james/project/trunk/backends-common/cassandra/src/test/java/org/apache/james/backends/cassandra/CassandraCluster.java
URL:
http://svn.apache.org/viewvc/james/project/trunk/backends-common/cassandra/src/test/java/org/apache/james/backends/cassandra/CassandraCluster.java?rev=1716349&r1=1716348&r2=1716349&view=diff
==============================================================================
---
james/project/trunk/backends-common/cassandra/src/test/java/org/apache/james/backends/cassandra/CassandraCluster.java
(original)
+++
james/project/trunk/backends-common/cassandra/src/test/java/org/apache/james/backends/cassandra/CassandraCluster.java
Wed Nov 25 10:49:20 2015
@@ -41,7 +41,7 @@ public final class CassandraCluster {
private static final int REPLICATION_FACTOR = 1;
private static final long SLEEP_BEFORE_RETRY = 200;
- private static final int MAX_RETRY = 200;
+ private static final int MAX_RETRY = 2000;
private final CassandraModule module;
private Session session;
@@ -54,7 +54,7 @@ public final class CassandraCluster {
private CassandraCluster(CassandraModule module) throws RuntimeException {
this.module = module;
try {
- EmbeddedCassandraServerHelper.startEmbeddedCassandra();
+ EmbeddedCassandraServerHelper.startEmbeddedCassandra(20000L);
session = new FunctionRunnerWithRetry(MAX_RETRY)
.executeAndRetrieveObject(CassandraCluster.this::tryInitializeSession);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
