[camel] branch master updated: CAMEL-12024 - Camel-CassandraQL: Add ErrorAwarePolicy to the Load Balancing Policies set

[ac...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git


The following commit(s) were added to refs/heads/master by this push:
     new 9780ce7  CAMEL-12024 - Camel-CassandraQL: Add ErrorAwarePolicy to the Load Balancing Policies set
9780ce7 is described below

commit 9780ce798cc4512c9339042ac20b8b9f190e7a1e
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Thu Nov 23 08:08:51 2017 +0100

    CAMEL-12024 - Camel-CassandraQL: Add ErrorAwarePolicy to the Load Balancing Policies set
---
 .../apache/camel/utils/cassandra/CassandraLoadBalancingPolicies.java | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/components/camel-cassandraql/src/main/java/org/apache/camel/utils/cassandra/CassandraLoadBalancingPolicies.java b/components/camel-cassandraql/src/main/java/org/apache/camel/utils/cassandra/CassandraLoadBalancingPolicies.java
index b5cefa8..d06e90a 100644
--- a/components/camel-cassandraql/src/main/java/org/apache/camel/utils/cassandra/CassandraLoadBalancingPolicies.java
+++ b/components/camel-cassandraql/src/main/java/org/apache/camel/utils/cassandra/CassandraLoadBalancingPolicies.java
@@ -17,6 +17,7 @@
 package org.apache.camel.utils.cassandra;
 
 import com.datastax.driver.core.policies.DCAwareRoundRobinPolicy;
+import com.datastax.driver.core.policies.ErrorAwarePolicy;
 import com.datastax.driver.core.policies.LatencyAwarePolicy;
 import com.datastax.driver.core.policies.LoadBalancingPolicy;
 import com.datastax.driver.core.policies.RoundRobinPolicy;
@@ -28,6 +29,7 @@ public class CassandraLoadBalancingPolicies {
     public final String tokenAwarePolicy = "TokenAwarePolicy";
     public final String dcAwareRoundRobinPolicy = "DcAwareRoundRobinPolicy";
     public final String latencyAwarePolicy = "LatencyAwarePolicy";
+    public final String errorAwarePolicy = "ErrorAwarePolicy";
     
     public LoadBalancingPolicy getLoadBalancingPolicy(String policy) {
         LoadBalancingPolicy loadBalancingPolicy = new RoundRobinPolicy();
@@ -44,6 +46,9 @@ public class CassandraLoadBalancingPolicies {
         case latencyAwarePolicy:
             loadBalancingPolicy = LatencyAwarePolicy.builder(new RoundRobinPolicy()).build();
             break;
+        case errorAwarePolicy:
+            loadBalancingPolicy = ErrorAwarePolicy.builder(new RoundRobinPolicy()).build();
+            break;
         default:
             throw new IllegalArgumentException("Cassandra load balancing policy can be " + roundRobinPolicy + " ," + tokenAwarePolicy 
                    + " ," + dcAwareRoundRobinPolicy);

-- 
To stop receiving notification emails like this one, please contact
['"commits@camel.apache.org" <co...@camel.apache.org>'].