EventRouteExecutorImpl.java 文件源码

@Override
public Future<List<Event>> execute(Event event, Device device) {

    List<Event> outEvents = new ArrayList<>();

    ServiceResponse<List<EventRoute>> serviceRoutes = eventRouteService.getAll(device.getTenant(), device.getApplication());
    if (!serviceRoutes.isOk()) {
        LOGGER.error("Error listing application events routes", device.toURI(), device.getTenant().getLogLevel());
        return new AsyncResult<>(outEvents);
    }

    List<EventRoute> eventRoutes = serviceRoutes.getResult();
    if (eventRoutes.isEmpty()) {
        return new AsyncResult<>(outEvents);
    }

    eventRoutes.parallelStream().forEach((eventRoute) ->
        processEventRoute(event, device, outEvents, eventRoute)
    );

    return new AsyncResult<>(outEvents);
}