From 355d09569b3cf8c14494b93ba0f124e2a77bac5f Mon Sep 17 00:00:00 2001
From: nickAS21 <nick@thingsboard.io>
Date: Tue, 13 Sep 2022 16:36:01 +0300
Subject: [PATCH] fix_bug: commit

---
 .../server/service/queue/DefaultTbClusterService.java        | 5 +----
 1 file changed, 1 insertion(+), 4 deletions(-)

diff --git a/application/src/main/java/org/thingsboard/server/service/queue/DefaultTbClusterService.java b/application/src/main/java/org/thingsboard/server/service/queue/DefaultTbClusterService.java
index c3df3c6522..8ec29672de 100644
--- a/application/src/main/java/org/thingsboard/server/service/queue/DefaultTbClusterService.java
+++ b/application/src/main/java/org/thingsboard/server/service/queue/DefaultTbClusterService.java
@@ -165,10 +165,7 @@ public class DefaultTbClusterService implements TbClusterService {
 
     @Override
     public void pushMsgToRuleEngine(TenantId tenantId, EntityId entityId, TbMsg tbMsg, TbQueueCallback callback) {
-        if (tenantId == null) {
-            log.warn("tenantId [null] [{}] Received invalid message: {}", entityId, tbMsg);
-            return;
-        } else if (tenantId.isNullUid()) {
+        if (tenantId == null || tenantId.isNullUid()) {
             if (entityId.getEntityType().equals(EntityType.TENANT)) {
                 tenantId = TenantId.fromUUID(entityId.getId());
             } else {