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