This is an automated email from the ASF dual-hosted git repository. rouazana pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/james-project.git
commit e99bc34eaf358fb887d485d6657293006e58d9fc Author: Matthieu Baechler <[email protected]> AuthorDate: Wed Oct 9 15:23:12 2019 +0200 JAMES-2813 run AdditionalInformation polling into an elastic scheduler --- .../src/main/java/org/apache/james/task/SerialTaskManagerWorker.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) 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 org.slf4j.LoggerFactory; 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 @@ public class SerialTaskManagerWorker implements TaskManagerWorker { 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)); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
