dendi-wang/thingsboard
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Override default implementation onDeviceUpdate()

Browse Source
This commit is contained in:
Viacheslav Kukhtyn 2020-11-21 16:01:04 +02:00 committed by Andrew Shvayka
parent 379ba80b2c
commit c36fc46e2c
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
common/transport/mqtt/src/main/java/org/thingsboard/server/transport/mqtt/MqttTransportHandler.java
View File

@ -40,6 +40,7 @@ import io.netty.util.concurrent.Future;
import io.netty.util.concurrent.GenericFutureListener; import io.netty.util.concurrent.GenericFutureListener;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.thingsboard.server.common.data.DataConstants; 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.DeviceProfile;
import org.thingsboard.server.common.data.DeviceTransportType; import org.thingsboard.server.common.data.DeviceTransportType;
import org.thingsboard.server.common.data.TransportPayloadType; import org.thingsboard.server.common.data.TransportPayloadType;
@ -703,4 +704,9 @@ public class MqttTransportHandler extends ChannelInboundHandlerAdapter implement
public void onProfileUpdate(DeviceProfile deviceProfile) { public void onProfileUpdate(DeviceProfile deviceProfile) {
deviceSessionCtx.onProfileUpdate(deviceProfile); deviceSessionCtx.onProfileUpdate(deviceProfile);
} }
@Override
public void onDeviceUpdate(Device device) {
deviceSessionCtx.onDeviceUpdate(device);
}
} }