diff --git a/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java b/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java
index f44545649b..a32ed11f85 100755
--- a/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java
+++ b/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java
@@ -2050,13 +2050,6 @@ public class ActiveMQConnection implements Connection, TopicConnection, QueueCon
         if (firstFailureError == null) {
             firstFailureError = error;
         }
-        if (!closed.get() && !closing.get()) {
-            try {
-                cleanup();
-            } catch (JMSException e) {
-                LOG.warn("Cleanup failed", e);
-            }
-        }
     }
 
     /**