diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/region/RegionBroker.java b/activemq-core/src/main/java/org/apache/activemq/broker/region/RegionBroker.java index c13cada724..443d164bb6 100755 --- a/activemq-core/src/main/java/org/apache/activemq/broker/region/RegionBroker.java +++ b/activemq-core/src/main/java/org/apache/activemq/broker/region/RegionBroker.java @@ -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;