From cf1fef29ee395a7b80ab222878fb58c2b22103ba Mon Sep 17 00:00:00 2001 From: zhanghonghao Date: Tue, 11 Mar 2025 18:58:30 +0800 Subject: [PATCH] =?UTF-8?q?feat(REQ-3714):=20=E5=A4=84=E7=90=86=E5=90=AF?= =?UTF-8?q?=E5=8A=A8=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../infra/event/config/RocketMQEventConfig.java | 15 +++++++++++++++ 1 file changed, 15 insertions(+) diff --git a/orgmanax-infra/src/main/java/cn/axzo/orgmanax/infra/event/config/RocketMQEventConfig.java b/orgmanax-infra/src/main/java/cn/axzo/orgmanax/infra/event/config/RocketMQEventConfig.java index 1f095d6..78e40c4 100644 --- a/orgmanax-infra/src/main/java/cn/axzo/orgmanax/infra/event/config/RocketMQEventConfig.java +++ b/orgmanax-infra/src/main/java/cn/axzo/orgmanax/infra/event/config/RocketMQEventConfig.java @@ -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); + } }