From 824eaf7a692a8e2fd394e2a2e5f2da4d4b10d294 Mon Sep 17 00:00:00 2001 From: gtully Date: Thu, 23 Sep 2021 17:03:49 +0100 Subject: [PATCH] no jira - fix leak of connection in case of failed attempt to connect --- .../main/java/org/apache/activemq/artemis/util/ServerUtil.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/artemis-cli/src/main/java/org/apache/activemq/artemis/util/ServerUtil.java b/artemis-cli/src/main/java/org/apache/activemq/artemis/util/ServerUtil.java index a953161d94..157ea5268b 100644 --- a/artemis-cli/src/main/java/org/apache/activemq/artemis/util/ServerUtil.java +++ b/artemis-cli/src/main/java/org/apache/activemq/artemis/util/ServerUtil.java @@ -135,8 +135,7 @@ public class ServerUtil { public static boolean waitForServerToStart(String uri, String username, String password, long timeout) throws InterruptedException { long realTimeout = System.currentTimeMillis() + timeout; while (System.currentTimeMillis() < realTimeout) { - try (ActiveMQConnectionFactory cf = ActiveMQJMSClient.createConnectionFactory(uri, null)) { - cf.createConnection(username, password).close(); + try (ActiveMQConnectionFactory cf = ActiveMQJMSClient.createConnectionFactory(uri, null); Connection c = cf.createConnection(username, password)) { System.out.println("server " + uri + " started"); } catch (Exception e) { System.out.println("awaiting server " + uri + " start at ");