commit e99bc34eaf358fb887d485d6657293006e58d9fc
author Matthieu Baechler <matthieu@apache.org> Wed Oct 09 15:23:12 2019 +0200
committer Raphael Ouazana <raphael.ouazana@linagora.com> Fri Oct 18 08:40:10 2019 +0200
tree 7a3d8f4ba511c15482c97222887b8f5f5025d796
parent 0f0b834878c2fb79b5357efd290c0d6ebcb6c8bd

JAMES-2813 run AdditionalInformation polling into an elastic scheduler

server/task/task-memory/src/main/java/org/apache/james/task/SerialTaskManagerWorker.java

diff --git a/server/task/task-memory/src/main/java/org/apache/james/task/SerialTaskManagerWorker.java b/server/task/task-memory/src/main/java/org/apache/james/task/SerialTaskManagerWorker.java
index 60b5a16..c296bf1 100644
--- a/server/task/task-memory/src/main/java/org/apache/james/task/SerialTaskManagerWorker.java
+++ b/server/task/task-memory/src/main/java/org/apache/james/task/SerialTaskManagerWorker.java
@@ -40,6 +40,7 @@
 import com.google.common.collect.Sets;
 import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
+import reactor.core.scheduler.Schedulers;
 import reactor.util.function.Tuple2;
 import reactor.util.function.Tuples;
 
@@ -111,7 +112,7 @@
 
     private Flux<TaskExecutionDetails.AdditionalInformation> pollAdditionalInformation(TaskWithId taskWithId) {
         return Mono.fromCallable(() -> taskWithId.getTask().details())
-            .delayElement(Duration.ofSeconds(1))
+            .delayElement(Duration.ofSeconds(1), Schedulers.boundedElastic())
             .repeat()
             .flatMap(Mono::justOrEmpty)
             .doOnNext(information -> listener.updated(taskWithId.getId(), information));