String setConsumedMsg(Properties props, Logger log, String[] consumedMsgInfo){
        String vNewMsgID = "";
        try {
            if(consumedMsgInfo!=null && consumedMsgInfo.length == 4){
                vNewMsgID = consumedMsgInfo[0];
                String vMsgName = consumedMsgInfo[1];
                String vSender = consumedMsgInfo[2];
                String vMsg = consumedMsgInfo[3];
                if (null == vMsg) {
                    props.put(EventChecker.MSG, "NULL");
                } else {
                    props.put(EventChecker.MSG, vMsg);
                }
                log.info("Received message : messageID: " + vNewMsgID + ", messageName: " + vMsgName + ", receiver: " + vSender
                        + ", messageBody: " + vMsg);
            }
        }catch (Exception e) {
            log.error("Error set consumed message failed {} setConsumedMsg failed" + e);
            return vNewMsgID;
        }
        return vNewMsgID;
    }
Fill the result into the source
dss-appconn/appconns/dss-eventchecker-appconn/src/main/java/com/webank/wedatasphere/dss/appconn/eventchecker/service/AbstractEventCheckReceiver.java