Repository: usergrid Updated Branches: refs/heads/release-2.1.1 b3739dc95 -> 3ab979108
Add connect timeout to Asytanax driver (set same as socket timeout for now). Project: http://git-wip-us.apache.org/repos/asf/usergrid/repo Commit: http://git-wip-us.apache.org/repos/asf/usergrid/commit/3ab97910 Tree: http://git-wip-us.apache.org/repos/asf/usergrid/tree/3ab97910 Diff: http://git-wip-us.apache.org/repos/asf/usergrid/diff/3ab97910 Branch: refs/heads/release-2.1.1 Commit: 3ab979108dda182b4ac1309151566667df3b3831 Parents: b3739dc Author: Michael Russo <[email protected]> Authored: Sat Mar 26 18:27:02 2016 -0700 Committer: Michael Russo <[email protected]> Committed: Sat Mar 26 18:27:02 2016 -0700 ---------------------------------------------------------------------- .../usergrid/persistence/core/astyanax/CassandraClusterImpl.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/usergrid/blob/3ab97910/stack/corepersistence/common/src/main/java/org/apache/usergrid/persistence/core/astyanax/CassandraClusterImpl.java ---------------------------------------------------------------------- diff --git a/stack/corepersistence/common/src/main/java/org/apache/usergrid/persistence/core/astyanax/CassandraClusterImpl.java b/stack/corepersistence/common/src/main/java/org/apache/usergrid/persistence/core/astyanax/CassandraClusterImpl.java index 5b59a98..d8493cf 100644 --- a/stack/corepersistence/common/src/main/java/org/apache/usergrid/persistence/core/astyanax/CassandraClusterImpl.java +++ b/stack/corepersistence/common/src/main/java/org/apache/usergrid/persistence/core/astyanax/CassandraClusterImpl.java @@ -170,6 +170,7 @@ public class CassandraClusterImpl implements CassandraCluster { .setLocalDatacenter( cassandraFig.getLocalDataCenter() ) .setMaxConnsPerHost( poolSize ) .setSeeds( cassandraFig.getHosts() ) + .setConnectTimeout( cassandraFig.getTimeout() ) .setSocketTimeout( cassandraFig.getTimeout() ) .setAuthenticationCredentials(new SimpleAuthenticationCredentials( username, password));
