You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@james.apache.org by bt...@apache.org on 2021/06/09 07:26:16 UTC
[james-project] 07/07: [PERFORMANCE] CassandraMailRepositoryKeysDAO
should use CassandraAsyncExecutor::executeRows
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 <bt...@linagora.com>
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: notifications-unsubscribe@james.apache.org
For additional commands, e-mail: notifications-help@james.apache.org