ensure the ConectionContext always has a broker set before sending message to DLQ

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@572300 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Robert Davies 2007-09-03 12:50:17 +00:00
parent 0a52fe7289
commit 1195ae751c
1 changed files with 3 additions and 0 deletions

View File

@ -664,6 +664,9 @@ public class RegionBroker implements Broker {
ActiveMQDestination deadLetterDestination=deadLetterStrategy
.getDeadLetterQueueFor(message
.getDestination());
if (context.getBroker()==null) {
context.setBroker(getRoot());
}
BrokerSupport.resend(context,message,
deadLetterDestination);
sent=true;