From f5b22510af0e082dd8c2e8112e6acc61afd6f657 Mon Sep 17 00:00:00 2001
From: Volodymyr Babak <volodymyr.babak@gmail.com>
Date: Wed, 20 Apr 2022 12:57:04 +0300
Subject: [PATCH] Reduced code complexity

---
 .../server/service/edge/rpc/EdgeGrpcSession.java            | 6 +-----
 1 file changed, 1 insertion(+), 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 e0e1ccad5b..de0cea14d6 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
@@ -399,14 +399,10 @@ public final class EdgeGrpcSession implements Closeable {
         Runnable sendDownlinkMsgsTask = () -> {
             try {
                 if (isConnected() && sessionState.getPendingMsgsMap().values().size() > 0) {
-                    List<DownlinkMsg> copy = null;
+                    List<DownlinkMsg> copy = new ArrayList<>(sessionState.getPendingMsgsMap().values());
                     if (!firstRun) {
-                        copy = new ArrayList<>(sessionState.getPendingMsgsMap().values());
                         log.warn("[{}] Failed to deliver the batch: {}", this.sessionId, copy);
                     }
-                    if (copy == null) {
-                        copy = new ArrayList<>(sessionState.getPendingMsgsMap().values());
-                    }
                     log.trace("[{}] [{}] downlink msg(s) are going to be send.", this.sessionId, copy.size());
                     for (DownlinkMsg downlinkMsg : copy) {
                         sendDownlinkMsg(ResponseMsg.newBuilder()