activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r386335 - /incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java
Date Thu, 16 Mar 2006 14:11:01 GMT
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 ) {



Mime
View raw message