Browse Source

update rocketmq consumer

deason 1 month ago
parent
commit
e23a5dc6f0

+ 1 - 2
examcloud-core-basic-service/src/main/java/cn/com/qmth/examcloud/core/basic/service/report/RocketMqConsumerListener.java

@@ -33,8 +33,6 @@ public class RocketMqConsumerListener {
         properties.put(PropertyKeyConst.SuspendTimeMillis, "100");
         // 消息消费失败时的最大重试次数
         properties.put(PropertyKeyConst.MaxReconsumeTimes, "10");
-        // 消费组名称
-        properties.put(PropertyKeyConst.GROUP_ID, PropertyHolder.getString("examcloud.rocketmq.consumer_group"));
     }
 
     public static void start() {
@@ -42,6 +40,7 @@ public class RocketMqConsumerListener {
     }
 
     private static void adminOperate() {
+        properties.put(PropertyKeyConst.GROUP_ID, Tag.ADMIN_OPERATE_INFO.getGroup() + ReportsUtil.getProfile());
         Consumer consumer = ONSFactory.createConsumer(properties);
         consumer.subscribe(ReportsUtil.getReportTopic(), Tag.ADMIN_OPERATE_INFO.getCode(), new MessageListener() {