package com.qxueyou.scc.school.service.impl; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.springframework.stereotype.Service; //import com.qxueyou.scc.base.model.ONSMsg; import com.qxueyou.scc.base.model.Result; //import com.qxueyou.scc.base.service.impl.ONSBaseMsgProducer; import com.qxueyou.scc.school.service.IDocdealMsgSenderService; /** * * @author 德虎 * */ @Service public class DocdealMsgSenderService implements IDocdealMsgSenderService { //public class DocdealMsgSenderService extends ONSBaseMsgProducer implements IDocdealMsgSenderService { @SuppressWarnings("unused") private Logger log = LogManager.getLogger("DocdealMsgSenderService"); /* * (non-Javadoc) * @see com.qxueyou.scc.school.service.IDocdealMsgSenderService#sendMsg(java.lang.String, java.lang.String) */ @Override public Result sendMsg(String docPath, String handoutId,String uploadModule,String userId) { // ONSMsg msg = new ONSMsg(getTopic()); // // msg.put("msgType", "SCH_DOCDEAL"); // msg.put("docPath", docPath); // msg.put("handoutId", handoutId); // msg.put("uploadModule", uploadModule); // msg.put("userId", userId); // // try { // // producer.send(msg.toONSMsg()); // // return new Result(true); // // } catch (Exception e) { // log.error("call DocdealMsgSendService fail.docPath: "+ docPath + " ;handoutId= " + handoutId,e); // } // return new Result(false); } // @Override // protected String getProducerId() { // return cfg.getConfigByEnv("ons-docdeal-producer-id"); // } // // @Override // protected String getTopic() { // return cfg.getConfigByEnv("ons-docdeal-topic"); // } }