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/10/04 05:08:09 UTC
[james-project] 02/03: JAMES-2900 Use UnicastProcessor instead of
WorkQueueProcessor
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 080c35ca469fc9ef338002c79ecac5580d663579
Author: Gautier DI FOLCO <gd...@linagora.com>
AuthorDate: Wed Sep 25 16:10:18 2019 +0200
JAMES-2900 Use UnicastProcessor instead of WorkQueueProcessor
---
.../org/apache/james/mailetcontainer/impl/JamesMailSpoolerTest.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/server/mailet/mailetcontainer-camel/src/test/java/org/apache/james/mailetcontainer/impl/JamesMailSpoolerTest.java b/server/mailet/mailetcontainer-camel/src/test/java/org/apache/james/mailetcontainer/impl/JamesMailSpoolerTest.java
index db43fcc..7a10d13 100644
--- a/server/mailet/mailetcontainer-camel/src/test/java/org/apache/james/mailetcontainer/impl/JamesMailSpoolerTest.java
+++ b/server/mailet/mailetcontainer-camel/src/test/java/org/apache/james/mailetcontainer/impl/JamesMailSpoolerTest.java
@@ -46,7 +46,7 @@ import org.awaitility.Awaitility;
import org.awaitility.core.ConditionFactory;
import org.junit.jupiter.api.Test;
-import reactor.core.publisher.WorkQueueProcessor;
+import reactor.core.publisher.UnicastProcessor;
class JamesMailSpoolerTest {
private static final ConditionFactory CALMLY_AWAIT = Awaitility
@@ -62,7 +62,7 @@ class JamesMailSpoolerTest {
JamesMailSpooler spooler = new JamesMailSpooler(metricFactory);
MailQueueFactory<?> queueFactory = mock(MailQueueFactory.class);
- WorkQueueProcessor<MockedMailQueueItem> workQueue = WorkQueueProcessor.create("fakeMQ", 1);
+ UnicastProcessor<MockedMailQueueItem> workQueue = UnicastProcessor.create();
MockedMailQueueItem item = new MockedMailQueueItem();
item.addCallback(isDone -> {
if (!isDone) {
@@ -98,7 +98,7 @@ class JamesMailSpoolerTest {
JamesMailSpooler spooler = new JamesMailSpooler(metricFactory);
MailQueueFactory<?> queueFactory = mock(MailQueueFactory.class);
- WorkQueueProcessor<MockedMailQueueItem> workQueue = WorkQueueProcessor.create("fakeMQ", 1);
+ UnicastProcessor<MockedMailQueueItem> workQueue = UnicastProcessor.create();
MockedMailQueueItem item = new MockedMailQueueItem();
item.addCallback(isDone -> {
if (!isDone) {
---------------------------------------------------------------------
To unsubscribe, e-mail: server-dev-unsubscribe@james.apache.org
For additional commands, e-mail: server-dev-help@james.apache.org