(james-project) 02/02: [devscout] properly close queue in test

[jhelou]

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 <j...@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-unsubscr...@james.apache.org
For additional commands, e-mail: notifications-h...@james.apache.org