You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@james.apache.org by jh...@apache.org on 2024/10/03 19:38:37 UTC
(james-project) 02/02: [devscout] properly close queue in test
This is an automated email from the ASF dual-hosted git repository.
jhelou pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/james-project.git
commit 2547f4936c33ca1b4d96b16cac28155ce21b176e
Author: Jean Helou <je...@xn--gml-cma.com>
AuthorDate: Fri Sep 27 00:08:50 2024 +0200
[devscout] properly close queue in test
This prevents a useless error stack trace when the actor system is being terminated.
---
.../test/java/org/apache/james/queue/pulsar/PulsarMailQueueTest.java | 2 ++
1 file changed, 2 insertions(+)
diff --git a/server/queue/queue-pulsar/src/test/java/org/apache/james/queue/pulsar/PulsarMailQueueTest.java b/server/queue/queue-pulsar/src/test/java/org/apache/james/queue/pulsar/PulsarMailQueueTest.java
index 135210a630..833cf62184 100644
--- a/server/queue/queue-pulsar/src/test/java/org/apache/james/queue/pulsar/PulsarMailQueueTest.java
+++ b/server/queue/queue-pulsar/src/test/java/org/apache/james/queue/pulsar/PulsarMailQueueTest.java
@@ -212,6 +212,8 @@ public class PulsarMailQueueTest implements MailQueueContract, MailQueueMetricCo
Awaitility.await().untilAsserted(() ->
assertThat(Flux.merge(Flux.from(secondQueue.deQueue()), Flux.from(getManageableMailQueue().deQueue())).blockFirst().getMail().getName())
.isEqualTo("namez"));
+
+ secondQueue.close();
}
@Test
---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscribe@james.apache.org
For additional commands, e-mail: notifications-help@james.apache.org