You are viewing a plain text version of this content. The canonical link for it is here.
Posted to server-dev@james.apache.org by bt...@apache.org on 2020/01/07 07:34:05 UTC

[james-project] 11/16: JAMES-2993 Using elastic scheduler in recomputing all

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 8c7a64f1e779c4279383f9405c9b269b70184016
Author: Tran Tien Duc <dt...@linagora.com>
AuthorDate: Tue Dec 24 10:47:03 2019 +0700

    JAMES-2993 Using elastic scheduler in recomputing all
---
 .../webadmin/data/jmap/RecomputeAllFastViewProjectionItemsTask.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/server/protocols/webadmin/webadmin-jmap/src/main/java/org/apache/james/webadmin/data/jmap/RecomputeAllFastViewProjectionItemsTask.java b/server/protocols/webadmin/webadmin-jmap/src/main/java/org/apache/james/webadmin/data/jmap/RecomputeAllFastViewProjectionItemsTask.java
index 5a95d37..4ef9365 100644
--- a/server/protocols/webadmin/webadmin-jmap/src/main/java/org/apache/james/webadmin/data/jmap/RecomputeAllFastViewProjectionItemsTask.java
+++ b/server/protocols/webadmin/webadmin-jmap/src/main/java/org/apache/james/webadmin/data/jmap/RecomputeAllFastViewProjectionItemsTask.java
@@ -117,7 +117,7 @@ public class RecomputeAllFastViewProjectionItemsTask implements Task {
     @Override
     public Result run() {
         corrector.correctAllProjectionItems(progress)
-            .subscribeOn(Schedulers.boundedElastic())
+            .subscribeOn(Schedulers.elastic())
             .block();
 
         if (progress.failed()) {


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