Apache/activemq-artemis
1
0
Fork 0
mirror of https://github.com/apache/activemq-artemis.git synced 2025-02-08 02:59:14 +00:00
Code Issues Packages Projects Releases Wiki Activity

ARTEMIS-1952 NPE logged at warn if MQTT subscriber disconnects abruptly

Browse Source 
Prevent a NullPointerException if no connection by the given clientId is
found on the cache of stored sessions
This commit is contained in:
Otavio R. Piske 2019-02-21 19:33:07 +01:00
parent 951a061555
commit 16909584c3
1 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -179,7 +179,13 @@ class MQTTProtocolManager extends AbstractProtocolManager<MqttMessage, MQTTInter
} }
public boolean isClientConnected(String clientId, MQTTConnection connection) { public boolean isClientConnected(String clientId, MQTTConnection connection) {
return connectedClients.get(clientId).equals(connection); MQTTConnection connectedConn = connectedClients.get(clientId);
if (connectedConn != null) {
return connectedConn.equals(connection);
}
return false;
} }
public void removeConnectedClient(String clientId) { public void removeConnectedClient(String clientId) {