@Override
    public void send(Event[] events, int streamIndex) {
        barrier.enter();
        try {
            inputProcessor.send(events, streamIndex);
        } finally {
            barrier.exit();
        }
    }
Implementation of {@link InputProcessor} which inject the event to the next input processor through a valve.
modules/siddhi-core/src/main/java/io/siddhi/core/stream/input/InputEntryValve.java