You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2016/04/27 08:19:43 UTC
camel git commit: CAMEL-9909: Camel-Cassandraql: Supports missing
Load Balancing policies
Repository: camel
Updated Branches:
refs/heads/master 45c375c38 -> eb7439438
CAMEL-9909: Camel-Cassandraql: Supports missing Load Balancing policies
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/eb743943
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/eb743943
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/eb743943
Branch: refs/heads/master
Commit: eb743943832b35e4d77ec5dda43b9be3dd190e98
Parents: 45c375c
Author: Andrea Cosentino <an...@gmail.com>
Authored: Wed Apr 27 08:18:44 2016 +0200
Committer: Andrea Cosentino <an...@gmail.com>
Committed: Wed Apr 27 08:19:09 2016 +0200
----------------------------------------------------------------------
.../camel/utils/cassandra/CassandraLoadBalancingPolicies.java | 5 +++++
1 file changed, 5 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/eb743943/components/camel-cassandraql/src/main/java/org/apache/camel/utils/cassandra/CassandraLoadBalancingPolicies.java
----------------------------------------------------------------------
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 d6225bd..b5cefa8 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.LatencyAwarePolicy;
import com.datastax.driver.core.policies.LoadBalancingPolicy;
import com.datastax.driver.core.policies.RoundRobinPolicy;
import com.datastax.driver.core.policies.TokenAwarePolicy;
@@ -26,6 +27,7 @@ public class CassandraLoadBalancingPolicies {
public final String roundRobinPolicy = "RoundRobinPolicy";
public final String tokenAwarePolicy = "TokenAwarePolicy";
public final String dcAwareRoundRobinPolicy = "DcAwareRoundRobinPolicy";
+ public final String latencyAwarePolicy = "LatencyAwarePolicy";
public LoadBalancingPolicy getLoadBalancingPolicy(String policy) {
LoadBalancingPolicy loadBalancingPolicy = new RoundRobinPolicy();
@@ -39,6 +41,9 @@ public class CassandraLoadBalancingPolicies {
case dcAwareRoundRobinPolicy:
loadBalancingPolicy = DCAwareRoundRobinPolicy.builder().build();
break;
+ case latencyAwarePolicy:
+ loadBalancingPolicy = LatencyAwarePolicy.builder(new RoundRobinPolicy()).build();
+ break;
default:
throw new IllegalArgumentException("Cassandra load balancing policy can be " + roundRobinPolicy + " ," + tokenAwarePolicy
+ " ," + dcAwareRoundRobinPolicy);