@Override
    public void run() {
        log.info("Event received for Stream " + streamDefinition.getId() + " in siddhi App " +
                siddhiAppContext.getName() + " for last " + duration + " minute(s): " + eventCounter + ". " +
                "Total Events: " + totalEventCounter + ".");
        eventCounter = 0;
    }
Log number of events received by each receiver
modules/siddhi-core/src/main/java/io/siddhi/core/util/statistics/ReceivedEventCounter.java