TB-41: Implementation

10 years ago · f5c7e53256
1 changed files with 1 additions and 1 deletions
--- a/transport/mqtt/src/main/java/org/thingsboard/server/transport/mqtt/session/GatewaySessionCtx.java
+++ b/transport/mqtt/src/main/java/org/thingsboard/server/transport/mqtt/session/GatewaySessionCtx.java
@ -128,7 +128,7 @@ public class GatewaySessionCtx {
        if (json.isJsonObject()) {
            JsonObject jsonObj = json.getAsJsonObject();
            String deviceName = checkDeviceConnected(jsonObj.get("device").getAsString());
-            Integer requestId = jsonObj.get("requestId").getAsInt();
+            Integer requestId = jsonObj.get("id").getAsInt();
            String data = jsonObj.get("data").getAsString();
            GatewayDeviceSessionCtx deviceSessionCtx = devices.get(deviceName);
            processor.process(new BasicToDeviceActorSessionMsg(deviceSessionCtx.getDevice(),