diff --git a/artemis-protocols/artemis-mqtt-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/mqtt/MQTTPublishManager.java b/artemis-protocols/artemis-mqtt-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/mqtt/MQTTPublishManager.java
index 161ee1d83a..77b45ab767 100644
--- a/artemis-protocols/artemis-mqtt-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/mqtt/MQTTPublishManager.java
+++ b/artemis-protocols/artemis-mqtt-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/mqtt/MQTTPublishManager.java
@@ -159,7 +159,7 @@ public class MQTTPublishManager {
             Transaction tx = session.getServerSession().newTransaction();
             try {
                if (internal) {
-                  session.getServer().getPostOffice().route(serverMessage, tx, true);
+                  session.getServer().getPostOffice().route(serverMessage, null, tx, true);
                } else {
                   session.getServerSession().send(tx, serverMessage, true, false);
                }