usergrid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mru...@apache.org
Subject [26/38] usergrid git commit: Add consistent read CL for datastax driver implementations.
Date Wed, 17 Aug 2016 21:48:33 GMT
Add consistent read CL for datastax driver implementations.


Project: http://git-wip-us.apache.org/repos/asf/usergrid/repo
Commit: http://git-wip-us.apache.org/repos/asf/usergrid/commit/ff3f7e89
Tree: http://git-wip-us.apache.org/repos/asf/usergrid/tree/ff3f7e89
Diff: http://git-wip-us.apache.org/repos/asf/usergrid/diff/ff3f7e89

Branch: refs/heads/master
Commit: ff3f7e899d81d636eddaa203141ee31ef2da097c
Parents: f28abda
Author: Michael Russo <mrusso@apigee.com>
Authored: Sun May 1 17:48:43 2016 +0800
Committer: Michael Russo <mrusso@apigee.com>
Committed: Sun May 1 17:48:43 2016 +0800

----------------------------------------------------------------------
 .../apache/usergrid/persistence/core/CassandraConfigImpl.java   | 2 +-
 .../java/org/apache/usergrid/persistence/core/CassandraFig.java | 5 +++++
 2 files changed, 6 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/usergrid/blob/ff3f7e89/stack/corepersistence/common/src/main/java/org/apache/usergrid/persistence/core/CassandraConfigImpl.java
----------------------------------------------------------------------
diff --git a/stack/corepersistence/common/src/main/java/org/apache/usergrid/persistence/core/CassandraConfigImpl.java
b/stack/corepersistence/common/src/main/java/org/apache/usergrid/persistence/core/CassandraConfigImpl.java
index 5dbf162..e87ebb8 100644
--- a/stack/corepersistence/common/src/main/java/org/apache/usergrid/persistence/core/CassandraConfigImpl.java
+++ b/stack/corepersistence/common/src/main/java/org/apache/usergrid/persistence/core/CassandraConfigImpl.java
@@ -61,7 +61,7 @@ public class CassandraConfigImpl implements CassandraConfig {
 
         this.dataStaxReadCl = com.datastax.driver.core.ConsistencyLevel.valueOf( cassandraFig.getReadCl());
 
-        this.dataStaxReadConsistentCl = com.datastax.driver.core.ConsistencyLevel.valueOf(
cassandraFig.getReadCl());
+        this.dataStaxReadConsistentCl = com.datastax.driver.core.ConsistencyLevel.valueOf(
cassandraFig.getReadClConsistent());
 
         this.dataStaxWriteCl = com.datastax.driver.core.ConsistencyLevel.valueOf( cassandraFig.getWriteCl()
);
 

http://git-wip-us.apache.org/repos/asf/usergrid/blob/ff3f7e89/stack/corepersistence/common/src/main/java/org/apache/usergrid/persistence/core/CassandraFig.java
----------------------------------------------------------------------
diff --git a/stack/corepersistence/common/src/main/java/org/apache/usergrid/persistence/core/CassandraFig.java
b/stack/corepersistence/common/src/main/java/org/apache/usergrid/persistence/core/CassandraFig.java
index d8620be..3c58dfb 100644
--- a/stack/corepersistence/common/src/main/java/org/apache/usergrid/persistence/core/CassandraFig.java
+++ b/stack/corepersistence/common/src/main/java/org/apache/usergrid/persistence/core/CassandraFig.java
@@ -33,6 +33,7 @@ public interface CassandraFig extends GuicyFig {
 
     // cassndra properties used by datastax driver
     String READ_CL = "cassandra.readcl";
+    String READ_CL_CONSISTENT = "cassandra.readcl.consistent";
     String WRITE_CL = "cassandra.writecl";
     String STRATEGY = "cassandra.strategy";
     String STRATEGY_OPTIONS = "cassandra.strategy.options";
@@ -136,6 +137,10 @@ public interface CassandraFig extends GuicyFig {
     @Key(READ_CL)
     String getReadCl();
 
+    @Default("QUORUM")
+    @Key(READ_CL_CONSISTENT)
+    String getReadClConsistent();
+
     @Default("LOCAL_QUORUM")
     @Key(WRITE_CL)
     String getWriteCl();


Mime
View raw message