JAMES-2292 too long delays are not handled well by DelayedQueue, use 100 years as a long delay
Project: http://git-wip-us.apache.org/repos/asf/james-project/repo Commit: http://git-wip-us.apache.org/repos/asf/james-project/commit/eedb206e Tree: http://git-wip-us.apache.org/repos/asf/james-project/tree/eedb206e Diff: http://git-wip-us.apache.org/repos/asf/james-project/diff/eedb206e Branch: refs/heads/master Commit: eedb206e2259081a17efb236d5166f79c4c7d86c Parents: fe252c2 Author: Matthieu Baechler <[email protected]> Authored: Wed Jan 24 17:24:45 2018 +0100 Committer: Matthieu Baechler <[email protected]> Committed: Wed Jan 24 17:24:45 2018 +0100 ---------------------------------------------------------------------- .../org/apache/james/queue/api/DelayedMailQueueContract.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/james-project/blob/eedb206e/server/queue/queue-api/src/test/java/org/apache/james/queue/api/DelayedMailQueueContract.java ---------------------------------------------------------------------- diff --git a/server/queue/queue-api/src/test/java/org/apache/james/queue/api/DelayedMailQueueContract.java b/server/queue/queue-api/src/test/java/org/apache/james/queue/api/DelayedMailQueueContract.java index f68f5b0..16a312f 100644 --- a/server/queue/queue-api/src/test/java/org/apache/james/queue/api/DelayedMailQueueContract.java +++ b/server/queue/queue-api/src/test/java/org/apache/james/queue/api/DelayedMailQueueContract.java @@ -67,7 +67,7 @@ public interface DelayedMailQueueContract { default void enqueueWithReasonablyLongDelayShouldDelayMail(ExecutorService executorService) throws Exception { getMailQueue().enQueue(defaultMail() .build(), - 365 * 1000, + 365 * 10, TimeUnit.DAYS); Future<?> future = executorService.submit(Throwing.runnable(() -> getMailQueue().deQueue())); @@ -79,7 +79,7 @@ public interface DelayedMailQueueContract { default void enqueueWithVeryLongDelayShouldDelayMail(ExecutorService executorService) throws Exception { getMailQueue().enQueue(defaultMail() .build(), - Long.MAX_VALUE / (3600 * 24), + 100 * 365, TimeUnit.DAYS); Future<?> future = executorService.submit(Throwing.runnable(() -> getMailQueue().deQueue())); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
