protected void processAndClear(int processIndex, StreamEvent streamEvent) {
        ComplexEventChunk<StreamEvent> currentStreamEventChunk = new ComplexEventChunk<StreamEvent>(
                streamEvent, streamEvent);
        nextProcessors[processIndex].process(currentStreamEventChunk);
    }
{StreamJunction.Receiver} implementation to receive events to be fed into multi
stream processors which consume multiple streams.
modules/siddhi-core/src/main/java/io/siddhi/core/query/input/MultiProcessStreamReceiver.java