You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@james.apache.org by rc...@apache.org on 2021/01/29 03:09:09 UTC
[james-project] 09/13: JAMES-3494 Stop waiting forever
This is an automated email from the ASF dual-hosted git repository.
rcordier pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/james-project.git
commit 4c8e8ecd9f911f7bab2e18ae6072b9885f25d489
Author: Benoit Tellier <bt...@linagora.com>
AuthorDate: Tue Jan 26 08:27:16 2021 +0700
JAMES-3494 Stop waiting forever
---
.../java/org/apache/james/adapter/mailbox/ReIndexerManagement.java | 5 +++--
.../src/test/java/org/apache/james/task/TaskManagerContract.java | 2 +-
2 files changed, 4 insertions(+), 3 deletions(-)
diff --git a/server/container/mailbox-jmx/src/main/java/org/apache/james/adapter/mailbox/ReIndexerManagement.java b/server/container/mailbox-jmx/src/main/java/org/apache/james/adapter/mailbox/ReIndexerManagement.java
index 3cf9675..2612d01 100644
--- a/server/container/mailbox-jmx/src/main/java/org/apache/james/adapter/mailbox/ReIndexerManagement.java
+++ b/server/container/mailbox-jmx/src/main/java/org/apache/james/adapter/mailbox/ReIndexerManagement.java
@@ -22,6 +22,7 @@ package org.apache.james.adapter.mailbox;
import java.io.Closeable;
import java.io.IOException;
import java.time.Duration;
+import java.time.temporal.ChronoUnit;
import javax.inject.Inject;
import javax.inject.Named;
@@ -54,7 +55,7 @@ public class ReIndexerManagement implements ReIndexerManagementMBean {
.addContext(MDCBuilder.ACTION, "reIndex")
.build()) {
TaskId taskId = taskManager.submit(reIndexer.reIndex(new MailboxPath(namespace, Username.of(user), name), RunningOptions.DEFAULT));
- taskManager.await(taskId, Duration.ofMillis(Long.MAX_VALUE));
+ taskManager.await(taskId, Duration.of(365, ChronoUnit.DAYS));
} catch (IOException | TaskManager.ReachedTimeoutException e) {
throw new RuntimeException(e);
}
@@ -68,7 +69,7 @@ public class ReIndexerManagement implements ReIndexerManagementMBean {
.addContext(MDCBuilder.ACTION, "reIndex")
.build()) {
TaskId taskId = taskManager.submit(reIndexer.reIndex(RunningOptions.DEFAULT));
- taskManager.await(taskId, Duration.ofMillis(Long.MAX_VALUE));
+ taskManager.await(taskId, Duration.of(365, ChronoUnit.DAYS));
} catch (IOException | TaskManager.ReachedTimeoutException e) {
throw new RuntimeException(e);
}
diff --git a/server/task/task-api/src/test/java/org/apache/james/task/TaskManagerContract.java b/server/task/task-api/src/test/java/org/apache/james/task/TaskManagerContract.java
index 406671f..517c737 100644
--- a/server/task/task-api/src/test/java/org/apache/james/task/TaskManagerContract.java
+++ b/server/task/task-api/src/test/java/org/apache/james/task/TaskManagerContract.java
@@ -47,7 +47,7 @@ public interface TaskManagerContract {
.pollDelay(slowPacedPollInterval)
.await();
ConditionFactory awaitAtMostFiveSeconds = calmlyAwait.atMost(FIVE_SECONDS);
- java.time.Duration TIMEOUT = java.time.Duration.ofMillis(Long.MAX_VALUE);
+ java.time.Duration TIMEOUT = java.time.Duration.ofMinutes(15);
TaskManager taskManager();
---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscribe@james.apache.org
For additional commands, e-mail: notifications-help@james.apache.org