mqjob更改为1分钟

themis-task/src/main/java/com/qmth/themis/task/quartz/MqJob.java

@@ -87,7 +87,7 @@ public class MqJob extends QuartzJobBean {
                     if (Objects.nonNull(mqExecTime) && (mqExecTime - System.currentTimeMillis()) / 1000 / 60 <= -1) {
                         mqDto.setReconsume(mqDto.getReconsume() + 1);
                         redisUtil.set(redisKey, mqDto.getId(), mqDto);
-                        producerServer.asyncDelayMsg(mqDto);
+                        producerServer.sendOneWay(mqDto);
                     }
                 }
             });

themis-task/src/main/java/com/qmth/themis/task/start/StartRunning.java

@@ -51,11 +51,11 @@ public class StartRunning implements CommandLineRunner {
     @Override
     public void run(String... args) throws Exception {
         log.info("服务器启动时执行 start");
-//        log.info("增加mqjob start");
+        log.info("增加mqjob start");
         Map mqMap = new HashMap();
         mqMap.put(SystemConstant.NAME, MqJob.class.getName());
         quartzService.deleteJob(QuartzTaskEnum.MQ_JOB_NAME.name(), QuartzTaskEnum.MQ_JOB_GROUP_NAME.name());
-        quartzService.addJob(MqJob.class, QuartzTaskEnum.MQ_JOB_NAME.name(), QuartzTaskEnum.MQ_JOB_GROUP_NAME.name(), "0/30 * * * * ?", mqMap);
+        quartzService.addJob(MqJob.class, QuartzTaskEnum.MQ_JOB_NAME.name(), QuartzTaskEnum.MQ_JOB_GROUP_NAME.name(), "0 0/1 * * * ?", mqMap);
         log.info("增加mqjob end");
 
         log.info("增加mqActivityjob start");