Browse Source

EdgeEventSourcingListener - return in case errors during processing ASSIGNED_TO_EDGE rule chain event

pull/11588/head
Volodymyr Babak 2 years ago
parent
commit
83aff21277
  1. 6
      application/src/main/java/org/thingsboard/server/service/edge/EdgeEventSourcingListener.java

6
application/src/main/java/org/thingsboard/server/service/edge/EdgeEventSourcingListener.java

@ -140,10 +140,12 @@ public class EdgeEventSourcingListener {
try { try {
Edge edge = JacksonUtil.fromString(event.getBody(), Edge.class); Edge edge = JacksonUtil.fromString(event.getBody(), Edge.class);
if (edge != null && new RuleChainId(event.getEntityId().getId()).equals(edge.getRootRuleChainId())) { 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; return;
} }
} catch (Exception ignored) {} } catch (Exception ignored) {
return;
}
} }
log.trace("[{}] ActionEntityEvent called: {}", event.getTenantId(), event); log.trace("[{}] ActionEntityEvent called: {}", event.getTenantId(), event);
tbClusterService.sendNotificationMsgToEdge(event.getTenantId(), event.getEdgeId(), event.getEntityId(), tbClusterService.sendNotificationMsgToEdge(event.getTenantId(), event.getEdgeId(), event.getEntityId(),

Loading…
Cancel
Save