延迟队列

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/send/impl/QwSendMsgServiceImpl.java

@@ -81,13 +81,13 @@ public class QwSendMsgServiceImpl implements QwSendMsgService {
             dealQwSendDTO.setRefreshType(2);
             DealQwSendDTO.QwSendMsgBO qwSendMsgBO = EntityUtil.changeEntityByJSON(DealQwSendDTO.QwSendMsgBO.class, qwSendMsg);
             dealQwSendDTO.setQwSendMsg(qwSendMsgBO);
-            MqUtils.sendMessageToMQ("qwSendRefreshByMQ", JSON.toJSONString(dealQwSendDTO));
+            MqUtils.sendMessageToMQ("qwSendRefreshByMQ", JSON.toJSONString(dealQwSendDTO), 60);
         }else {
             // 重新刷新
             DealQwSendDTO dealQwSendDTO = new DealQwSendDTO();
             dealQwSendDTO.setRefreshType(1);
             dealQwSendDTO.setFinishQwSend(finishQwSendBO);
-            MqUtils.sendMessageToMQ("qwSendRefreshByMQ", JSON.toJSONString(dealQwSendDTO),60);
+            MqUtils.sendMessageToMQ("qwSendRefreshByMQ", JSON.toJSONString(dealQwSendDTO), 60);
         }
     }