diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/util/LoggingBrokerPlugin.java b/activemq-core/src/main/java/org/apache/activemq/broker/util/LoggingBrokerPlugin.java index 5d4c415fca..5775fd275b 100644 --- a/activemq-core/src/main/java/org/apache/activemq/broker/util/LoggingBrokerPlugin.java +++ b/activemq-core/src/main/java/org/apache/activemq/broker/util/LoggingBrokerPlugin.java @@ -18,7 +18,6 @@ package org.apache.activemq.broker.util; import java.io.IOException; import java.util.Set; - import javax.annotation.PostConstruct; import org.apache.activemq.broker.BrokerPluginSupport; import org.apache.activemq.broker.Connection; @@ -530,6 +529,7 @@ public class LoggingBrokerPlugin extends BrokerPluginSupport { } LOG.info("Sending to DLQ : " + msg); } + super.sendToDeadLetterQueue(context, messageReference); } @Override