动态注册mq消费者

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

@@ -1,48 +1,48 @@
-package com.qmth.themis.backend.start;
-
-import com.qmth.themis.business.entity.TEExamStudent;
-import com.qmth.themis.business.service.TEExamStudentService;
-import com.qmth.themis.mq.listener.RocketMessageConsumer;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.springframework.beans.factory.annotation.Value;
-import org.springframework.boot.CommandLineRunner;
-import org.springframework.stereotype.Component;
-
-import javax.annotation.Resource;
-import java.util.List;
-import java.util.StringJoiner;
-
-/**
- * @Description: 服务启动时初始化运行，哪个微服务模块需要则拿此模版去用
- * @Param:
- * @return:
- * @Author: wangliang
- * @Date: 2020/7/3
- */
-@Component
-public class StartRunning implements CommandLineRunner {
-    private final static Logger log = LoggerFactory.getLogger(StartRunning.class);
-
-    @Resource
-    TEExamStudentService teExamStudentService;
-
-    @Resource
-    RocketMessageConsumer rocketMessageConsumer;
-
-    @Value("${rocketmq.name-server}")
-    String nameSrvAddr;
-
-    @Override
-    public void run(String... args) throws Exception {
-        log.info("服务器启动时执行 start");
-        List<TEExamStudent> teExamStudentList = teExamStudentService.list();
-        StringJoiner stringJoiner = new StringJoiner("");
-        teExamStudentList.forEach(s -> {
-            rocketMessageConsumer.setRocketMQConsumer(nameSrvAddr, String.valueOf(s.getId()) + "group", "imTopic", "teacher");
-//            rocketImConsumer.setRocketMQConsumer(nameSrvAddr, "imGroup", "imTopic", "teacher || user");
-        });
-//        rocketImConsumer.setRocketMQConsumer(nameSrvAddr, "imGroup", "imTopic", "teacher");
-        log.info("服务器启动时执行 end");
-    }
-}
+//package com.qmth.themis.backend.start;
+//
+//import com.qmth.themis.business.entity.TEExamStudent;
+//import com.qmth.themis.business.service.TEExamStudentService;
+//import com.qmth.themis.mq.listener.RocketMessageConsumer;
+//import org.slf4j.Logger;
+//import org.slf4j.LoggerFactory;
+//import org.springframework.beans.factory.annotation.Value;
+//import org.springframework.boot.CommandLineRunner;
+//import org.springframework.stereotype.Component;
+//
+//import javax.annotation.Resource;
+//import java.util.List;
+//import java.util.StringJoiner;
+//
+///**
+// * @Description: 服务启动时初始化运行，哪个微服务模块需要则拿此模版去用
+// * @Param:
+// * @return:
+// * @Author: wangliang
+// * @Date: 2020/7/3
+// */
+//@Component
+//public class StartRunning implements CommandLineRunner {
+//    private final static Logger log = LoggerFactory.getLogger(StartRunning.class);
+//
+//    @Resource
+//    TEExamStudentService teExamStudentService;
+//
+//    @Resource
+//    RocketMessageConsumer rocketMessageConsumer;
+//
+//    @Value("${rocketmq.name-server}")
+//    String nameSrvAddr;
+//
+//    @Override
+//    public void run(String... args) throws Exception {
+//        log.info("服务器启动时执行 start");
+//        List<TEExamStudent> teExamStudentList = teExamStudentService.list();
+//        StringJoiner stringJoiner = new StringJoiner("");
+//        teExamStudentList.forEach(s -> {
+//            rocketMessageConsumer.setRocketMQConsumer(nameSrvAddr, String.valueOf(s.getId()) + "group", "imTopic", "teacher");
+////            rocketImConsumer.setRocketMQConsumer(nameSrvAddr, "imGroup", "imTopic", "teacher || user");
+//        });
+////        rocketImConsumer.setRocketMQConsumer(nameSrvAddr, "imGroup", "imTopic", "teacher");
+//        log.info("服务器启动时执行 end");
+//    }
+//}