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 ro...@apache.org on 2019/10/18 06:40:44 UTC
[james-project] 11/17: JAMES-2813 run AdditionalInformation polling
into an elastic scheduler
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 <ma...@apache.org>
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: server-dev-unsubscribe@james.apache.org
For additional commands, e-mail: server-dev-help@james.apache.org