BaseEdgeProcessor - Fixed incorrect return
This commit is contained in:
parent
5653ac7f2f
commit
e964c0781e
@ -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);
|
||||
}
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user