消除成功接收处理

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

@@ -30,6 +30,7 @@ public class MqServiceImpl implements MqService {
      *
      * @param req
      */
+    @Override
     public String createQueue(QueueVo req) {
         req.check();
         return queueService.create(req);
@@ -41,6 +42,7 @@ public class MqServiceImpl implements MqService {
      * @param req 请求数据
      * @return 查询结果
      */
+    @Override
     public PageSizeData<QueueVo> queryQueue(QueueQueryReqVo req) {
         return queueService.query(req);
     }
@@ -50,6 +52,7 @@ public class MqServiceImpl implements MqService {
      *
      * @return 查询结果
      */
+    @Override
     public String queryInit() {
         queueService.init();
         return "初始化完成";
@@ -61,6 +64,7 @@ public class MqServiceImpl implements MqService {
      * @param req 需要发送的消息
      * @return 消息编号，但是没有任何意义，发送成功会更改
      */
+    @Override
     public String message(MessageVo req) {
         req.check();
         return messageService.send(req);
@@ -72,6 +76,7 @@ public class MqServiceImpl implements MqService {
      * @param req
      * @return
      */
+    @Override
     public String message_error(MessageVo req) {
         req.check();
         return messageService.onError(req);