|
@@ -40,7 +40,7 @@ public class RocketMqConsumerListener {
|
|
}
|
|
}
|
|
|
|
|
|
private static void onlineExamStudent() {
|
|
private static void onlineExamStudent() {
|
|
- properties.put(PropertyKeyConst.GROUP_ID, Tag.EXAM_PROCESS_RECORD.getGroup() + ReportsUtil.getProfile());
|
|
|
|
|
|
+ properties.put(PropertyKeyConst.GROUP_ID, Tag.EXAM_PROCESS_RECORD.getGroup() + "_" + ReportsUtil.getProfile());
|
|
Consumer consumer = ONSFactory.createConsumer(properties);
|
|
Consumer consumer = ONSFactory.createConsumer(properties);
|
|
consumer.subscribe(ReportsUtil.getReportTopic(), Tag.EXAM_PROCESS_RECORD.getCode(), new MessageListener() {
|
|
consumer.subscribe(ReportsUtil.getReportTopic(), Tag.EXAM_PROCESS_RECORD.getCode(), new MessageListener() {
|
|
|
|
|