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

Apply patch for https://issues.apache.org/activemq/browse/AMQ-1620 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@646299 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Robert Davies 2008-04-09 12:23:26 +00:00
parent c338d3e0e5
commit d77d82e33d
1 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -70,12 +70,16 @@ public class CompositeDestinationFilter extends DestinationFilter {
continue;
}
Message forwarded_message;
if (copyMessage) {
message = message.copy();
message.setDestination(destination);
forwarded_message = message.copy();
forwarded_message.setDestination(destination);
}
else {
forwarded_message = message;
}
send(context, message, destination);
send(context, forwarded_message, destination);
}
if (!forwardOnly) {
super.send(context, message);