JAMES-2541 Improve stability for MailQueueContract::deQueueShouldWaitForAMailToBeEnqueued
Project: http://git-wip-us.apache.org/repos/asf/james-project/repo Commit: http://git-wip-us.apache.org/repos/asf/james-project/commit/7dc41ae7 Tree: http://git-wip-us.apache.org/repos/asf/james-project/tree/7dc41ae7 Diff: http://git-wip-us.apache.org/repos/asf/james-project/diff/7dc41ae7 Branch: refs/heads/master Commit: 7dc41ae7e93750b444d510c4ec118b443ec5c26b Parents: d8b8527 Author: Benoit Tellier <[email protected]> Authored: Fri Sep 7 16:38:55 2018 +0700 Committer: Benoit Tellier <[email protected]> Committed: Mon Sep 10 17:19:38 2018 +0700 ---------------------------------------------------------------------- .../java/org/apache/james/queue/api/MailQueueContract.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/james-project/blob/7dc41ae7/server/queue/queue-api/src/test/java/org/apache/james/queue/api/MailQueueContract.java ---------------------------------------------------------------------- diff --git a/server/queue/queue-api/src/test/java/org/apache/james/queue/api/MailQueueContract.java b/server/queue/queue-api/src/test/java/org/apache/james/queue/api/MailQueueContract.java index 377cf3f..ac68e87 100644 --- a/server/queue/queue-api/src/test/java/org/apache/james/queue/api/MailQueueContract.java +++ b/server/queue/queue-api/src/test/java/org/apache/james/queue/api/MailQueueContract.java @@ -330,11 +330,13 @@ public interface MailQueueContract { @Test default void deQueueShouldWaitForAMailToBeEnqueued(ExecutorService executorService) throws Exception { + MailQueue testee = getMailQueue(); + Mail mail = defaultMail() .name("name") .build(); - Future<MailQueue.MailQueueItem> tryDequeue = executorService.submit(() -> getMailQueue().deQueue()); - getMailQueue().enQueue(mail); + Future<MailQueue.MailQueueItem> tryDequeue = executorService.submit(testee::deQueue); + testee.enQueue(mail); assertThat(tryDequeue.get().getMail().getName()).isEqualTo("name"); } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
