diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/ClientSessionFactoryImpl.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/ClientSessionFactoryImpl.java index 4223e3c0b62..edc4bf6f4fa 100644 --- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/ClientSessionFactoryImpl.java +++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/ClientSessionFactoryImpl.java @@ -16,6 +16,7 @@ */ package org.apache.activemq.artemis.core.client.impl; +import java.lang.invoke.MethodHandles; import java.lang.ref.WeakReference; import java.security.AccessController; import java.security.PrivilegedAction; @@ -31,6 +32,7 @@ import java.util.concurrent.TimeUnit; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock; +import java.util.function.BiPredicate; import org.apache.activemq.artemis.api.config.ServerLocatorConfig; import org.apache.activemq.artemis.api.core.ActiveMQBuffer; @@ -75,8 +77,6 @@ import org.apache.activemq.artemis.utils.collections.ConcurrentHashSet; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import java.lang.invoke.MethodHandles; -import java.util.function.BiPredicate; public class ClientSessionFactoryImpl implements ClientSessionFactoryInternal, ClientConnectionLifeCycleListener { @@ -1291,13 +1291,6 @@ protected Connection createTransportConnection() { ActiveMQClientLogger.LOGGER.createConnectorException(cause); - if (transportConnection != null) { - try { - transportConnection.close(); - } catch (Throwable t) { - } - } - if (connector != null) { try { connector.close();