Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fixes AMQ-4320: Destinations are not auto created when using Composite Destination configured on the broker 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1446300 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Hiram R. Chirino 2013-02-14 18:57:28 +00:00
parent c9fcc006ed
commit ecd5c2f738
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
activemq-broker/src/main/java/org/apache/activemq/broker/region/virtual/CompositeDestinationFilter.java
View File

@ -19,6 +19,7 @@ package org.apache.activemq.broker.region.virtual;
import java.util.Collection; import java.util.Collection;
import java.util.Iterator; import java.util.Iterator;
import org.apache.activemq.broker.Broker;
import org.apache.activemq.broker.ProducerBrokerExchange; import org.apache.activemq.broker.ProducerBrokerExchange;
import org.apache.activemq.broker.region.Destination; import org.apache.activemq.broker.region.Destination;
import org.apache.activemq.broker.region.DestinationFilter; import org.apache.activemq.broker.region.DestinationFilter;
@ -79,7 +80,10 @@ public class CompositeDestinationFilter extends DestinationFilter {
forwarded_message = message; forwarded_message = message;
} }
send(context, forwarded_message, destination); // Send it back through the region broker for routing.
context.setMutable(true);
Broker regionBroker = context.getConnectionContext().getBroker().getBrokerService().getRegionBroker();
regionBroker.send(context, forwarded_message);
} }
if (!forwardOnly) { if (!forwardOnly) {
super.send(context, message); super.send(context, message);