From c36fc46e2ce9fa18fb078eaa1e7565f8237f25d7 Mon Sep 17 00:00:00 2001
From: Viacheslav Kukhtyn <vkukhtyn@thingsboard.io>
Date: Sat, 21 Nov 2020 16:01:04 +0200
Subject: [PATCH] Override default implementation onDeviceUpdate()

---
 .../server/transport/mqtt/MqttTransportHandler.java         | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/common/transport/mqtt/src/main/java/org/thingsboard/server/transport/mqtt/MqttTransportHandler.java b/common/transport/mqtt/src/main/java/org/thingsboard/server/transport/mqtt/MqttTransportHandler.java
index cdd5f1b3ca..eadfab729e 100644
--- a/common/transport/mqtt/src/main/java/org/thingsboard/server/transport/mqtt/MqttTransportHandler.java
+++ b/common/transport/mqtt/src/main/java/org/thingsboard/server/transport/mqtt/MqttTransportHandler.java
@@ -40,6 +40,7 @@ import io.netty.util.concurrent.Future;
 import io.netty.util.concurrent.GenericFutureListener;
 import lombok.extern.slf4j.Slf4j;
 import org.thingsboard.server.common.data.DataConstants;
+import org.thingsboard.server.common.data.Device;
 import org.thingsboard.server.common.data.DeviceProfile;
 import org.thingsboard.server.common.data.DeviceTransportType;
 import org.thingsboard.server.common.data.TransportPayloadType;
@@ -703,4 +704,9 @@ public class MqttTransportHandler extends ChannelInboundHandlerAdapter implement
     public void onProfileUpdate(DeviceProfile deviceProfile) {
         deviceSessionCtx.onProfileUpdate(deviceProfile);
     }
+
+    @Override
+    public void onDeviceUpdate(Device device) {
+        deviceSessionCtx.onDeviceUpdate(device);
+    }
 }