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 <[email protected]> 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: [email protected] For additional commands, e-mail: [email protected]
