You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@usergrid.apache.org by mr...@apache.org on 2016/11/12 08:52:43 UTC
usergrid git commit: Add reconnection policy.
Repository: usergrid
Updated Branches:
refs/heads/master ac28b8f50 -> ce9d66c31
Add reconnection policy.
Project: http://git-wip-us.apache.org/repos/asf/usergrid/repo
Commit: http://git-wip-us.apache.org/repos/asf/usergrid/commit/ce9d66c3
Tree: http://git-wip-us.apache.org/repos/asf/usergrid/tree/ce9d66c3
Diff: http://git-wip-us.apache.org/repos/asf/usergrid/diff/ce9d66c3
Branch: refs/heads/master
Commit: ce9d66c318cc42103caadc07c5d2292177126c3d
Parents: ac28b8f
Author: Michael Russo <mr...@apigee.com>
Authored: Sat Nov 12 00:52:31 2016 -0800
Committer: Michael Russo <mr...@apigee.com>
Committed: Sat Nov 12 00:52:31 2016 -0800
----------------------------------------------------------------------
.../persistence/core/datastax/impl/DataStaxClusterImpl.java | 6 +++++-
1 file changed, 5 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/usergrid/blob/ce9d66c3/stack/corepersistence/common/src/main/java/org/apache/usergrid/persistence/core/datastax/impl/DataStaxClusterImpl.java
----------------------------------------------------------------------
diff --git a/stack/corepersistence/common/src/main/java/org/apache/usergrid/persistence/core/datastax/impl/DataStaxClusterImpl.java b/stack/corepersistence/common/src/main/java/org/apache/usergrid/persistence/core/datastax/impl/DataStaxClusterImpl.java
index f90b235..2bb1a0a 100644
--- a/stack/corepersistence/common/src/main/java/org/apache/usergrid/persistence/core/datastax/impl/DataStaxClusterImpl.java
+++ b/stack/corepersistence/common/src/main/java/org/apache/usergrid/persistence/core/datastax/impl/DataStaxClusterImpl.java
@@ -21,6 +21,8 @@ package org.apache.usergrid.persistence.core.datastax.impl;
import com.datastax.driver.core.*;
import com.datastax.driver.core.policies.DCAwareRoundRobinPolicy;
import com.datastax.driver.core.policies.LoadBalancingPolicy;
+import com.datastax.driver.core.policies.Policies;
+import com.datastax.driver.core.policies.ReconnectionPolicy;
import com.google.inject.Inject;
import com.google.inject.Singleton;
import org.apache.usergrid.persistence.core.CassandraConfig;
@@ -215,7 +217,8 @@ public class DataStaxClusterImpl implements DataStaxCluster {
// purposely add a couple seconds to the driver's lower level socket timeouts vs. cassandra timeouts
final SocketOptions socketOptions = new SocketOptions()
.setConnectTimeoutMillis( cassandraConfig.getTimeout() + 2000)
- .setReadTimeoutMillis( cassandraConfig.getTimeout() + 2000);
+ .setReadTimeoutMillis( cassandraConfig.getTimeout() + 2000)
+ .setReuseAddress();
final QueryOptions queryOptions = new QueryOptions()
.setConsistencyLevel(defaultConsistencyLevel);
@@ -229,6 +232,7 @@ public class DataStaxClusterImpl implements DataStaxCluster {
.withPoolingOptions(poolingOptions)
.withQueryOptions(queryOptions)
.withSocketOptions(socketOptions)
+ .withReconnectionPolicy(Policies.defaultReconnectionPolicy())
.withProtocolVersion(getProtocolVersion( cassandraConfig.getVersion()));
// only add auth credentials if they were provided