From d77e557945040180f9a65262c0311a7e6ea69df8 Mon Sep 17 00:00:00 2001
From: nick <nick@avalr.com.ua>
Date: Fri, 18 Oct 2024 14:32:26 +0300
Subject: [PATCH] activity: add return if callback error

---
 .../common/transport/service/DefaultTransportService.java   | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/common/transport/transport-api/src/main/java/org/thingsboard/server/common/transport/service/DefaultTransportService.java b/common/transport/transport-api/src/main/java/org/thingsboard/server/common/transport/service/DefaultTransportService.java
index edb0e5c44a..15073ba841 100644
--- a/common/transport/transport-api/src/main/java/org/thingsboard/server/common/transport/service/DefaultTransportService.java
+++ b/common/transport/transport-api/src/main/java/org/thingsboard/server/common/transport/service/DefaultTransportService.java
@@ -1104,12 +1104,12 @@ public class DefaultTransportService extends TransportActivityManager implements
         TopicPartitionInfo tpi;
         try {
             tpi = partitionService.resolve(ServiceType.TB_CORE, tenantId, entityId);
-        } catch (TenantNotFoundException e) {
-            log.trace("Failed to send message to core. Tenant with ID [{}] not found in the database. Message delivery aborted.", tenantId, e);
-            tpi = TopicPartitionInfo.builder().topic("").build();
+        } catch (Exception e) {
+            log.trace("Failed to send message to core. Tenant with ID [{}], entityType [{}], entityId [{}], routingKey [{}], \nmsg [{}].\n Message delivery aborted.", tenantId, entityId.getEntityType(),  entityId.toString(), routingKey, msg, e);
             if (callback != null) {
                 callback.onError(e);
             }
+            return;
         }
         if (log.isTraceEnabled()) {
             log.trace("[{}][{}] Pushing to topic {} message {}", tenantId, entityId, tpi.getFullTopicName(), msg);