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