[james-project] 13/18: JAMES-2899 replace new elastic schedulers by new boundedElastic ones

[btellier]

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 7881aa94b74c82d74138920251dfacd647119a75
Author: Rémi Kowalski <rkowal...@linagora.com>
AuthorDate: Wed Sep 25 10:47:14 2019 +0200

    JAMES-2899 replace new elastic schedulers by new boundedElastic ones
---
 .../james/transport/mailets/remote/delivery/DeliveryRunnable.java       | 2 +-
 .../james/task/eventsourcing/distributed/RabbitMQExclusiveConsumer.java | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/server/mailet/mailets/src/main/java/org/apache/james/transport/mailets/remote/delivery/DeliveryRunnable.java
 
b/server/mailet/mailets/src/main/java/org/apache/james/transport/mailets/remote/delivery/DeliveryRunnable.java
index 5ec4ec0..8e52c84 100644
--- 
a/server/mailet/mailets/src/main/java/org/apache/james/transport/mailets/remote/delivery/DeliveryRunnable.java
+++ 
b/server/mailet/mailets/src/main/java/org/apache/james/transport/mailets/remote/delivery/DeliveryRunnable.java
@@ -81,7 +81,7 @@ public class DeliveryRunnable implements Disposable {
     }
 
     public void start() {
-        Scheduler remoteDeliveryScheduler = 
Schedulers.newElastic("RemoteDelivery");
+        Scheduler remoteDeliveryScheduler = 
Schedulers.newBoundedElastic(Schedulers.DEFAULT_BOUNDED_ELASTIC_SIZE, 
Schedulers.DEFAULT_BOUNDED_ELASTIC_QUEUESIZE, "RemoteDelivery");
         disposable = Flux.from(queue.deQueue())
             .publishOn(remoteDeliveryScheduler)
             .flatMap(this::runStep)
diff --git 
a/server/task/task-distributed/src/main/java/org/apache/james/task/eventsourcing/distributed/RabbitMQExclusiveConsumer.java
 
b/server/task/task-distributed/src/main/java/org/apache/james/task/eventsourcing/distributed/RabbitMQExclusiveConsumer.java
index 2977312..c600691 100644
--- 
a/server/task/task-distributed/src/main/java/org/apache/james/task/eventsourcing/distributed/RabbitMQExclusiveConsumer.java
+++ 
b/server/task/task-distributed/src/main/java/org/apache/james/task/eventsourcing/distributed/RabbitMQExclusiveConsumer.java
@@ -90,7 +90,7 @@ public class RabbitMQExclusiveConsumer implements Closeable {
     }
 
     protected Scheduler createScheduler(String name) {
-        return Schedulers.newElastic(name);
+        return 
Schedulers.newBoundedElastic(Schedulers.DEFAULT_BOUNDED_ELASTIC_SIZE, 
Schedulers.DEFAULT_BOUNDED_ELASTIC_QUEUESIZE, name);
     }
 
 


---------------------------------------------------------------------
To unsubscribe, e-mail: server-dev-unsubscr...@james.apache.org
For additional commands, e-mail: server-dev-h...@james.apache.org