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 2280f4bc54..aa56d627c8 100755
--- a/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java
+++ b/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java
@@ -1584,7 +1584,7 @@ public class ActiveMQConnection implements Connection, TopicConnection, QueueCon
     }
 
     public void setAsyncDispatch(boolean asyncDispatch) {
-        //this.asyncDispatch = asyncDispatch;
+        this.asyncDispatch = asyncDispatch;
     }
 
     public boolean isObjectMessageSerializationDefered() {