Apache/activemq
1
0
Fork 0
mirror of https://github.com/apache/activemq.git synced 2025-02-28 13:19:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

https://issues.apache.org/jira/browse/AMQ-4017 - always use async dispatch for the advisory consumer so that we will not block remote dispatch

Browse Source 
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1381095 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Gary Tully 2012-09-05 09:22:43 +00:00
parent 640424727d
commit 5c61d97b20
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java
View File

@ -322,7 +322,8 @@ public abstract class DemandForwardingBridgeSupport implements NetworkBridge, Br
// determine demand.
if (!configuration.isStaticBridge()) {
demandConsumerInfo = new ConsumerInfo(remoteSessionInfo, 1);
demandConsumerInfo.setDispatchAsync(configuration.isDispatchAsync());
// always dispatch advisories async so that we never block the producer broker if we are slow
demandConsumerInfo.setDispatchAsync(true);
String advisoryTopic = configuration.getDestinationFilter();
if (configuration.isBridgeTempDestinations()) {
advisoryTopic += "," + AdvisorySupport.TEMP_DESTINATION_COMPOSITE_ADVISORY_TOPIC;