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/datastax-cass-driver Commit: ff3f7e899d81d636eddaa203141ee31ef2da097c Parents: f28abda Author: Michael Russo <[email protected]> Authored: Sun May 1 17:48:43 2016 +0800 Committer: Michael Russo <[email protected]> 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();
