JAMES-2500 Don't fail when RabbitMQCluster fails to stop

Project: http://git-wip-us.apache.org/repos/asf/james-project/repo
Commit: http://git-wip-us.apache.org/repos/asf/james-project/commit/60249c0d
Tree: http://git-wip-us.apache.org/repos/asf/james-project/tree/60249c0d
Diff: http://git-wip-us.apache.org/repos/asf/james-project/diff/60249c0d

Branch: refs/heads/master
Commit: 60249c0d3c6da95c2bb9c7b09c54315762790a9f
Parents: cfd46a1
Author: benwa <btell...@linagora.com>
Authored: Thu Jul 26 16:49:24 2018 +0700
Committer: benwa <btell...@linagora.com>
Committed: Mon Jul 30 13:50:35 2018 +0700

----------------------------------------------------------------------
 .../james/queue/rabbitmq/DockerClusterRabbitMQExtension.java   | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/james-project/blob/60249c0d/server/queue/queue-rabbitmq/src/test/java/org/apache/james/queue/rabbitmq/DockerClusterRabbitMQExtension.java
----------------------------------------------------------------------
diff --git 
a/server/queue/queue-rabbitmq/src/test/java/org/apache/james/queue/rabbitmq/DockerClusterRabbitMQExtension.java
 
b/server/queue/queue-rabbitmq/src/test/java/org/apache/james/queue/rabbitmq/DockerClusterRabbitMQExtension.java
index bbe9457..a24dde9 100644
--- 
a/server/queue/queue-rabbitmq/src/test/java/org/apache/james/queue/rabbitmq/DockerClusterRabbitMQExtension.java
+++ 
b/server/queue/queue-rabbitmq/src/test/java/org/apache/james/queue/rabbitmq/DockerClusterRabbitMQExtension.java
@@ -103,9 +103,9 @@ public class DockerClusterRabbitMQExtension implements 
BeforeEachCallback, After
 
         public void stop() {
             Runnables.runParallel(
-                rabbitMQ1::stop,
-                rabbitMQ2::stop,
-                rabbitMQ3::stop);
+                Throwing.runnable(rabbitMQ1::stop).orDoNothing(),
+                Throwing.runnable(rabbitMQ2::stop).orDoNothing(),
+                Throwing.runnable(rabbitMQ3::stop).orDoNothing());
         }
 
         public DockerRabbitMQ getRabbitMQ1() {


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

Reply via email to