private void process(int eventSequence, StreamEvent newEvent) {
        if (lockWrapper != null) {
            lockWrapper.lock();
        }
        try {
            LatencyTracker latencyTracker = siddhiQueryContext.getLatencyTracker();
            if (latencyTracker != null) {
                try {
                    latencyTracker.markIn();
                    processAndClear(eventSequence, newEvent);
                } finally {
                    latencyTracker.markOut();
                }
            } else {
                processAndClear(eventSequence, newEvent);
            }
        } finally {
            if (lockWrapper != null) {
                lockWrapper.unlock();
            }
        }
    }
{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