You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ra...@apache.org on 2008/04/09 14:23:27 UTC
svn commit: r646299 -
/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/CompositeDestinationFilter.java
Author: rajdavies
Date: Wed Apr 9 05:23:26 2008
New Revision: 646299
URL: http://svn.apache.org/viewvc?rev=646299&view=rev
Log:
Apply patch for https://issues.apache.org/activemq/browse/AMQ-1620
Modified:
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/CompositeDestinationFilter.java
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/CompositeDestinationFilter.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/CompositeDestinationFilter.java?rev=646299&r1=646298&r2=646299&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/CompositeDestinationFilter.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/CompositeDestinationFilter.java Wed Apr 9 05:23:26 2008
@@ -70,12 +70,16 @@
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);