日志只执行１次

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

@@ -130,7 +130,7 @@ public class MqServiceImpl implements MqService, InitializingBean {
     @Override
     public String log(MessageLogReqVo req) {
         if (StringHelper.isEmpty(req.getMessageId()) || StringHelper.isEmpty(req.getQueue())) {
-            return StringHelper.EMPTY;
+            throw new CodeException("请传入queue和messageId");
         }
         MessageLogRemoveReqVo loadReq = new MessageLogRemoveReqVo(req.getQueue(), req.getMessageId());
         MessageLogVo load = messageLogDao.load(loadReq, MessageLogVo.class);
@@ -151,7 +151,7 @@ public class MqServiceImpl implements MqService, InitializingBean {
     @Override
     public String logRemove(MessageLogRemoveReqVo req) {
         if (StringHelper.isEmpty(req.getMessageId()) || StringHelper.isEmpty(req.getQueue())) {
-            return StringHelper.EMPTY;
+            throw new CodeException("请传入queue和messageId");
         }
         messageLogDao.load(req, MessageLogVo.class);
         return req.getMessageId();