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 00ada78..47e853e 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 @@ -23,6 +23,9 @@ public class RocketMQEventConfig { @Value("topic_organizational_${spring.profiles.active}") private String currentTopic; + @Value("topic_organizational_${spring.profiles.active}") + private String organizationalTopic; + @Value("topic_organizational_retry_${spring.profiles.active}") private String currentRetryTopic;