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 ) {
