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 3f24078c67eda1124bbede01dee2a2b8e2df60f2 Author: Benoit TELLIER <[email protected]> AuthorDate: Fri Nov 17 17:26:09 2023 +0100 [BUILD] Avoid polling without delays for MemoryMailQueue --- .../org/apache/james/queue/memory/MemoryMailQueueFactory.java | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/server/queue/queue-memory/src/main/java/org/apache/james/queue/memory/MemoryMailQueueFactory.java b/server/queue/queue-memory/src/main/java/org/apache/james/queue/memory/MemoryMailQueueFactory.java index 42770b30ae..cc5e7541c7 100644 --- a/server/queue/queue-memory/src/main/java/org/apache/james/queue/memory/MemoryMailQueueFactory.java +++ b/server/queue/queue-memory/src/main/java/org/apache/james/queue/memory/MemoryMailQueueFactory.java @@ -126,7 +126,13 @@ public class MemoryMailQueueFactory implements MailQueueFactory<MemoryMailQueueF this.name = name; this.scheduler = Schedulers.newSingle("memory-mail-queue"); - this.flux = Mono.<MemoryMailQueueItem>create(sink -> sink.success(mailItems.poll())) + this.flux = Mono.<MemoryMailQueueItem>create(sink -> { + try { + sink.success(mailItems.poll(10, TimeUnit.MILLISECONDS)); + } catch (InterruptedException e) { + sink.success(); + } + }) .subscribeOn(Schedulers.boundedElastic()) .repeat() .subscribeOn(scheduler) --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
