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

Set downlink msg id in the response msg

Browse Source
This commit is contained in:
Volodymyr Babak 2021-06-02 11:24:19 +03:00
parent 0465781303
commit ea8e55dbab
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
application/src/test/java/org/thingsboard/server/edge/imitator/EdgeImitator.java
View File

@ -136,7 +136,9 @@ public class EdgeImitator {
@Override @Override
public void onSuccess(@Nullable List<Void> result) { public void onSuccess(@Nullable List<Void> result) {
if (connected) { if (connected) {
DownlinkResponseMsg downlinkResponseMsg = DownlinkResponseMsg.newBuilder().setSuccess(true).build(); DownlinkResponseMsg downlinkResponseMsg = DownlinkResponseMsg.newBuilder()
.setDownlinkMsgId(downlinkMsg.getDownlinkMsgId())
.setSuccess(true).build();
edgeRpcClient.sendDownlinkResponseMsg(downlinkResponseMsg); edgeRpcClient.sendDownlinkResponseMsg(downlinkResponseMsg);
} }
} }
@ -144,7 +146,9 @@ public class EdgeImitator {
@Override @Override
public void onFailure(Throwable t) { public void onFailure(Throwable t) {
if (connected) { if (connected) {
DownlinkResponseMsg downlinkResponseMsg = DownlinkResponseMsg.newBuilder().setSuccess(false).setErrorMsg(t.getMessage()).build(); DownlinkResponseMsg downlinkResponseMsg = DownlinkResponseMsg.newBuilder()
.setDownlinkMsgId(downlinkMsg.getDownlinkMsgId())
.setSuccess(false).setErrorMsg(t.getMessage()).build();
edgeRpcClient.sendDownlinkResponseMsg(downlinkResponseMsg); edgeRpcClient.sendDownlinkResponseMsg(downlinkResponseMsg);
} }
} }