@Override
    public void receive(long timestamp, Object[] data) {
        StreamEvent newEvent = streamEventFactory.newInstance();
        streamEventConverter.convertData(timestamp, data, newEvent);
        // Send to debugger
        if (siddhiDebugger != null) {
            siddhiDebugger.checkBreakPoint(siddhiQueryContext.getName(),
                    SiddhiDebugger.QueryTerminal.IN, newEvent);
        }
        process(new ComplexEventChunk<StreamEvent>(newEvent, newEvent));
    }
Parent implementation for all process stream receivers(Multi/Single/State). Any newly written process stream
receivers should extend this. ProcessStreamReceivers are the entry point to Siddhi queries.
modules/siddhi-core/src/main/java/io/siddhi/core/query/input/ProcessStreamReceiver.java