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