@Override
    public long getBufferedEvents() {
        if (disruptor != null) {
            return disruptor.getBufferSize() - disruptor.getRingBuffer().remainingCapacity();
        }
        return 0L;
    }
Create and start disruptor based on annotations given in the streamDefinition.
modules/siddhi-core/src/main/java/io/siddhi/core/stream/StreamJunction.java