added downgrading retry policy to avoid problems with consistency lev…

…els and nodes down
EinsamHauer · Aug 3, 2016 · 9c63646 · 9c63646
1 parent 0a1931b
commit 9c63646
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/pom.xml b/pom.xml
@@ -4,7 +4,7 @@
     <groupId>net.iponweb.disthene.reader</groupId>
     <artifactId>disthene-reader</artifactId>
     <packaging>jar</packaging>
-    <version>0.2.37</version>
+    <version>0.2.38</version>
     <name>disthene-reader</name>
     <url>http://maven.apache.org</url>
     <dependencies>

diff --git a/src/main/java/net/iponweb/disthene/reader/service/store/CassandraService.java b/src/main/java/net/iponweb/disthene/reader/service/store/CassandraService.java
@@ -2,6 +2,7 @@
 
 import com.datastax.driver.core.*;
 import com.datastax.driver.core.policies.DCAwareRoundRobinPolicy;
+import com.datastax.driver.core.policies.DowngradingConsistencyRetryPolicy;
 import com.datastax.driver.core.policies.TokenAwarePolicy;
 import com.datastax.driver.core.policies.WhiteListPolicy;
 import net.iponweb.disthene.reader.config.StoreConfiguration;
@@ -44,6 +45,7 @@ public CassandraService(StoreConfiguration storeConfiguration) {
                 .withSocketOptions(socketOptions)
                 .withCompression(ProtocolOptions.Compression.LZ4)
                 .withLoadBalancingPolicy(new TokenAwarePolicy(new DCAwareRoundRobinPolicy()))
+                .withRetryPolicy(DowngradingConsistencyRetryPolicy.INSTANCE)
                 .withPoolingOptions(poolingOptions)
                 .withQueryOptions(new QueryOptions().setConsistencyLevel(ConsistencyLevel.valueOf(storeConfiguration.getConsistency())))
                 .withProtocolVersion(ProtocolVersion.V2)