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: ARTEMIS-1175 fix memory leak
Date Fri, 26 May 2017 10:17:11 GMT
ARTEMIS-1175 fix memory leak

This closes #1292


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

Branch: refs/heads/master
Commit: b136fed48f756071bbf9542e94ae6448c37881f2
Parents: 28a60bc
Author: Odyldzhon Toshbekov <odyldzhon.toshbekov@ampard.com>
Authored: Thu May 25 14:44:59 2017 +0300
Committer: Martyn Taylor <mtaylor@redhat.com>
Committed: Fri May 26 11:16:41 2017 +0100

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


http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/b136fed4/artemis-protocols/artemis-mqtt-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/mqtt/MQTTSessionState.java
----------------------------------------------------------------------
diff --git a/artemis-protocols/artemis-mqtt-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/mqtt/MQTTSessionState.java
b/artemis-protocols/artemis-mqtt-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/mqtt/MQTTSessionState.java
index 971ddb7..74bc101 100644
--- a/artemis-protocols/artemis-mqtt-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/mqtt/MQTTSessionState.java
+++ b/artemis-protocols/artemis-mqtt-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/mqtt/MQTTSessionState.java
@@ -159,6 +159,7 @@ public class MQTTSessionState {
             Pair p =  mqttToServerIds.remove(mqtt);
             if (p != null) {
                mqttToServerIds.remove(p.getA());
+               artemisToMqttMessageMap.remove(p.getB() + ":" + p.getA());
             }
             return p;
          }


Mime
View raw message