Skip to content

Instantly share code, notes, and snippets.

@eeichinger
Created March 2, 2012 08:13
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save eeichinger/1956717 to your computer and use it in GitHub Desktop.
Save eeichinger/1956717 to your computer and use it in GitHub Desktop.
Enable global statement result listeners in Esper
Configuration config = new Configuration();
// must select both streams to get oldEvents as well
config.getEngineDefaults().getStreamSelection().setDefaultStreamSelector(StreamSelector.RSTREAM_ISTREAM_BOTH);
AuditPath.isAuditEnabled = true;
// get serviceProvider and register global statement result listener to get notified of all events created or removed
epService = EPServiceProviderManager.getDefaultProvider(config);
EPServiceProviderSPI spi = (EPServiceProviderSPI) epService;
((MetricReportingServiceSPI)spi.getMetricReportingService()).addStatementResultListener(new StatementResultListener() {
@Override
public void update(EventBean[] newEvents, EventBean[] oldEvents, String statementName, EPStatementSPI statement, EPServiceProviderSPI epServiceProvider) {
}
});
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment