|
@@ -40,7 +40,7 @@ public class RocketMqConsumerListener {
|
|
|
}
|
|
|
|
|
|
private static void adminOperate() {
|
|
|
- properties.put(PropertyKeyConst.GROUP_ID, Tag.ADMIN_OPERATE_INFO.getGroup() + ReportsUtil.getProfile());
|
|
|
+ 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() {
|
|
|
|