From a5fbfcf951989f20758dc8af7c74df9e293db655 Mon Sep 17 00:00:00 2001
From: Chen Xi <chenx@wesine.com>
Date: Mon, 4 Jun 2018 12:47:40 +0800
Subject: [PATCH] BUGFIX: fixed the server do not send a PUBLIC ACK when a
 PUBLIC on v1/gateway/rpc is received

---
 .../server/transport/mqtt/session/GatewaySessionCtx.java         | 1 +
 1 file changed, 1 insertion(+)

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 bf2aa0cd51..cc825b92b8 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
@@ -155,6 +155,7 @@ public class GatewaySessionCtx {
             GatewayDeviceSessionCtx deviceSessionCtx = devices.get(deviceName);
             processor.process(new BasicTransportToDeviceSessionActorMsg(deviceSessionCtx.getDevice(),
                     new BasicAdaptorToSessionActorMsg(deviceSessionCtx, new ToDeviceRpcResponseMsg(requestId, data))));
+            ack(mqttMsg);
         } else {
             throw new JsonSyntaxException(CAN_T_PARSE_VALUE + json);
         }