You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ch...@apache.org on 2006/03/16 15:11:01 UTC
svn commit: r386335 -
/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java
Author: chirino
Date: Thu Mar 16 06:11:00 2006
New Revision: 386335
URL: http://svn.apache.org/viewcvs?rev=386335&view=rev
Log:
Also set the dispatchAsync when using connection consumers (use in MDB dispatching).
Modified:
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java
Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java?rev=386335&r1=386334&r2=386335&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java Thu Mar 16 06:11:00 2006
@@ -656,6 +656,7 @@
info.setSubcriptionName(subscriptionName);
info.setSelector(messageSelector);
info.setPrefetchSize(maxMessages);
+ info.setDispatchAsync(asyncDispatch);
// Allows the options on the destination to configure the consumerInfo
if( info.getDestination().getOptions()!=null ) {
@@ -963,12 +964,14 @@
checkClosedOrFailed();
ensureConnectionInfoSent();
+
ConsumerId consumerId = createConsumerId();
ConsumerInfo info = new ConsumerInfo(consumerId);
info.setDestination(ActiveMQMessageTransformation.transformDestination(destination));
info.setSelector(messageSelector);
info.setPrefetchSize(maxMessages);
info.setNoLocal(noLocal);
+ info.setDispatchAsync(asyncDispatch);
// Allows the options on the destination to configure the consumerInfo
if( info.getDestination().getOptions()!=null ) {