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 764d69eb679f426beed986eee22e903952a26e82 Author: Benoit Tellier <[email protected]> AuthorDate: Wed Apr 15 11:06:38 2020 +0700 JAMES-3146 Ordering messages by Uid in CassandraMessageIdMapper is a non sense Uid is a mailbox bound concept while find operation miwes messages that could be in multiple mailboxes. We can skip that comparison. --- .../apache/james/mailbox/cassandra/mail/CassandraMessageIdMapper.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/mail/CassandraMessageIdMapper.java b/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/mail/CassandraMessageIdMapper.java index 26caba1..bee2732 100644 --- a/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/mail/CassandraMessageIdMapper.java +++ b/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/mail/CassandraMessageIdMapper.java @@ -20,7 +20,6 @@ package org.apache.james.mailbox.cassandra.mail; import java.time.Duration; import java.util.Collection; -import java.util.Comparator; import java.util.List; import java.util.Optional; @@ -99,7 +98,7 @@ public class CassandraMessageIdMapper implements MessageIdMapper { .flatMap(messageRepresentation -> attachmentLoader.addAttachmentToMessage(messageRepresentation, fetchType), cassandraConfiguration.getMessageReadChunkSize()) .groupBy(MailboxMessage::getMailboxId) .flatMap(this::keepMessageIfMailboxExists) - .collectSortedList(Comparator.comparing(MailboxMessage::getUid)) + .collectList() .block(); } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
