wangli/workflow-engine
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix - 调整监听配置

Browse Source
This commit is contained in:
wangli 2024-11-08 10:01:38 +08:00
parent 60e7af03df
commit 26bd236bb1
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
workflow-engine-server/src/main/java/cn/axzo/workflow/server/mq/inside/SelfBoradcastRocketConfiguration.java
View File

@ -25,7 +25,7 @@ public class SelfBoradcastRocketConfiguration {
@Component @Component
@ConditionalOnProperty(name = "rocketmq.name-server") @ConditionalOnProperty(name = "rocketmq.name-server")
@RocketMQMessageListener(topic = DEFAULT_EVENT + "${spring.profiles.active}", @RocketMQMessageListener(topic = DEFAULT_EVENT + "${spring.profiles.active}",
consumerGroup = "GID_${spring.application.name}_workflow_engine_consumer", consumerGroup = "GID_${spring.application.name}_workflow_engine_${spring.profiles.active}_consumer",
consumeMode = ConsumeMode.ORDERLY, consumeMode = ConsumeMode.ORDERLY,
maxReconsumeTimes = 3, maxReconsumeTimes = 3,
nameServer = "${rocketmq.name-server}" nameServer = "${rocketmq.name-server}"

2
workflow-engine-server/src/main/java/cn/axzo/workflow/server/mq/outside/DingtalkRocketConfiguration.java
View File

@ -28,7 +28,7 @@ import java.util.HashMap;
* @since 2024-10-25 13:39 * @since 2024-10-25 13:39
*/ */
@Slf4j @Slf4j
//@Configuration(proxyBeanMethods = false) @Configuration(proxyBeanMethods = false)
public class DingtalkRocketConfiguration { public class DingtalkRocketConfiguration {
@Value("${spring.profiles.active:dev}") @Value("${spring.profiles.active:dev}")
private String activeProfile; private String activeProfile;