Browse Source
Merge pull request #832 from lucky2you/gateway-rpc-resp-no-ack
BUGFIX: fixed the server do not send a PUBLIC ACK on v1/gateway/rpc
pull/841/head
Andrew Shvayka
8 years ago
committed by
GitHub
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with
1 additions and
0 deletions
-
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); |
|
|
GatewayDeviceSessionCtx deviceSessionCtx = devices.get(deviceName); |
|
|
processor.process(new BasicTransportToDeviceSessionActorMsg(deviceSessionCtx.getDevice(), |
|
|
processor.process(new BasicTransportToDeviceSessionActorMsg(deviceSessionCtx.getDevice(), |
|
|
new BasicAdaptorToSessionActorMsg(deviceSessionCtx, new ToDeviceRpcResponseMsg(requestId, data)))); |
|
|
new BasicAdaptorToSessionActorMsg(deviceSessionCtx, new ToDeviceRpcResponseMsg(requestId, data)))); |
|
|
|
|
|
ack(mqttMsg); |
|
|
} else { |
|
|
} else { |
|
|
throw new JsonSyntaxException(CAN_T_PARSE_VALUE + json); |
|
|
throw new JsonSyntaxException(CAN_T_PARSE_VALUE + json); |
|
|
} |
|
|
} |
|
|
|
