From e2b2dea9685b86c6416cf233a81cab46f950caa0 Mon Sep 17 00:00:00 2001 From: Andrii Landiak Date: Fri, 5 Jan 2024 12:31:43 +0200 Subject: [PATCH] Improve findRelatedEdgeIdIfAny to check for total elements > 0 --- .../server/service/queue/DefaultTbClusterService.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 21d1d2022d..d567d1b447 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 @@ -559,7 +559,7 @@ public class DefaultTbClusterService implements TbClusterService { private EdgeId findRelatedEdgeIdIfAny(TenantId tenantId, EntityId entityId) { PageData pageData = edgeService.findRelatedEdgeIdsByEntityId(tenantId, entityId, new PageLink(1)); - return Optional.ofNullable(pageData).filter(pd -> pd.getTotalElements() == 1).map(pd -> pd.getData().get(0)).orElse(null); + return Optional.ofNullable(pageData).filter(pd -> pd.getTotalElements() > 0).map(pd -> pd.getData().get(0)).orElse(null); } @Override