[james-project] 07/10: JAMES-2897 to ensure we read the right value after LWT, SERIAL is required

[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 dbcc50879f2c3187f8045e21032130147de93fbf
Author: Matthieu Baechler <matth...@apache.org>
AuthorDate: Tue Sep 10 16:43:59 2019 +0200

    JAMES-2897 to ensure we read the right value after LWT, SERIAL is required
---
 .../james/mailbox/cassandra/mail/CassandraMessageIdToImapUidDAO.java   | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/mail/CassandraMessageIdToImapUidDAO.java
 
b/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/mail/CassandraMessageIdToImapUidDAO.java
index 1b0353a..aaae23b 100644
--- 
a/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/mail/CassandraMessageIdToImapUidDAO.java
+++ 
b/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/mail/CassandraMessageIdToImapUidDAO.java
@@ -55,6 +55,7 @@ import 
org.apache.james.mailbox.cassandra.ids.CassandraMessageId.Factory;
 import org.apache.james.mailbox.model.ComposedMessageId;
 import org.apache.james.mailbox.model.ComposedMessageIdWithMetaData;
 
+import com.datastax.driver.core.ConsistencyLevel;
 import com.datastax.driver.core.PreparedStatement;
 import com.datastax.driver.core.Row;
 import com.datastax.driver.core.Session;
@@ -193,7 +194,7 @@ public class CassandraMessageIdToImapUidDAO {
 
     public Flux<ComposedMessageIdWithMetaData> retrieve(CassandraMessageId 
messageId, Optional<CassandraId> mailboxId) {
         return cassandraAsyncExecutor.executeRows(
-                    selectStatement(messageId, mailboxId))
+                    selectStatement(messageId, 
mailboxId).setConsistencyLevel(ConsistencyLevel.SERIAL))
                 .map(this::toComposedMessageIdWithMetadata);
     }
 


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