@Override
        public void send(Event[] events, int streamIndex) {
            try {
                streamJunction.sendEvent(events);
            } catch (Exception e) {
                streamJunction.handleError(events, e);
            }
        }
Interface to be implemented to send events into the Stream Junction.
modules/siddhi-core/src/main/java/io/siddhi/core/stream/StreamJunction.java