From f5c7e5325686688defae4aff16a13c9a077cea14 Mon Sep 17 00:00:00 2001 From: Andrew Shvayka Date: Tue, 7 Mar 2017 19:19:35 +0200 Subject: [PATCH] TB-41: Implementation --- .../server/transport/mqtt/session/GatewaySessionCtx.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git 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 index aaec17c37f..879526984d 100644 --- 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(),