From 944145b19196da884fb2b28ed5d998e920261117 Mon Sep 17 00:00:00 2001 From: Robert Davies Date: Fri, 6 Jun 2008 18:56:02 +0000 Subject: [PATCH] patch for https://issues.apache.org/activemq/browse/AMQ-1779 git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@664079 13f79535-47bb-0310-9956-ffa450edef68 --- .../java/org/apache/activemq/ActiveMQConnectionConsumer.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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); } /**