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/21 03:46:10 UTC
usergrid git commit: Make sure to create keyspaces on initialization
before trying to obtain sessions to the keyspaces.
Repository: usergrid
Updated Branches:
refs/heads/master 3d6014529 -> 2af22a871
Make sure to create keyspaces on initialization before trying to obtain sessions to the keyspaces.
Project: http://git-wip-us.apache.org/repos/asf/usergrid/repo
Commit: http://git-wip-us.apache.org/repos/asf/usergrid/commit/2af22a87
Tree: http://git-wip-us.apache.org/repos/asf/usergrid/tree/2af22a87
Diff: http://git-wip-us.apache.org/repos/asf/usergrid/diff/2af22a87
Branch: refs/heads/master
Commit: 2af22a87105629f423463c4132ff9141bb95930c
Parents: 3d60145
Author: Michael Russo <mr...@apigee.com>
Authored: Sun Nov 20 19:45:43 2016 -0800
Committer: Michael Russo <mr...@apigee.com>
Committed: Sun Nov 20 19:45:43 2016 -0800
----------------------------------------------------------------------
.../persistence/core/datastax/impl/DataStaxClusterImpl.java | 4 +---
1 file changed, 1 insertion(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/usergrid/blob/2af22a87/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 a9238e8..bd7d326 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
@@ -51,9 +51,6 @@ public class DataStaxClusterImpl implements DataStaxCluster {
public DataStaxClusterImpl(final CassandraConfig cassandraFig ) throws Exception {
this.cassandraConfig = cassandraFig;
this.cluster = getCluster();
- this.clusterSession = getClusterSession();
- this.applicationSession = getApplicationSession();
- this.queueMessageSession = getApplicationLocalSession();
logger.info("Initialized datastax cluster client. Hosts={}, Idle Timeout={}s, Pool Timeout={}s",
getCluster().getMetadata().getAllHosts().toString(),
@@ -62,6 +59,7 @@ public class DataStaxClusterImpl implements DataStaxCluster {
// always initialize the keyspaces
this.createApplicationKeyspace(false);
+ this.createApplicationLocalKeyspace(false);
}
@Override