From 59e33914a7ef452ac88017003051c205da4e5f86 Mon Sep 17 00:00:00 2001 From: Amit Pandey Date: Thu, 1 Feb 2024 19:02:57 +0530 Subject: [PATCH] Java 30676 :- Make minor modifications to work with docker compose (#15783) --- .../ConnectionPerChannelPublisherLiveTest.java | 2 +- .../benchmark/SingleConnectionPublisherLiveTest.java | 4 ++-- .../queue/dynamic/DynamicQueueCreationLiveTest.java | 10 ++++++++-- 3 files changed, 11 insertions(+), 5 deletions(-) diff --git a/messaging-modules/rabbitmq/src/test/java/com/baeldung/benchmark/ConnectionPerChannelPublisherLiveTest.java b/messaging-modules/rabbitmq/src/test/java/com/baeldung/benchmark/ConnectionPerChannelPublisherLiveTest.java index 7776e789cb..9131d8dd59 100644 --- a/messaging-modules/rabbitmq/src/test/java/com/baeldung/benchmark/ConnectionPerChannelPublisherLiveTest.java +++ b/messaging-modules/rabbitmq/src/test/java/com/baeldung/benchmark/ConnectionPerChannelPublisherLiveTest.java @@ -12,7 +12,7 @@ class ConnectionPerChannelPublisherLiveTest { // host, workerCount, iterations, payloadSize Stream.of(1,5,10,20,50,100,150) .forEach(workers -> { - ConnectionPerChannelPublisher.main(new String[]{"192.168.99.100", Integer.toString(workers), "1000", "4096"}); + ConnectionPerChannelPublisher.main(new String[]{"localhost", Integer.toString(workers), "1000", "4096"}); }); } diff --git a/messaging-modules/rabbitmq/src/test/java/com/baeldung/benchmark/SingleConnectionPublisherLiveTest.java b/messaging-modules/rabbitmq/src/test/java/com/baeldung/benchmark/SingleConnectionPublisherLiveTest.java index edd0690d07..073b1a08a8 100644 --- a/messaging-modules/rabbitmq/src/test/java/com/baeldung/benchmark/SingleConnectionPublisherLiveTest.java +++ b/messaging-modules/rabbitmq/src/test/java/com/baeldung/benchmark/SingleConnectionPublisherLiveTest.java @@ -10,9 +10,9 @@ class SingleConnectionPublisherLiveTest { @Test void whenSingleChannel_thenRunBenchmark() throws Exception { // host, workerCount, iterations, payloadSize - Stream.of(1,5,10,20,50,100,150) + Stream.of(1,5,10,20,50) .forEach(workers -> { - SingleConnectionPublisher.main(new String[]{"192.168.99.100", Integer.toString(workers), "1000", "4096"}); + SingleConnectionPublisher.main(new String[]{"localhost", Integer.toString(workers), "1000", "4096"}); }); } diff --git a/messaging-modules/rabbitmq/src/test/java/com/baeldung/benchmark/queue/dynamic/DynamicQueueCreationLiveTest.java b/messaging-modules/rabbitmq/src/test/java/com/baeldung/benchmark/queue/dynamic/DynamicQueueCreationLiveTest.java index aa430035ef..2f97440505 100644 --- a/messaging-modules/rabbitmq/src/test/java/com/baeldung/benchmark/queue/dynamic/DynamicQueueCreationLiveTest.java +++ b/messaging-modules/rabbitmq/src/test/java/com/baeldung/benchmark/queue/dynamic/DynamicQueueCreationLiveTest.java @@ -56,11 +56,17 @@ public class DynamicQueueCreationLiveTest { @Test void givenQueueName_whenQueueDoesNotExist_thenCheckingIfQueueExists() throws IOException, TimeoutException { - - try (Channel channel = connection.createChannel()) { + Channel temp = null; + try { + Channel channel = connection.createChannel(); assertThrows(IOException.class, () -> { channel.queueDeclarePassive(QUEUE_NAME_NEW); }); + temp = channel; + } finally { + if(temp != null && temp.isOpen()) { + temp.close(); + } } }