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; }