public void scheduleEventCounterLogger() {
        if (scheduleLogger != null) {
            scheduleLogger.cancel(true);
        }
        scheduleLogger = siddhiAppContext.getScheduledExecutorService().
                scheduleWithFixedDelay(this, loggerExecutionInterval, loggerExecutionInterval,
                        TimeUnit.MILLISECONDS);
    }
Log number of events received by each receiver
modules/siddhi-core/src/main/java/io/siddhi/core/util/statistics/ReceivedEventCounter.java