diff --git a/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnectionConsumer.java b/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnectionConsumer.java
index 26f0ea434a..a1e7f523e7 100755
--- a/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnectionConsumer.java
+++ b/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnectionConsumer.java
@@ -76,7 +76,7 @@ public class ActiveMQConnectionConsumer implements ConnectionConsumer, ActiveMQD
 
         this.connection.addConnectionConsumer(this);
         this.connection.addDispatcher(consumerInfo.getConsumerId(), this);
-        this.connection.syncSendPacket(this.consumerInfo);
+        this.connection.asyncSendPacket(this.consumerInfo);
     }
 
     /**