From e964c0781e27e1cfbd44a6d3161be47ee43577a6 Mon Sep 17 00:00:00 2001 From: Volodymyr Babak Date: Mon, 14 Apr 2025 15:35:39 +0300 Subject: [PATCH] BaseEdgeProcessor - Fixed incorrect return --- .../server/service/edge/rpc/processor/BaseEdgeProcessor.java | 1 - 1 file changed, 1 deletion(-) diff --git a/application/src/main/java/org/thingsboard/server/service/edge/rpc/processor/BaseEdgeProcessor.java b/application/src/main/java/org/thingsboard/server/service/edge/rpc/processor/BaseEdgeProcessor.java index bb4bd19980..6fcb02e4bc 100644 --- a/application/src/main/java/org/thingsboard/server/service/edge/rpc/processor/BaseEdgeProcessor.java +++ b/application/src/main/java/org/thingsboard/server/service/edge/rpc/processor/BaseEdgeProcessor.java @@ -163,7 +163,6 @@ public abstract class BaseEdgeProcessor implements EdgeProcessor { for (Edge edge : edges) { futures.add(saveEdgeEvent(edge.getTenantId(), edge.getId(), type, actionType, entityId, body, false)); } - return Futures.immediateFuture(null); } else { futures = processActionForAllEdgesByTenantId(tenantId, type, actionType, entityId, null, sourceEdgeId); }