activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rajdav...@apache.org
Subject svn commit: r572300 - /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/RegionBroker.java
Date Mon, 03 Sep 2007 12:50:17 GMT
Author: rajdavies
Date: Mon Sep  3 05:50:17 2007
New Revision: 572300

URL: http://svn.apache.org/viewvc?rev=572300&view=rev
Log:
ensure the ConectionContext always has a broker set before sending message to DLQ

Modified:
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/RegionBroker.java

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/RegionBroker.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/RegionBroker.java?rev=572300&r1=572299&r2=572300&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/RegionBroker.java
(original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/RegionBroker.java
Mon Sep  3 05:50:17 2007
@@ -664,6 +664,9 @@
 							ActiveMQDestination deadLetterDestination=deadLetterStrategy
 							        .getDeadLetterQueueFor(message
 							                .getDestination());
+							if (context.getBroker()==null) {
+								context.setBroker(getRoot());
+							}
 							BrokerSupport.resend(context,message,
 							        deadLetterDestination);
 							sent=true;



Mime
View raw message