activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From martyntay...@apache.org
Subject [2/3] activemq-artemis git commit: ARTMEIS-958 Route Will message outside server session
Date Tue, 14 Feb 2017 19:42:13 GMT
ARTMEIS-958 Route Will message outside server session

(cherry picked from commit 3bd5c9df6ac28f99e2c3552c8d27fd44eaa0d7a3)


Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/f25396d9
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/f25396d9
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/f25396d9

Branch: refs/heads/1.x
Commit: f25396d9219501e13035fb34f865db7d11f97b9e
Parents: 66c19d9
Author: Martyn Taylor <mtaylor@redhat.com>
Authored: Mon Feb 13 21:19:28 2017 +0000
Committer: Martyn Taylor <mtaylor@redhat.com>
Committed: Tue Feb 14 19:41:35 2017 +0000

----------------------------------------------------------------------
 .../activemq/artemis/core/protocol/mqtt/MQTTConnectionManager.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/f25396d9/artemis-protocols/artemis-mqtt-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/mqtt/MQTTConnectionManager.java
----------------------------------------------------------------------
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 2b100e2..f5f9111 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();
    }
 


Mime
View raw message