From d25c605ac617be3ccfeae644fa3f3b22325f4b3d Mon Sep 17 00:00:00 2001
From: Sergey Matvienko <smatvienko@thingsboard.io>
Date: Tue, 12 Oct 2021 12:36:46 +0300
Subject: [PATCH] DefaultTbCoreToTransportService: fire "onSuccess send" when
 skipping message without nodeId

---
 .../service/transport/DefaultTbCoreToTransportService.java     | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/application/src/main/java/org/thingsboard/server/service/transport/DefaultTbCoreToTransportService.java b/application/src/main/java/org/thingsboard/server/service/transport/DefaultTbCoreToTransportService.java
index 1208518e3c..b4101edc8e 100644
--- a/application/src/main/java/org/thingsboard/server/service/transport/DefaultTbCoreToTransportService.java
+++ b/application/src/main/java/org/thingsboard/server/service/transport/DefaultTbCoreToTransportService.java
@@ -56,6 +56,9 @@ public class DefaultTbCoreToTransportService implements TbCoreToTransportService
     public void process(String nodeId, ToTransportMsg msg, Runnable onSuccess, Consumer<Throwable> onFailure) {
         if (nodeId == null || nodeId.isEmpty()){
             log.trace("process: skipping message without nodeId [{}], (ToTransportMsg) msg [{}]", nodeId, msg);
+            if (onSuccess != null) {
+                onSuccess.run();
+            }
             return;
         }
         TopicPartitionInfo tpi = partitionService.getNotificationsTopic(ServiceType.TB_TRANSPORT, nodeId);