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

fix - 增加 starter 消费 mq 的日志

Browse Source
This commit is contained in:
wangli 2025-11-05 18:02:40 +08:00
parent f6c13979aa
commit 3c8279e45c
2 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
workflow-engine-spring-boot-starter/src/main/java/cn/axzo/workflow/starter/mq/broadcast/filter/InnerFilterDefinitionKey.java
View File

@ -36,6 +36,7 @@ public class InnerFilterDefinitionKey implements InnerMessageQueueHandleBeforeFi
} }
Map<String, String> headers = message.getProperties(); Map<String, String> headers = message.getProperties();
String processDefinitionKey = headers.getOrDefault(MQ_OWNERSHIP_PROCESS_DEFINITION_KEY, ""); String processDefinitionKey = headers.getOrDefault(MQ_OWNERSHIP_PROCESS_DEFINITION_KEY, "");
log.info("MQ_OWNERSHIP_PROCESS_DEFINITION_KEY: {}", processDefinitionKey);
if (properties.getBroadcast().getFilterProcessDefinitionKeys().contains(processDefinitionKey)) { if (properties.getBroadcast().getFilterProcessDefinitionKeys().contains(processDefinitionKey)) {
return false; return false;
} }

2
workflow-engine-spring-boot-starter/src/main/java/cn/axzo/workflow/starter/mq/broadcast/filter/InnerFilterMQOwnerShip.java
View File

@ -34,7 +34,7 @@ public class InnerFilterMQOwnerShip implements InnerMessageQueueHandleBeforeFilt
} }
Map<String, String> headers = message.getProperties(); Map<String, String> headers = message.getProperties();
String mqOwnerShip = headers.getOrDefault(MQ_OWNERSHIP_APPLICATION, null); String mqOwnerShip = headers.getOrDefault(MQ_OWNERSHIP_APPLICATION, null);
log.info("MQ_OWNERSHIP_APPLICATION: {}", mqOwnerShip);
if (!StringUtils.hasText(mqOwnerShip)) { if (!StringUtils.hasText(mqOwnerShip)) {
log.debug("【{}】The broadcast message does not attribute the message, will not be ignored. messageId: {}", this.getClass().getSimpleName(), message.getMsgId()); log.debug("【{}】The broadcast message does not attribute the message, will not be ignored. messageId: {}", this.getClass().getSimpleName(), message.getMsgId());
return false; return false;