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 1657eba301872271dc44ce2e771cb46e98c4cd33 Author: Rémi Kowalski <[email protected]> AuthorDate: Fri May 3 17:07:32 2019 +0200 JAMES-2754 run JamesMailSpooler on init --- .../org/apache/james/modules/server/CamelMailetContainerModule.java | 1 - .../java/org/apache/james/mailetcontainer/impl/JamesMailSpooler.java | 3 ++- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/server/container/guice/mailet/src/main/java/org/apache/james/modules/server/CamelMailetContainerModule.java b/server/container/guice/mailet/src/main/java/org/apache/james/modules/server/CamelMailetContainerModule.java index 0a0a46c..8071593 100644 --- a/server/container/guice/mailet/src/main/java/org/apache/james/modules/server/CamelMailetContainerModule.java +++ b/server/container/guice/mailet/src/main/java/org/apache/james/modules/server/CamelMailetContainerModule.java @@ -175,7 +175,6 @@ public class CamelMailetContainerModule extends AbstractModule { jamesMailSpooler.setMailProcessor(camelCompositeProcessor); jamesMailSpooler.configure(getJamesSpoolerConfiguration()); jamesMailSpooler.init(); - jamesMailSpooler.run(); } private HierarchicalConfiguration getJamesSpoolerConfiguration() { diff --git a/server/mailet/mailetcontainer-camel/src/main/java/org/apache/james/mailetcontainer/impl/JamesMailSpooler.java b/server/mailet/mailetcontainer-camel/src/main/java/org/apache/james/mailetcontainer/impl/JamesMailSpooler.java index d24e23e..b9a0c5c 100644 --- a/server/mailet/mailetcontainer-camel/src/main/java/org/apache/james/mailetcontainer/impl/JamesMailSpooler.java +++ b/server/mailet/mailetcontainer-camel/src/main/java/org/apache/james/mailetcontainer/impl/JamesMailSpooler.java @@ -105,9 +105,10 @@ public class JamesMailSpooler implements Disposable, Configurable, MailSpoolerMB queue = queueFactory.createQueue(MailQueueFactory.SPOOL); spooler = Schedulers.fromExecutor(Executors.newFixedThreadPool(numThreads, NamedThreadFactory.withName("spooler"))); LOGGER.info("uses {} Thread(s)", numThreads); + run(); } - public void run() { + private void run() { LOGGER.info("Queue={}", queue); disposable = Flux.from(queue.deQueue()) --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
