public void receiveEvents(Event[] events) {
        try {
            receive(events);
        } catch (RuntimeException e) {
            log.error("Error on sending events " + Arrays.deepToString(events) +
                    " in the SiddhiApp '" + siddhiAppContext.getName() + "'", e);
        }
    }
StreamCallback is used to receive events from {@link StreamJunction}. This class should be extended if one intends
to get events from a Siddhi Stream.
modules/siddhi-core/src/main/java/io/siddhi/core/stream/output/StreamCallback.java