diff --git a/artemis-protocols/artemis-mqtt-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/mqtt/MQTTConnectionManager.java b/artemis-protocols/artemis-mqtt-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/mqtt/MQTTConnectionManager.java
index 2b100e2fc0..f5f9111321 100644
--- a/artemis-protocols/artemis-mqtt-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/mqtt/MQTTConnectionManager.java
+++ b/artemis-protocols/artemis-mqtt-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/mqtt/MQTTConnectionManager.java
@@ -133,7 +133,7 @@ public class MQTTConnectionManager {
    }
 
    private void sendWill() throws Exception {
-      session.getServerSession().send(session.getSessionState().getWillMessage(), true);
+      session.getServer().getPostOffice().route(session.getSessionState().getWillMessage(), true);
       session.getSessionState().deleteWillMessage();
    }