wangliang 4 gadi atpakaļ
vecāks
revīzija
dd616329b2

+ 0 - 4
themis-business/src/main/java/com/qmth/themis/business/util/MqUtil.java

@@ -31,10 +31,6 @@ public class MqUtil {
         return mqGroupDomain;
     }
 
-    public static Logger getLog() {
-        return log;
-    }
-
     public MqGroupDomain getMqGroupDomain() {
         return mqGroupDomain;
     }

+ 0 - 2
themis-task/src/main/java/com/qmth/themis/task/listener/QuartzOrderlyImpl.java

@@ -6,10 +6,8 @@ import com.qmth.themis.business.dto.MqDto;
 import com.qmth.themis.business.util.JacksonUtil;
 import com.qmth.themis.business.util.RedisUtil;
 import com.qmth.themis.common.contanst.Constants;
-import com.qmth.themis.mq.service.MqLogicService;
 import com.qmth.themis.mq.templete.Orderly;
 import com.qmth.themis.task.listener.service.MqTaskLogicService;
-import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus;
 import org.apache.rocketmq.client.consumer.listener.ConsumeOrderlyContext;
 import org.apache.rocketmq.client.consumer.listener.ConsumeOrderlyStatus;
 import org.apache.rocketmq.common.message.MessageExt;

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

@@ -62,7 +62,7 @@ public class StartRunning implements CommandLineRunner {
         Map mqActivityMap = new HashMap();
         mqActivityMap.put("name", MqActivityJob.class.getName());
         quartzService.deleteJob(QuartzTaskEnum.MQ_ACTIVITY_JOB_NAME.name(), QuartzTaskEnum.MQ_ACTIVITY_JOB_GROUP_NAME.name());
-        quartzService.addJob(MqActivityJob.class, QuartzTaskEnum.MQ_ACTIVITY_JOB_NAME.name(), QuartzTaskEnum.MQ_ACTIVITY_JOB_GROUP_NAME.name(), "0 0 0 * * ?", mqMap);
+        quartzService.addJob(MqActivityJob.class, QuartzTaskEnum.MQ_ACTIVITY_JOB_NAME.name(), QuartzTaskEnum.MQ_ACTIVITY_JOB_GROUP_NAME.name(), "0 0 0 * * ?", mqActivityMap);
         log.info("增加mqActivityjob end");
         
         log.info("增加客观题答案缓存加载job start");