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(); + } } }