Revert "fixup! upgrade org.testcontainers:testcontainers" This reverts commit 2c9eda147d3f5e2c1fd7d680850d315c1b31f1ff.
Project: http://git-wip-us.apache.org/repos/asf/james-project/repo Commit: http://git-wip-us.apache.org/repos/asf/james-project/commit/2666bc49 Tree: http://git-wip-us.apache.org/repos/asf/james-project/tree/2666bc49 Diff: http://git-wip-us.apache.org/repos/asf/james-project/diff/2666bc49 Branch: refs/heads/master Commit: 2666bc49a35f4001d4a04141ba50e4687efa3a22 Parents: 60249c0 Author: benwa <btell...@linagora.com> Authored: Fri Jul 27 17:23:39 2018 +0700 Committer: benwa <btell...@linagora.com> Committed: Mon Jul 30 13:50:35 2018 +0700 ---------------------------------------------------------------------- .../org/apache/james/queue/rabbitmq/RabbitMQClusterTest.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/james-project/blob/2666bc49/server/queue/queue-rabbitmq/src/test/java/org/apache/james/queue/rabbitmq/RabbitMQClusterTest.java ---------------------------------------------------------------------- diff --git a/server/queue/queue-rabbitmq/src/test/java/org/apache/james/queue/rabbitmq/RabbitMQClusterTest.java b/server/queue/queue-rabbitmq/src/test/java/org/apache/james/queue/rabbitmq/RabbitMQClusterTest.java index 66bc342..26cf6e1 100644 --- a/server/queue/queue-rabbitmq/src/test/java/org/apache/james/queue/rabbitmq/RabbitMQClusterTest.java +++ b/server/queue/queue-rabbitmq/src/test/java/org/apache/james/queue/rabbitmq/RabbitMQClusterTest.java @@ -217,10 +217,10 @@ class RabbitMQClusterTest { @Test void connectingToAClusterWithAFailedRabbit(DockerRabbitMQCluster cluster) throws Exception { ConnectionFactory node3ConnectionFactory = cluster.getRabbitMQ3().connectionFactory(); - try (Connection connection = node3ConnectionFactory.newConnection(cluster.getAddresses()); - Channel channel = connection.createChannel()) { + cluster.getRabbitMQ3().stop(); - cluster.getRabbitMQ3().stop(); + try (Connection connection = node3ConnectionFactory.newConnection(cluster.getAddresses()); + Channel channel = connection.createChannel()) { channel.exchangeDeclare(EXCHANGE_NAME, DIRECT, DURABLE); channel.queueDeclare(QUEUE, DURABLE, !EXCLUSIVE, !AUTO_DELETE, ImmutableMap.of()).getQueue(); --------------------------------------------------------------------- To unsubscribe, e-mail: server-dev-unsubscr...@james.apache.org For additional commands, e-mail: server-dev-h...@james.apache.org
