From 30d686f7528ae90ed57da4bf2d8233618211d1a1 Mon Sep 17 00:00:00 2001
From: Volodymyr Babak <volodymyr.babak@gmail.com>
Date: Wed, 19 Aug 2020 13:52:03 +0300
Subject: [PATCH] Send response only if connected

---
 .../server/service/edge/rpc/EdgeGrpcSession.java     | 12 +++++++-----
 1 file changed, 7 insertions(+), 5 deletions(-)

diff --git a/application/src/main/java/org/thingsboard/server/service/edge/rpc/EdgeGrpcSession.java b/application/src/main/java/org/thingsboard/server/service/edge/rpc/EdgeGrpcSession.java
index ba77616f77..121772a01b 100644
--- a/application/src/main/java/org/thingsboard/server/service/edge/rpc/EdgeGrpcSession.java
+++ b/application/src/main/java/org/thingsboard/server/service/edge/rpc/EdgeGrpcSession.java
@@ -253,11 +253,13 @@ public final class EdgeGrpcSession implements Closeable {
     }
 
     private void sendResponseMsg(ResponseMsg responseMsg) {
-        try {
-            responseMsgLock.lock();
-            outputStream.onNext(responseMsg);
-        } finally {
-            responseMsgLock.unlock();
+        if (isConnected()) {
+            try {
+                responseMsgLock.lock();
+                outputStream.onNext(responseMsg);
+            } finally {
+                responseMsgLock.unlock();
+            }
         }
     }