[james-project] 05/10: JAMES-2897 use wasApplied method on LWT statements

[btellier]

This is an automated email from the ASF dual-hosted git repository.

btellier pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/james-project.git

commit 7dbbd3d86f686d7dfa0dd7dbc503d5a9f9448ae9
Author: Matthieu Baechler <matth...@apache.org>
AuthorDate: Tue Sep 10 16:40:44 2019 +0200

    JAMES-2897 use wasApplied method on LWT statements
---
 .../apache/james/backends/cassandra/utils/CassandraAsyncExecutor.java | 4 ++--
 .../org/apache/james/backends/cassandra/utils/CassandraConstants.java | 3 ---
 2 files changed, 2 insertions(+), 5 deletions(-)

diff --git 
a/backends-common/cassandra/src/main/java/org/apache/james/backends/cassandra/utils/CassandraAsyncExecutor.java
 
b/backends-common/cassandra/src/main/java/org/apache/james/backends/cassandra/utils/CassandraAsyncExecutor.java
index 6e19b60..1b6464c 100644
--- 
a/backends-common/cassandra/src/main/java/org/apache/james/backends/cassandra/utils/CassandraAsyncExecutor.java
+++ 
b/backends-common/cassandra/src/main/java/org/apache/james/backends/cassandra/utils/CassandraAsyncExecutor.java
@@ -48,8 +48,8 @@ public class CassandraAsyncExecutor {
     }
 
     public Mono<Boolean> executeReturnApplied(Statement statement) {
-        return executeSingleRow(statement)
-                .map(row -> 
row.getBool(CassandraConstants.LIGHTWEIGHT_TRANSACTION_APPLIED));
+        return execute(statement)
+                .map(row -> row.wasApplied());
     }
 
     public Mono<Void> executeVoid(Statement statement) {
diff --git 
a/backends-common/cassandra/src/main/java/org/apache/james/backends/cassandra/utils/CassandraConstants.java
 
b/backends-common/cassandra/src/main/java/org/apache/james/backends/cassandra/utils/CassandraConstants.java
index b152088..38ee95d 100644
--- 
a/backends-common/cassandra/src/main/java/org/apache/james/backends/cassandra/utils/CassandraConstants.java
+++ 
b/backends-common/cassandra/src/main/java/org/apache/james/backends/cassandra/utils/CassandraConstants.java
@@ -20,8 +20,5 @@
 package org.apache.james.backends.cassandra.utils;
 
 public interface CassandraConstants {
-    int LIGHTWEIGHT_TRANSACTION_APPLIED = 0;
-
-
     int DEFAULT_CACHED_ROW_PER_PARTITION = 10;
 }


---------------------------------------------------------------------
To unsubscribe, e-mail: server-dev-unsubscr...@james.apache.org
For additional commands, e-mail: server-dev-h...@james.apache.org