You are viewing a plain text version of this content. The canonical link for it is here.
Posted to server-dev@james.apache.org by bt...@apache.org on 2018/07/30 06:54:48 UTC
[2/8] james-project git commit: Revert "fixup! upgrade
org.testcontainers:testcontainers"
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 <bt...@linagora.com>
Authored: Fri Jul 27 17:23:39 2018 +0700
Committer: benwa <bt...@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-unsubscribe@james.apache.org
For additional commands, e-mail: server-dev-help@james.apache.org