This is an automated email from the ASF dual-hosted git repository. btellier pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/james-project.git
commit a9cb75f3fdd9aeaf761eb9838e12714791284577 Author: Benoit Tellier <[email protected]> AuthorDate: Wed Mar 20 13:32:36 2019 +0700 MAILBOX-368 Fix asynchronous issues within EventDeadLettersContract --- .../org/apache/james/mailbox/events/EventDeadLettersContract.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/mailbox/api/src/test/java/org/apache/james/mailbox/events/EventDeadLettersContract.java b/mailbox/api/src/test/java/org/apache/james/mailbox/events/EventDeadLettersContract.java index 4b3bca8..af49e42 100644 --- a/mailbox/api/src/test/java/org/apache/james/mailbox/events/EventDeadLettersContract.java +++ b/mailbox/api/src/test/java/org/apache/james/mailbox/events/EventDeadLettersContract.java @@ -178,7 +178,7 @@ interface EventDeadLettersContract { Event.EventId eventId = Event.EventId.random(); EventDeadLetters.InsertionId insertionId = EventDeadLetters.InsertionId.random(); storedInsertionIds.put(threadNumber, insertionId); - eventDeadLetters.store(groups.get(threadNumber), event(eventId), insertionId).subscribe(); + eventDeadLetters.store(groups.get(threadNumber), event(eventId), insertionId).block(); }) .threadCount(THREAD_COUNT) .operationCount(OPERATION_COUNT) @@ -278,7 +278,7 @@ interface EventDeadLettersContract { Event.EventId eventId = Event.EventId.random(); EventDeadLetters.InsertionId insertionId = EventDeadLetters.InsertionId.random(); storedInsertionIds.put(operationIndex, insertionId); - eventDeadLetters.store(groups.get(threadNumber), event(eventId), insertionId).subscribe(); + eventDeadLetters.store(groups.get(threadNumber), event(eventId), insertionId).block(); }) .threadCount(THREAD_COUNT) .operationCount(OPERATION_COUNT) @@ -288,7 +288,7 @@ interface EventDeadLettersContract { .operation((threadNumber, step) -> { int operationIndex = threadNumber * OPERATION_COUNT + step; eventDeadLetters.remove(groups.get(threadNumber), storedInsertionIds.get(operationIndex)) - .subscribe(); + .block(); }) .threadCount(THREAD_COUNT) .operationCount(OPERATION_COUNT) --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
