From 9980a72ee98c45a23f2ba6dcd317ddfafacd6cfd Mon Sep 17 00:00:00 2001 From: Volodymyr Babak Date: Fri, 31 Jul 2020 18:05:15 +0300 Subject: [PATCH] Fix connection if edge removed --- .../src/main/java/org/thingsboard/edge/rpc/EdgeGrpcClient.java | 1 + 1 file changed, 1 insertion(+) diff --git a/common/edge-api/src/main/java/org/thingsboard/edge/rpc/EdgeGrpcClient.java b/common/edge-api/src/main/java/org/thingsboard/edge/rpc/EdgeGrpcClient.java index 38b377c4a8..917cc3fa02 100644 --- a/common/edge-api/src/main/java/org/thingsboard/edge/rpc/EdgeGrpcClient.java +++ b/common/edge-api/src/main/java/org/thingsboard/edge/rpc/EdgeGrpcClient.java @@ -155,6 +155,7 @@ public class EdgeGrpcClient implements EdgeRpcClient { @Override public void onCompleted() { log.debug("[{}] The rpc session was closed!", edgeKey); + onError.accept(new EdgeConnectionException("[" + edgeKey + "] The rpc session was closed!")); } }; }