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 96d47a52c65b16272408cd4cfcd8af50243c8c23 Author: Benoit Tellier <[email protected]> AuthorDate: Tue Nov 17 17:40:13 2020 +0700 JAMES-3440 Cassandra implementation for EmailQueryView --- .../main/java/org/apache/james/modules/data/CassandraJmapModule.java | 2 ++ .../james/jmap/cassandra/projections/CassandraEmailQueryView.java | 1 - 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/server/container/guice/cassandra-guice/src/main/java/org/apache/james/modules/data/CassandraJmapModule.java b/server/container/guice/cassandra-guice/src/main/java/org/apache/james/modules/data/CassandraJmapModule.java index e970220..859e8c2 100644 --- a/server/container/guice/cassandra-guice/src/main/java/org/apache/james/modules/data/CassandraJmapModule.java +++ b/server/container/guice/cassandra-guice/src/main/java/org/apache/james/modules/data/CassandraJmapModule.java @@ -36,6 +36,7 @@ import org.apache.james.jmap.cassandra.access.CassandraAccessModule; import org.apache.james.jmap.cassandra.access.CassandraAccessTokenRepository; import org.apache.james.jmap.cassandra.filtering.FilteringRuleSetDefineDTOModules; import org.apache.james.jmap.cassandra.projections.CassandraEmailQueryView; +import org.apache.james.jmap.cassandra.projections.CassandraEmailQueryViewModule; import org.apache.james.jmap.cassandra.projections.CassandraMessageFastViewProjection; import org.apache.james.jmap.cassandra.projections.CassandraMessageFastViewProjectionModule; import org.apache.james.jmap.cassandra.vacation.CassandraNotificationRegistry; @@ -79,6 +80,7 @@ public class CassandraJmapModule extends AbstractModule { cassandraDataDefinitions.addBinding().toInstance(CassandraVacationModule.MODULE); cassandraDataDefinitions.addBinding().toInstance(CassandraNotificationRegistryModule.MODULE); cassandraDataDefinitions.addBinding().toInstance(CassandraMessageFastViewProjectionModule.MODULE); + cassandraDataDefinitions.addBinding().toInstance(CassandraEmailQueryViewModule.MODULE); Multibinder<EventDTOModule<? extends Event, ? extends EventDTO>> eventDTOModuleBinder = Multibinder.newSetBinder(binder(), new TypeLiteral<EventDTOModule<? extends Event, ? extends EventDTO>>() {}); eventDTOModuleBinder.addBinding().toInstance(FilteringRuleSetDefineDTOModules.FILTERING_RULE_SET_DEFINED); diff --git a/server/data/data-jmap-cassandra/src/main/java/org/apache/james/jmap/cassandra/projections/CassandraEmailQueryView.java b/server/data/data-jmap-cassandra/src/main/java/org/apache/james/jmap/cassandra/projections/CassandraEmailQueryView.java index 610fba5..4eb2c5a 100644 --- a/server/data/data-jmap-cassandra/src/main/java/org/apache/james/jmap/cassandra/projections/CassandraEmailQueryView.java +++ b/server/data/data-jmap-cassandra/src/main/java/org/apache/james/jmap/cassandra/projections/CassandraEmailQueryView.java @@ -60,7 +60,6 @@ import reactor.core.publisher.Mono; public class CassandraEmailQueryView implements EmailQueryView { private static final String LIMIT_MARKER = "LIMIT_BIND_MARKER"; - private static final int CONCURRENCY = 10; private final CassandraMessageId.Factory messageIdFactory; private final CassandraAsyncExecutor executor; --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
