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 <[email protected]> Authored: Sat Nov 12 00:52:31 2016 -0800 Committer: Michael Russo <[email protected]> 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
