svn commit: r1440018 - /activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java

[ta...@apache.org]

Author: tabish
Date: Tue Jan 29 17:36:26 2013
New Revision: 1440018

URL: http://svn.apache.org/viewvc?rev=1440018&view=rev
Log:
fix for: https://issues.apache.org/jira/browse/AMQ-4282

Make sure that we don't allow advisory destinations to be marked as sync dispatch. 

Modified:
    activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java

Modified: activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java?rev=1440018&r1=1440017&r2=1440018&view=diff
==============================================================================
--- activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java (original)
+++ activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java Tue Jan 29 17:36:26 2013
@@ -1332,7 +1332,11 @@ public abstract class DemandForwardingBr
     }
 
     protected void configureDemandSubscription(ConsumerInfo info, DemandSubscription sub) throws IOException {
-        sub.getLocalInfo().setDispatchAsync(configuration.isDispatchAsync());
+        if (AdvisorySupport.isConsumerAdvisoryTopic(info.getDestination())){
+            sub.getLocalInfo().setDispatchAsync(true);
+        } else {
+            sub.getLocalInfo().setDispatchAsync(configuration.isDispatchAsync());
+        }
         sub.getLocalInfo().setPrefetchSize(configuration.getPrefetchSize());
         subscriptionMapByLocalId.put(sub.getLocalInfo().getConsumerId(), sub);
         subscriptionMapByRemoteId.put(sub.getRemoteInfo().getConsumerId(), sub);