Showing
1 changed file
with
1 additions
and
0 deletions
... | ... | @@ -155,6 +155,7 @@ public class EdgeGrpcClient implements EdgeRpcClient { |
155 | 155 | @Override |
156 | 156 | public void onCompleted() { |
157 | 157 | log.debug("[{}] The rpc session was closed!", edgeKey); |
158 | + onError.accept(new EdgeConnectionException("[" + edgeKey + "] The rpc session was closed!")); | |
158 | 159 | } |
159 | 160 | }; |
160 | 161 | } | ... | ... |