Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

ARTMEIS-958 Route Will message outside server session 

(cherry picked from commit 3bd5c9df6a)
This commit is contained in:
Martyn Taylor 2017-02-13 21:19:28 +00:00
parent 66c19d9408
commit f25396d921
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
artemis-protocols/artemis-mqtt-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/mqtt/MQTTConnectionManager.java
View File

@ -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();
}