Repository: james-project Updated Branches: refs/heads/master cfd46a149 -> 2d6d69eca
JAMES-2500 Don't get IP of stopped containers No more works with testcontainers 1.8.1 Project: http://git-wip-us.apache.org/repos/asf/james-project/repo Commit: http://git-wip-us.apache.org/repos/asf/james-project/commit/5635e133 Tree: http://git-wip-us.apache.org/repos/asf/james-project/tree/5635e133 Diff: http://git-wip-us.apache.org/repos/asf/james-project/diff/5635e133 Branch: refs/heads/master Commit: 5635e13304f3ae87afcf58e84ff9692f2abf174e Parents: 2666bc4 Author: benwa <btell...@linagora.com> Authored: Fri Jul 27 18:24:41 2018 +0700 Committer: benwa <btell...@linagora.com> Committed: Mon Jul 30 13:50:35 2018 +0700 ---------------------------------------------------------------------- .../org/apache/james/queue/rabbitmq/RabbitMQClusterTest.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/james-project/blob/5635e133/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 26cf6e1..63146a9 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 @@ -49,8 +49,10 @@ import org.testcontainers.shaded.com.google.common.collect.ImmutableMap; import com.github.fge.lambdas.Throwing; import com.github.steveash.guavate.Guavate; +import com.google.common.collect.ImmutableList; import com.jayway.awaitility.Awaitility; import com.jayway.awaitility.Duration; +import com.rabbitmq.client.Address; import com.rabbitmq.client.Channel; import com.rabbitmq.client.Connection; import com.rabbitmq.client.ConnectionFactory; @@ -217,9 +219,10 @@ class RabbitMQClusterTest { @Test void connectingToAClusterWithAFailedRabbit(DockerRabbitMQCluster cluster) throws Exception { ConnectionFactory node3ConnectionFactory = cluster.getRabbitMQ3().connectionFactory(); + ImmutableList<Address> clusterAddresses = cluster.getAddresses(); cluster.getRabbitMQ3().stop(); - try (Connection connection = node3ConnectionFactory.newConnection(cluster.getAddresses()); + try (Connection connection = node3ConnectionFactory.newConnection(clusterAddresses); Channel channel = connection.createChannel()) { channel.exchangeDeclare(EXCHANGE_NAME, DIRECT, DURABLE); --------------------------------------------------------------------- To unsubscribe, e-mail: server-dev-unsubscr...@james.apache.org For additional commands, e-mail: server-dev-h...@james.apache.org
