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

feat(REQ-3714): 处理启动问题

Browse Source
This commit is contained in:
zhanghonghao 2025-03-11 18:58:30 +08:00
parent 73f158b4fb
commit cf1fef29ee
1 changed files with 15 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
orgmanax-infra/src/main/java/cn/axzo/orgmanax/infra/event/config/RocketMQEventConfig.java
View File

@ -10,6 +10,9 @@ import cn.axzo.foundation.event.support.producer.EventProducer;
import cn.axzo.foundation.event.support.producer.RocketMQEventProducer;
import cn.axzo.foundation.web.support.AppRuntime;
import cn.axzo.foundation.web.support.conditional.NonLocalCondition;
import cn.axzo.framework.rocketmq.EventProduceTemplate;
import cn.axzo.framework.rocketmq.RockerEventProduceFactory;
import cn.axzo.framework.rocketmq.RocketConfigProperties;
import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.spring.annotation.ConsumeMode;
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
@ -25,6 +28,8 @@ import org.springframework.stereotype.Component;
public class RocketMQEventConfig {
public static final String DEFAULT_MODULE = "orgmanax-server";
public static final String DEFAULT_NAME = "orgmanax-server";
@Value("topic_organizational_${spring.profiles.active}")
private String currentTopic;
@ -139,5 +144,15 @@ public class RocketMQEventConfig {
//发送后回调 可以处理事件发送统计
});
}
@Bean
RockerEventProduceFactory rockerEventProduceFactory(RocketConfigProperties rocketMQProperties, RocketMQTemplate rocketMQTemplate) {
return new RockerEventProduceFactory(rocketMQProperties, rocketMQTemplate, DEFAULT_MODULE, DEFAULT_NAME);
}
@Bean
EventProduceTemplate eventProduceTemplate(RockerEventProduceFactory rockerEventProduceFactory) {
return new EventProduceTemplate(rockerEventProduceFactory, DEFAULT_MODULE, DEFAULT_NAME);
}
}