final EPStatement epl = epService.getEPAdministrator().createEPL(sqlStatement);
for (final String publisherType : publishers.keySet()) {
log.info(String.format("Added publisher [%-50s] to [%s]", publisherType, sqlStatement));
epl.addListener(publishers.get(publisherType));
}
epl.start();
}
}
/**
* Connect a given stream to its publisher. Its subscriber(s) is automatically mapped (the eventOutputName maps to the field