wangli/nanopart
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat(REQ-3300) - 移除多余的 IM MQ 监听

Browse Source
This commit is contained in:
wangli 2025-02-19 11:17:13 +08:00
parent cc406bf0f7
commit 199b30c400
1 changed files with 21 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

42
nanopart-server/src/main/java/cn/axzo/nanopart/config/RocketMQEventConfiguration.java
View File

@ -265,25 +265,25 @@ public class RocketMQEventConfiguration {
}
}
/**
* IM 事件处理
*/
@Slf4j
@Component
@RocketMQMessageListener(topic = "topic_im_center_${spring.profiles.active}",
consumerGroup = "GID_im_${spring.application.name}_${spring.profiles.active}",
consumeMode = ConsumeMode.ORDERLY,
nameServer = "${rocketmq.name-server}"
)
public static class ImCenterListener extends BaseListener implements RocketMQListener<MessageExt> {
@Autowired
private EventConsumer eventConsumer;
@Override
public void onMessage(MessageExt message) {
log.info("ImCenterListener onMessage nanopart, message:{}", JSON.toJSONString(message));
super.onEvent(message, eventConsumer);
}
}
// /**
// * IM 事件处理
// */
// @Slf4j
// @Component
// @RocketMQMessageListener(topic = "topic_im_center_${spring.profiles.active}",
// consumerGroup = "GID_im_${spring.application.name}_${spring.profiles.active}",
// consumeMode = ConsumeMode.ORDERLY,
// nameServer = "${rocketmq.name-server}"
// )
// public static class ImCenterListener extends BaseListener implements RocketMQListener<MessageExt> {
//
// @Autowired
// private EventConsumer eventConsumer;
//
// @Override
// public void onMessage(MessageExt message) {
// log.info("ImCenterListener onMessage nanopart, message:{}", JSON.toJSONString(message));
// super.onEvent(message, eventConsumer);
// }
// }
}