JAMES-2334 Use resilient channel for queue declaration
Project: http://git-wip-us.apache.org/repos/asf/james-project/repo Commit: http://git-wip-us.apache.org/repos/asf/james-project/commit/de7d0e0a Tree: http://git-wip-us.apache.org/repos/asf/james-project/tree/de7d0e0a Diff: http://git-wip-us.apache.org/repos/asf/james-project/diff/de7d0e0a Branch: refs/heads/master Commit: de7d0e0aaf711a6da6105788d2bbecacdbb2d967 Parents: 9d52d56 Author: Benoit Tellier <[email protected]> Authored: Mon Oct 8 10:31:27 2018 +0700 Committer: Benoit Tellier <[email protected]> Committed: Wed Oct 10 15:46:36 2018 +0700 ---------------------------------------------------------------------- .../org/apache/james/backend/rabbitmq/RabbitMQClusterTest.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/james-project/blob/de7d0e0a/backends-common/rabbitmq/src/test/java/org/apache/james/backend/rabbitmq/RabbitMQClusterTest.java ---------------------------------------------------------------------- diff --git a/backends-common/rabbitmq/src/test/java/org/apache/james/backend/rabbitmq/RabbitMQClusterTest.java b/backends-common/rabbitmq/src/test/java/org/apache/james/backend/rabbitmq/RabbitMQClusterTest.java index 6486a84..081f0d1 100644 --- a/backends-common/rabbitmq/src/test/java/org/apache/james/backend/rabbitmq/RabbitMQClusterTest.java +++ b/backends-common/rabbitmq/src/test/java/org/apache/james/backend/rabbitmq/RabbitMQClusterTest.java @@ -247,9 +247,9 @@ class RabbitMQClusterTest { @Test void nodeKillingWhenConsuming(DockerRabbitMQCluster cluster) throws Exception { - node2Channel.exchangeDeclare(EXCHANGE_NAME, DIRECT, DURABLE); - node2Channel.queueDeclare(QUEUE, DURABLE, !EXCLUSIVE, !AUTO_DELETE, ImmutableMap.of()).getQueue(); - node2Channel.queueBind(QUEUE, EXCHANGE_NAME, ROUTING_KEY); + resilientChannel.exchangeDeclare(EXCHANGE_NAME, DIRECT, DURABLE); + resilientChannel.queueDeclare(QUEUE, DURABLE, !EXCLUSIVE, !AUTO_DELETE, ImmutableMap.of()).getQueue(); + resilientChannel.queueBind(QUEUE, EXCHANGE_NAME, ROUTING_KEY); int nbMessages = 10; IntStream.range(0, nbMessages) --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
