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/05/15 07:42:09 UTC
[james-project] 03/05: JAMES-2754 run JamesMailSpooler on init
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 <rk...@linagora.com>
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: server-dev-unsubscribe@james.apache.org
For additional commands, e-mail: server-dev-help@james.apache.org