JAMES-2541 Adding runSuccessfullyWithin helper method to ConcurrentTestRunner
Note that is: - enforce error on order of calls (checking exceptions while not running) - reduce the boiler-plate Project: http://git-wip-us.apache.org/repos/asf/james-project/repo Commit: http://git-wip-us.apache.org/repos/asf/james-project/commit/f0b3f6ed Tree: http://git-wip-us.apache.org/repos/asf/james-project/tree/f0b3f6ed Diff: http://git-wip-us.apache.org/repos/asf/james-project/diff/f0b3f6ed Branch: refs/heads/master Commit: f0b3f6edde5e59e4ca94c4106ea7f5b03b48208e Parents: c73758e Author: Benoit Tellier <[email protected]> Authored: Tue Sep 11 11:14:24 2018 +0700 Committer: Benoit Tellier <[email protected]> Committed: Thu Oct 4 15:12:07 2018 +0700 ---------------------------------------------------------------------- .../org/apache/james/mailbox/MailboxManagerTest.java | 5 +---- .../mail/CassandraMailboxMapperConcurrencyTest.java | 8 ++------ .../listeners/QuotaThresholdMailingIntegrationTest.java | 4 +--- .../mailbox/store/mail/model/MessageIdMapperTest.java | 10 ++-------- .../mailbox/store/mail/model/MessageMapperTest.java | 10 ++-------- .../james/mailbox/tika/CachingTextExtractorTest.java | 5 +---- .../james/imap/processor/base/UidMsnConverterTest.java | 12 +++--------- .../james/protocols/smtp/AbstractSMTPServerTest.java | 5 +---- .../james/util/concurrency/ConcurrentTestRunner.java | 11 +++++++++++ .../api/MailRepositoryUrlStoreContract.java | 10 ++-------- .../memory/MemoryMailRepositoryStoreTest.java | 5 +---- .../transport/mailets/delivery/MailboxAppenderTest.java | 6 +++--- .../java/org/apache/james/jmap/ProvisioningTest.java | 4 +--- .../jmap/DefaultMailboxesProvisioningFilterTest.java | 5 +---- .../DefaultMailboxesProvisioningFilterThreadTest.java | 5 ++--- .../james/jmap/UserProvisioningFilterThreadTest.java | 5 ++--- 16 files changed, 36 insertions(+), 74 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/james-project/blob/f0b3f6ed/mailbox/api/src/test/java/org/apache/james/mailbox/MailboxManagerTest.java ---------------------------------------------------------------------- diff --git a/mailbox/api/src/test/java/org/apache/james/mailbox/MailboxManagerTest.java b/mailbox/api/src/test/java/org/apache/james/mailbox/MailboxManagerTest.java index 2b67604..1108237 100644 --- a/mailbox/api/src/test/java/org/apache/james/mailbox/MailboxManagerTest.java +++ b/mailbox/api/src/test/java/org/apache/james/mailbox/MailboxManagerTest.java @@ -983,10 +983,7 @@ public abstract class MailboxManagerTest { ConcurrentTestRunner.builder() .operation((a, b) -> mailboxManager.createMailbox(MailboxPath.forUser(USER_1, mailboxName + a), session)) .threadCount(10) - .build() - .run() - .awaitTermination(1, TimeUnit.MINUTES) - .assertNoException(); + .runSuccessfullyWithin(1, TimeUnit.MINUTES); } @Test http://git-wip-us.apache.org/repos/asf/james-project/blob/f0b3f6ed/mailbox/cassandra/src/test/java/org/apache/james/mailbox/cassandra/mail/CassandraMailboxMapperConcurrencyTest.java ---------------------------------------------------------------------- diff --git a/mailbox/cassandra/src/test/java/org/apache/james/mailbox/cassandra/mail/CassandraMailboxMapperConcurrencyTest.java b/mailbox/cassandra/src/test/java/org/apache/james/mailbox/cassandra/mail/CassandraMailboxMapperConcurrencyTest.java index adc612b..997dcf5 100644 --- a/mailbox/cassandra/src/test/java/org/apache/james/mailbox/cassandra/mail/CassandraMailboxMapperConcurrencyTest.java +++ b/mailbox/cassandra/src/test/java/org/apache/james/mailbox/cassandra/mail/CassandraMailboxMapperConcurrencyTest.java @@ -65,9 +65,7 @@ class CassandraMailboxMapperConcurrencyTest { .operation((a, b) -> testee.save(new SimpleMailbox(MAILBOX_PATH, UID_VALIDITY))) .threadCount(THREAD_COUNT) .operationCount(OPERATION_COUNT) - .build() - .run() - .awaitTermination(1, TimeUnit.MINUTES); + .runSuccessfullyWithin(1, TimeUnit.MINUTES); assertThat(testee.list()).hasSize(1); } @@ -83,9 +81,7 @@ class CassandraMailboxMapperConcurrencyTest { .operation((a, b) -> testee.save(mailbox)) .threadCount(THREAD_COUNT) .operationCount(OPERATION_COUNT) - .build() - .run() - .awaitTermination(1, TimeUnit.MINUTES); + .runSuccessfullyWithin(1, TimeUnit.MINUTES); List<Mailbox> list = testee.list(); assertThat(list).hasSize(1); http://git-wip-us.apache.org/repos/asf/james-project/blob/f0b3f6ed/mailbox/plugin/quota-mailing/src/test/java/org/apache/james/mailbox/quota/mailing/listeners/QuotaThresholdMailingIntegrationTest.java ---------------------------------------------------------------------- diff --git a/mailbox/plugin/quota-mailing/src/test/java/org/apache/james/mailbox/quota/mailing/listeners/QuotaThresholdMailingIntegrationTest.java b/mailbox/plugin/quota-mailing/src/test/java/org/apache/james/mailbox/quota/mailing/listeners/QuotaThresholdMailingIntegrationTest.java index 3a7a2f3..7a825e5 100644 --- a/mailbox/plugin/quota-mailing/src/test/java/org/apache/james/mailbox/quota/mailing/listeners/QuotaThresholdMailingIntegrationTest.java +++ b/mailbox/plugin/quota-mailing/src/test/java/org/apache/james/mailbox/quota/mailing/listeners/QuotaThresholdMailingIntegrationTest.java @@ -214,9 +214,7 @@ public interface QuotaThresholdMailingIntegrationTest { ConcurrentTestRunner.builder() .operation((threadNb, step) -> testee.event(new QuotaUsageUpdatedEvent(BOB_SESSION, QUOTAROOT, Counts._40_PERCENT, Sizes._55_PERCENT, NOW))) .threadCount(10) - .build() - .run() - .awaitTermination(1, TimeUnit.MINUTES); + .runSuccessfullyWithin(1, TimeUnit.MINUTES); assertThat(mailetContext.getSentMails()) .hasSize(1); http://git-wip-us.apache.org/repos/asf/james-project/blob/f0b3f6ed/mailbox/store/src/test/java/org/apache/james/mailbox/store/mail/model/MessageIdMapperTest.java ---------------------------------------------------------------------- diff --git a/mailbox/store/src/test/java/org/apache/james/mailbox/store/mail/model/MessageIdMapperTest.java b/mailbox/store/src/test/java/org/apache/james/mailbox/store/mail/model/MessageIdMapperTest.java index 67dbe45..32e8766 100644 --- a/mailbox/store/src/test/java/org/apache/james/mailbox/store/mail/model/MessageIdMapperTest.java +++ b/mailbox/store/src/test/java/org/apache/james/mailbox/store/mail/model/MessageIdMapperTest.java @@ -684,10 +684,7 @@ public abstract class MessageIdMapperTest { FlagsUpdateMode.ADD)) .threadCount(threadCount) .operationCount(updateCount) - .build() - .run() - .awaitTermination(1, TimeUnit.MINUTES) - .assertNoException(); + .runSuccessfullyWithin(1, TimeUnit.MINUTES); List<MailboxMessage> messages = sut.find(ImmutableList.of(message1.getMessageId()), MessageMapper.FetchType.Body); assertThat(messages).hasSize(1); @@ -719,10 +716,7 @@ public abstract class MessageIdMapperTest { }) .threadCount(threadCount) .operationCount(updateCount) - .build() - .run() - .awaitTermination(1, TimeUnit.MINUTES) - .assertNoException(); + .runSuccessfullyWithin(1, TimeUnit.MINUTES); List<MailboxMessage> messages = sut.find(ImmutableList.of(message1.getMessageId()), MessageMapper.FetchType.Body); assertThat(messages).hasSize(1); http://git-wip-us.apache.org/repos/asf/james-project/blob/f0b3f6ed/mailbox/store/src/test/java/org/apache/james/mailbox/store/mail/model/MessageMapperTest.java ---------------------------------------------------------------------- diff --git a/mailbox/store/src/test/java/org/apache/james/mailbox/store/mail/model/MessageMapperTest.java b/mailbox/store/src/test/java/org/apache/james/mailbox/store/mail/model/MessageMapperTest.java index 08c5eea..2bb2a8e 100644 --- a/mailbox/store/src/test/java/org/apache/james/mailbox/store/mail/model/MessageMapperTest.java +++ b/mailbox/store/src/test/java/org/apache/james/mailbox/store/mail/model/MessageMapperTest.java @@ -802,10 +802,7 @@ public abstract class MessageMapperTest { MessageRange.one(message1.getUid()))) .threadCount(threadCount) .operationCount(updateCount) - .build() - .run() - .awaitTermination(1, TimeUnit.MINUTES) - .assertNoException(); + .runSuccessfullyWithin(1, TimeUnit.MINUTES); Iterator<MailboxMessage> messages = messageMapper.findInMailbox(benwaInboxMailbox, MessageRange.one(message1.getUid()), FetchType.Metadata, 1); @@ -835,10 +832,7 @@ public abstract class MessageMapperTest { }) .threadCount(threadCount) .operationCount(updateCount) - .build() - .run() - .awaitTermination(1, TimeUnit.MINUTES) - .assertNoException(); + .runSuccessfullyWithin(1, TimeUnit.MINUTES); Iterator<MailboxMessage> messages = messageMapper.findInMailbox(benwaInboxMailbox, MessageRange.one(message1.getUid()), FetchType.Metadata, 1); http://git-wip-us.apache.org/repos/asf/james-project/blob/f0b3f6ed/mailbox/tika/src/test/java/org/apache/james/mailbox/tika/CachingTextExtractorTest.java ---------------------------------------------------------------------- diff --git a/mailbox/tika/src/test/java/org/apache/james/mailbox/tika/CachingTextExtractorTest.java b/mailbox/tika/src/test/java/org/apache/james/mailbox/tika/CachingTextExtractorTest.java index 12287be..2b0beb4 100644 --- a/mailbox/tika/src/test/java/org/apache/james/mailbox/tika/CachingTextExtractorTest.java +++ b/mailbox/tika/src/test/java/org/apache/james/mailbox/tika/CachingTextExtractorTest.java @@ -188,10 +188,7 @@ public class CachingTextExtractorTest { ConcurrentTestRunner.builder() .operation((a, b) -> textExtractor.extractContent(INPUT_STREAM.get(), CONTENT_TYPE)) .threadCount(10) - .build() - .run() - .awaitTermination(1, TimeUnit.MINUTES) - .assertNoException(); + .runSuccessfullyWithin(1, TimeUnit.MINUTES); verify(wrappedTextExtractor, times(1)).extractContent(any(), any()); } http://git-wip-us.apache.org/repos/asf/james-project/blob/f0b3f6ed/protocols/imap/src/test/java/org/apache/james/imap/processor/base/UidMsnConverterTest.java ---------------------------------------------------------------------- diff --git a/protocols/imap/src/test/java/org/apache/james/imap/processor/base/UidMsnConverterTest.java b/protocols/imap/src/test/java/org/apache/james/imap/processor/base/UidMsnConverterTest.java index 2092cc3..44f82ea 100644 --- a/protocols/imap/src/test/java/org/apache/james/imap/processor/base/UidMsnConverterTest.java +++ b/protocols/imap/src/test/java/org/apache/james/imap/processor/base/UidMsnConverterTest.java @@ -380,9 +380,7 @@ public class UidMsnConverterTest { }) .threadCount(2) .operationCount(initialCount) - .build() - .run() - .awaitTermination(10, TimeUnit.SECONDS); + .runSuccessfullyWithin(10, TimeUnit.SECONDS); ImmutableMap.Builder<Integer, MessageUid> resultBuilder = ImmutableMap.builder(); for (int i = 1; i <= initialCount; i++) { @@ -401,9 +399,7 @@ public class UidMsnConverterTest { .operation((threadNumber, step) -> testee.addUid(MessageUid.of((threadNumber * operationCount) + (step + 1)))) .threadCount(threadCount) .operationCount(operationCount) - .build() - .run() - .awaitTermination(10, TimeUnit.SECONDS); + .runSuccessfullyWithin(10, TimeUnit.SECONDS); ImmutableMap.Builder<Integer, MessageUid> resultBuilder = ImmutableMap.builder(); for (int i = 1; i <= threadCount * operationCount; i++) { @@ -425,9 +421,7 @@ public class UidMsnConverterTest { .operation((threadNumber, step) -> testee.remove(MessageUid.of((threadNumber * operationCount) + (step + 1)))) .threadCount(threadCount) .operationCount(operationCount) - .build() - .run() - .awaitTermination(10, TimeUnit.SECONDS); + .runSuccessfullyWithin(10, TimeUnit.SECONDS); ImmutableMap.Builder<Integer, MessageUid> resultBuilder = ImmutableMap.builder(); for (int i = 1; i <= operationCount; i++) { http://git-wip-us.apache.org/repos/asf/james-project/blob/f0b3f6ed/protocols/smtp/src/test/java/org/apache/james/protocols/smtp/AbstractSMTPServerTest.java ---------------------------------------------------------------------- diff --git a/protocols/smtp/src/test/java/org/apache/james/protocols/smtp/AbstractSMTPServerTest.java b/protocols/smtp/src/test/java/org/apache/james/protocols/smtp/AbstractSMTPServerTest.java index 21fa151..d62cfea 100644 --- a/protocols/smtp/src/test/java/org/apache/james/protocols/smtp/AbstractSMTPServerTest.java +++ b/protocols/smtp/src/test/java/org/apache/james/protocols/smtp/AbstractSMTPServerTest.java @@ -106,10 +106,7 @@ public abstract class AbstractSMTPServerTest { ConcurrentTestRunner.builder() .operation((threadNumber, step) -> send(finalServer, bindedAddress, mailContent)) .threadCount(4) - .build() - .run() - .awaitTermination(1, TimeUnit.MINUTES) - .assertNoException(); + .runSuccessfullyWithin(1, TimeUnit.MINUTES); Iterator<MailEnvelope> queued = hook.getQueued().iterator(); assertThat(queued.hasNext()).isTrue(); http://git-wip-us.apache.org/repos/asf/james-project/blob/f0b3f6ed/server/container/util/src/main/java/org/apache/james/util/concurrency/ConcurrentTestRunner.java ---------------------------------------------------------------------- diff --git a/server/container/util/src/main/java/org/apache/james/util/concurrency/ConcurrentTestRunner.java b/server/container/util/src/main/java/org/apache/james/util/concurrency/ConcurrentTestRunner.java index 91b6d58..eb24bb0 100644 --- a/server/container/util/src/main/java/org/apache/james/util/concurrency/ConcurrentTestRunner.java +++ b/server/container/util/src/main/java/org/apache/james/util/concurrency/ConcurrentTestRunner.java @@ -74,6 +74,11 @@ public class ConcurrentTestRunner { operationCount.orElse(DEFAULT_OPERATION_COUNT), operation); } + + public ConcurrentTestRunner runSuccessfullyWithin(long time, TimeUnit unit) throws InterruptedException, ExecutionException { + return build() + .runSuccessfullyWithin(time, unit); + } } public interface ConcurrentOperation { @@ -156,4 +161,10 @@ public class ConcurrentTestRunner { } return this; } + + public ConcurrentTestRunner runSuccessfullyWithin(long time, TimeUnit unit) throws InterruptedException, ExecutionException { + return run() + .awaitTermination(time, unit) + .assertNoException(); + } } http://git-wip-us.apache.org/repos/asf/james-project/blob/f0b3f6ed/server/data/data-api/src/test/java/org/apache/james/mailrepository/api/MailRepositoryUrlStoreContract.java ---------------------------------------------------------------------- diff --git a/server/data/data-api/src/test/java/org/apache/james/mailrepository/api/MailRepositoryUrlStoreContract.java b/server/data/data-api/src/test/java/org/apache/james/mailrepository/api/MailRepositoryUrlStoreContract.java index c0fd293..a476e20 100644 --- a/server/data/data-api/src/test/java/org/apache/james/mailrepository/api/MailRepositoryUrlStoreContract.java +++ b/server/data/data-api/src/test/java/org/apache/james/mailrepository/api/MailRepositoryUrlStoreContract.java @@ -79,10 +79,7 @@ public interface MailRepositoryUrlStoreContract { .operation((a, b) -> store.add(MailRepositoryUrl.from("proto://" + a + "/" + b))) .threadCount(threadCount) .operationCount(operationCount) - .build() - .run() - .awaitTermination(1, TimeUnit.MINUTES) - .assertNoException(); + .runSuccessfullyWithin(1, TimeUnit.MINUTES); assertThat(store.listDistinct()).hasSize(threadCount * operationCount); } @@ -95,10 +92,7 @@ public interface MailRepositoryUrlStoreContract { .operation((a, b) -> store.add(MailRepositoryUrl.from("proto://" + b))) .threadCount(10) .operationCount(operationCount) - .build() - .run() - .awaitTermination(1, TimeUnit.MINUTES) - .assertNoException(); + .runSuccessfullyWithin(1, TimeUnit.MINUTES); assertThat(store.listDistinct()).hasSize(operationCount); } http://git-wip-us.apache.org/repos/asf/james-project/blob/f0b3f6ed/server/data/data-memory/src/test/java/org/apache/james/mailrepository/memory/MemoryMailRepositoryStoreTest.java ---------------------------------------------------------------------- diff --git a/server/data/data-memory/src/test/java/org/apache/james/mailrepository/memory/MemoryMailRepositoryStoreTest.java b/server/data/data-memory/src/test/java/org/apache/james/mailrepository/memory/MemoryMailRepositoryStoreTest.java index a6684a4..5bbd308 100644 --- a/server/data/data-memory/src/test/java/org/apache/james/mailrepository/memory/MemoryMailRepositoryStoreTest.java +++ b/server/data/data-memory/src/test/java/org/apache/james/mailrepository/memory/MemoryMailRepositoryStoreTest.java @@ -239,10 +239,7 @@ public class MemoryMailRepositoryStoreTest { .setText("Any body")) .build())) .threadCount(10) - .build() - .run() - .awaitTermination(1, TimeUnit.MINUTES) - .assertNoException(); + .runSuccessfullyWithin(1, TimeUnit.MINUTES); long actualSize = repositoryStore.get(url).get().size(); http://git-wip-us.apache.org/repos/asf/james-project/blob/f0b3f6ed/server/mailet/mailets/src/test/java/org/apache/james/transport/mailets/delivery/MailboxAppenderTest.java ---------------------------------------------------------------------- diff --git a/server/mailet/mailets/src/test/java/org/apache/james/transport/mailets/delivery/MailboxAppenderTest.java b/server/mailet/mailets/src/test/java/org/apache/james/transport/mailets/delivery/MailboxAppenderTest.java index 23f6d4c..ae56e62 100644 --- a/server/mailet/mailets/src/test/java/org/apache/james/transport/mailets/delivery/MailboxAppenderTest.java +++ b/server/mailet/mailets/src/test/java/org/apache/james/transport/mailets/delivery/MailboxAppenderTest.java @@ -22,6 +22,8 @@ package org.apache.james.transport.mailets.delivery; import static org.assertj.core.api.Assertions.assertThat; import static org.assertj.core.api.Assertions.assertThatThrownBy; +import java.util.concurrent.TimeUnit; + import javax.mail.MessagingException; import javax.mail.internet.MimeMessage; @@ -128,8 +130,6 @@ public class MailboxAppenderTest { ConcurrentTestRunner.builder() .operation((a, b) -> testee.append(mimeMessage, USER, FOLDER + "/any")) .threadCount(100) - .build() - .run() - .assertNoException(); + .runSuccessfullyWithin(1, TimeUnit.MINUTES); } } http://git-wip-us.apache.org/repos/asf/james-project/blob/f0b3f6ed/server/protocols/jmap-integration-testing/jmap-integration-testing-common/src/test/java/org/apache/james/jmap/ProvisioningTest.java ---------------------------------------------------------------------- diff --git a/server/protocols/jmap-integration-testing/jmap-integration-testing-common/src/test/java/org/apache/james/jmap/ProvisioningTest.java b/server/protocols/jmap-integration-testing/jmap-integration-testing-common/src/test/java/org/apache/james/jmap/ProvisioningTest.java index e478a6c..e2f3f74 100644 --- a/server/protocols/jmap-integration-testing/jmap-integration-testing-common/src/test/java/org/apache/james/jmap/ProvisioningTest.java +++ b/server/protocols/jmap-integration-testing/jmap-integration-testing-common/src/test/java/org/apache/james/jmap/ProvisioningTest.java @@ -84,9 +84,7 @@ public abstract class ProvisioningTest { .body("[[\"getMailboxes\", {}, \"#0\"]]") .post("/jmap")) .threadCount(10) - .build() - .run() - .awaitTermination(1, TimeUnit.MINUTES); + .runSuccessfullyWithin(1, TimeUnit.MINUTES); given() .header("Authorization", token) http://git-wip-us.apache.org/repos/asf/james-project/blob/f0b3f6ed/server/protocols/jmap/src/test/java/org/apache/james/jmap/DefaultMailboxesProvisioningFilterTest.java ---------------------------------------------------------------------- diff --git a/server/protocols/jmap/src/test/java/org/apache/james/jmap/DefaultMailboxesProvisioningFilterTest.java b/server/protocols/jmap/src/test/java/org/apache/james/jmap/DefaultMailboxesProvisioningFilterTest.java index facdae7..6db411a 100644 --- a/server/protocols/jmap/src/test/java/org/apache/james/jmap/DefaultMailboxesProvisioningFilterTest.java +++ b/server/protocols/jmap/src/test/java/org/apache/james/jmap/DefaultMailboxesProvisioningFilterTest.java @@ -92,10 +92,7 @@ public class DefaultMailboxesProvisioningFilterTest { ConcurrentTestRunner.builder() .operation((threadNumber, step) -> testee.createMailboxesIfNeeded(session)) .threadCount(10) - .build() - .run() - .awaitTermination(10, TimeUnit.SECONDS) - .assertNoException(); + .runSuccessfullyWithin(10, TimeUnit.SECONDS); assertThat(mailboxManager.list(session)) .containsOnlyElementsOf(DefaultMailboxes.DEFAULT_MAILBOXES http://git-wip-us.apache.org/repos/asf/james-project/blob/f0b3f6ed/server/protocols/jmap/src/test/java/org/apache/james/jmap/DefaultMailboxesProvisioningFilterThreadTest.java ---------------------------------------------------------------------- diff --git a/server/protocols/jmap/src/test/java/org/apache/james/jmap/DefaultMailboxesProvisioningFilterThreadTest.java b/server/protocols/jmap/src/test/java/org/apache/james/jmap/DefaultMailboxesProvisioningFilterThreadTest.java index 7060147..90f1350 100644 --- a/server/protocols/jmap/src/test/java/org/apache/james/jmap/DefaultMailboxesProvisioningFilterThreadTest.java +++ b/server/protocols/jmap/src/test/java/org/apache/james/jmap/DefaultMailboxesProvisioningFilterThreadTest.java @@ -26,6 +26,7 @@ import static org.mockito.Mockito.mock; import static org.mockito.Mockito.when; import java.util.Optional; +import java.util.concurrent.TimeUnit; import org.apache.james.mailbox.MailboxManager; import org.apache.james.mailbox.MailboxSession; @@ -67,8 +68,6 @@ public class DefaultMailboxesProvisioningFilterThreadTest { .builder() .operation((threadNumber, step) -> sut.createMailboxesIfNeeded(session)) .threadCount(2) - .build() - .run() - .assertNoException(); + .runSuccessfullyWithin(1, TimeUnit.MINUTES); } } http://git-wip-us.apache.org/repos/asf/james-project/blob/f0b3f6ed/server/protocols/jmap/src/test/java/org/apache/james/jmap/UserProvisioningFilterThreadTest.java ---------------------------------------------------------------------- diff --git a/server/protocols/jmap/src/test/java/org/apache/james/jmap/UserProvisioningFilterThreadTest.java b/server/protocols/jmap/src/test/java/org/apache/james/jmap/UserProvisioningFilterThreadTest.java index 93a3270..f41515c 100644 --- a/server/protocols/jmap/src/test/java/org/apache/james/jmap/UserProvisioningFilterThreadTest.java +++ b/server/protocols/jmap/src/test/java/org/apache/james/jmap/UserProvisioningFilterThreadTest.java @@ -19,6 +19,7 @@ package org.apache.james.jmap; import java.util.concurrent.ExecutionException; +import java.util.concurrent.TimeUnit; import org.apache.james.mailbox.MailboxSession; import org.apache.james.mailbox.mock.MockMailboxSession; @@ -47,9 +48,7 @@ public class UserProvisioningFilterThreadTest { .builder() .operation((threadNumber, step) -> sut.createAccountIfNeeded(session)) .threadCount(2) - .build() - .run() - .assertNoException(); + .runSuccessfullyWithin(1, TimeUnit.MINUTES); } } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
