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 9097b9abb1c0711738a987208d0b8c6bba43c63f Author: Benoit Tellier <[email protected]> AuthorDate: Fri Jun 4 14:22:44 2021 +0700 [PERFORMANCE] CassandraMailRepositoryKeysDAO should use CassandraAsyncExecutor::executeRows --- .../mailrepository/cassandra/CassandraMailRepositoryKeysDAO.java | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/server/mailrepository/mailrepository-cassandra/src/main/java/org/apache/james/mailrepository/cassandra/CassandraMailRepositoryKeysDAO.java b/server/mailrepository/mailrepository-cassandra/src/main/java/org/apache/james/mailrepository/cassandra/CassandraMailRepositoryKeysDAO.java index 897e2a5..7bbc3c9 100644 --- a/server/mailrepository/mailrepository-cassandra/src/main/java/org/apache/james/mailrepository/cassandra/CassandraMailRepositoryKeysDAO.java +++ b/server/mailrepository/mailrepository-cassandra/src/main/java/org/apache/james/mailrepository/cassandra/CassandraMailRepositoryKeysDAO.java @@ -28,8 +28,6 @@ import static org.apache.james.mailrepository.cassandra.MailRepositoryTable.KEYS import static org.apache.james.mailrepository.cassandra.MailRepositoryTable.MAIL_KEY; import static org.apache.james.mailrepository.cassandra.MailRepositoryTable.REPOSITORY_NAME; -import java.util.function.Function; - import javax.inject.Inject; import org.apache.james.backends.cassandra.utils.CassandraAsyncExecutor; @@ -86,9 +84,8 @@ public class CassandraMailRepositoryKeysDAO { } public Flux<MailKey> list(MailRepositoryUrl url) { - return executor.execute(listKeys.bind() + return executor.executeRows(listKeys.bind() .setString(REPOSITORY_NAME, url.asString())) - .flatMapIterable(Function.identity()) .map(row -> new MailKey(row.getString(MAIL_KEY))); } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
