Spring/spring-data-rest
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

DATAREST-414 - Added retry logic to connect to embedded Cassandra.

Browse Source 
The Cassandra tests sometimes cannot to the embedded instance on the CI server. Added a triple retry with a delay of 200ms to work around a potentially slow Cassandra bootstrap.
This commit is contained in:
Oliver Gierke
2015-01-21 15:24:13 +01:00
parent c67b3e749d
commit fbd803f32a
1 changed files with 22 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
spring-data-rest-webmvc/src/test/java/org/springframework/data/rest/webmvc/cassandra/AbstractCassandraIntegrationTest.java
View File

@@ -25,6 +25,7 @@ import org.springframework.data.rest.webmvc.CommonWebTests;
import com.datastax.driver.core.Cluster;
import com.datastax.driver.core.Session;
import com.datastax.driver.core.exceptions.NoHostAvailableException;
/**
* Base class for testing with an embedded cassandra database
@@ -67,7 +68,27 @@ public abstract class AbstractCassandraIntegrationTest extends CommonWebTests {
// check system session connected
if (systemSession == null) {
systemSession = cluster.connect();
systemSession = tryToConnect(cluster, 3);
}
}
private static Session tryToConnect(Cluster cluster, int attempts) {
try {
return cluster.connect();
} catch (NoHostAvailableException o_O) {
if (attempts == 0) {
throw o_O;
}
try {
Thread.sleep(200);
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
return tryToConnect(cluster, --attempts);
}
}
}