From 07439c2ddec5b3c4316872a8b683d981da5891b4 Mon Sep 17 00:00:00 2001 From: David Webb Date: Thu, 12 Jun 2014 00:12:52 -0400 Subject: [PATCH] DATACASS-137 - Completed Added mapping for 3 new ConsistencyLevels. --- .../springframework/cassandra/core/ConsistencyLevel.java | 2 +- .../cassandra/core/ConsistencyLevelResolver.java | 9 +++++++++ 2 files changed, 10 insertions(+), 1 deletion(-) diff --git a/spring-cql/src/main/java/org/springframework/cassandra/core/ConsistencyLevel.java b/spring-cql/src/main/java/org/springframework/cassandra/core/ConsistencyLevel.java index 2373413c4..116ba04c2 100644 --- a/spring-cql/src/main/java/org/springframework/cassandra/core/ConsistencyLevel.java +++ b/spring-cql/src/main/java/org/springframework/cassandra/core/ConsistencyLevel.java @@ -23,6 +23,6 @@ package org.springframework.cassandra.core; */ public enum ConsistencyLevel { - ANY, ONE, TWO, THREE, QUOROM, LOCAL_QUOROM, EACH_QUOROM, ALL + ANY, ONE, TWO, THREE, QUOROM, LOCAL_QUOROM, EACH_QUOROM, ALL, LOCAL_ONE, SERIAL, LOCAL_SERIAL } diff --git a/spring-cql/src/main/java/org/springframework/cassandra/core/ConsistencyLevelResolver.java b/spring-cql/src/main/java/org/springframework/cassandra/core/ConsistencyLevelResolver.java index 96482e472..fc2fe577d 100644 --- a/spring-cql/src/main/java/org/springframework/cassandra/core/ConsistencyLevelResolver.java +++ b/spring-cql/src/main/java/org/springframework/cassandra/core/ConsistencyLevelResolver.java @@ -46,6 +46,9 @@ public final class ConsistencyLevelResolver { case ONE: resolvedLevel = com.datastax.driver.core.ConsistencyLevel.ONE; break; + case LOCAL_ONE: + resolvedLevel = com.datastax.driver.core.ConsistencyLevel.LOCAL_ONE; + break; case ALL: resolvedLevel = com.datastax.driver.core.ConsistencyLevel.ALL; break; @@ -67,6 +70,12 @@ public final class ConsistencyLevelResolver { case TWO: resolvedLevel = com.datastax.driver.core.ConsistencyLevel.TWO; break; + case SERIAL: + resolvedLevel = com.datastax.driver.core.ConsistencyLevel.SERIAL; + break; + case LOCAL_SERIAL: + resolvedLevel = com.datastax.driver.core.ConsistencyLevel.LOCAL_SERIAL; + break; default: break; }