下载视频

yzg-util-mq/src/main/java/com/yanzuoguang/mq/service/impl/MessageLogServiceImpl.java

@@ -7,7 +7,6 @@ import com.yanzuoguang.mq.vo.MessageLogVo;
 import com.yanzuoguang.mq.vo.req.MessageLogRemoveReqVo;
 import com.yanzuoguang.mq.vo.req.MessageLogReqVo;
 import com.yanzuoguang.util.YzgError;
-import com.yanzuoguang.util.exception.CodeException;
 import com.yanzuoguang.util.helper.JsonHelper;
 import com.yanzuoguang.util.helper.StringHelper;
 import org.springframework.amqp.core.Message;
@@ -92,7 +91,7 @@ public class MessageLogServiceImpl implements MessageLogService {
         MessageLogRemoveReqVo loadReq = new MessageLogRemoveReqVo(req.getQueue(), req.getMessageId());
         MessageLogVo load = messageLogDao.load(loadReq, MessageLogVo.class);
         if (load != null) {
-            throw YzgError.getRuntimeException("081", req.getQueue(), req.getMessageId());
+            throw YzgError.getException("081", req.getQueue(), req.getMessageId());
         }
         load = JsonHelper.to(req, MessageLogVo.class);
         messageLogDao.create(load);