Browse Source

this.deviceCreationLockMap = createWeakMap();

pull/5018/head
Sergey Matvienko 5 years ago
committed by Andrew Shvayka
parent
commit
e3303f1b64
  1. 2
      common/transport/mqtt/src/main/java/org/thingsboard/server/transport/mqtt/session/GatewaySessionHandler.java

2
common/transport/mqtt/src/main/java/org/thingsboard/server/transport/mqtt/session/GatewaySessionHandler.java

@ -98,7 +98,7 @@ public class GatewaySessionHandler {
this.sessionId = sessionId;
this.devices = new ConcurrentHashMap<>();
this.deviceFutures = new ConcurrentHashMap<>();
this.deviceCreationLockMap = new ConcurrentHashMap<>();
this.deviceCreationLockMap = createWeakMap();
this.mqttQoSMap = deviceSessionCtx.getMqttQoSMap();
this.channel = deviceSessionCtx.getChannel();
}

Loading…
Cancel
Save