public void addStreamJunction(List<QueryRuntime> queryRuntimeList) {
        StreamJunction streamJunction = streamJunctionMap.get(streamId);
        if (streamJunction == null) {
            streamJunction = partitionRuntime.getInnerPartitionStreamReceiverStreamJunctionMap().get(streamId);
            if (streamJunction == null) {
                streamJunction = createStreamJunction();
                partitionRuntime.addInnerpartitionStreamReceiverStreamJunction(streamId, streamJunction);
            }
            streamJunctionMap.put(streamId, streamJunction);
        }
        for (QueryRuntime queryRuntime : queryRuntimeList) {
            StreamRuntime streamRuntime = ((QueryRuntimeImpl) queryRuntime).getStreamRuntime();
            for (int i = 0; i < ((QueryRuntimeImpl) queryRuntime).getInputStreamId().size(); i++) {
                if ((streamRuntime.getSingleStreamRuntimes().get(i)).
                        getProcessStreamReceiver().getStreamId().equals(streamId)) {
                    streamJunction.subscribe((streamRuntime.getSingleStreamRuntimes().get(i))
                            .getProcessStreamReceiver());
                }
            }
        }
    }
create local streamJunctions through which events received by partitionStreamReceiver, are sent to
queryStreamReceivers

@param queryRuntimeList queryRuntime list of the partition
modules/siddhi-core/src/main/java/io/siddhi/core/partition/PartitionStreamReceiver.java