You are viewing a plain text version of this content. The canonical link for it is here.
Posted to server-dev@james.apache.org by bt...@apache.org on 2019/03/21 03:10:24 UTC
[james-project] 02/02: MAILBOX-368 Fix asynchronous issues within
EventDeadLettersContract
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 <bt...@linagora.com>
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: server-dev-unsubscribe@james.apache.org
For additional commands, e-mail: server-dev-help@james.apache.org