From 83aff21277bdff9329f2eda2a187873a25be81c3 Mon Sep 17 00:00:00 2001 From: Volodymyr Babak Date: Mon, 9 Sep 2024 10:55:03 +0300 Subject: [PATCH] EdgeEventSourcingListener - return in case errors during processing ASSIGNED_TO_EDGE rule chain event --- .../server/service/edge/EdgeEventSourcingListener.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/application/src/main/java/org/thingsboard/server/service/edge/EdgeEventSourcingListener.java b/application/src/main/java/org/thingsboard/server/service/edge/EdgeEventSourcingListener.java index 3134a9d0dc..17ceb17ed1 100644 --- a/application/src/main/java/org/thingsboard/server/service/edge/EdgeEventSourcingListener.java +++ b/application/src/main/java/org/thingsboard/server/service/edge/EdgeEventSourcingListener.java @@ -140,10 +140,12 @@ public class EdgeEventSourcingListener { try { Edge edge = JacksonUtil.fromString(event.getBody(), Edge.class); if (edge != null && new RuleChainId(event.getEntityId().getId()).equals(edge.getRootRuleChainId())) { - log.trace("skipping ASSIGNED_TO_EDGE event of RULE_CHAIN entity in case Edge Root Rule Chain: {}", event); + log.trace("[{}] skipping ASSIGNED_TO_EDGE event of RULE_CHAIN entity in case Edge Root Rule Chain: {}", event.getTenantId(), event); return; } - } catch (Exception ignored) {} + } catch (Exception ignored) { + return; + } } log.trace("[{}] ActionEntityEvent called: {}", event.getTenantId(), event); tbClusterService.sendNotificationMsgToEdge(event.getTenantId(), event.getEdgeId(), event.getEntityId(),