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

Merge branch 'master' into pre

Browse Source
This commit is contained in:
wangli 2025-11-05 18:04:16 +08:00
commit 53e1f9ff94
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();
String processDefinitionKey = headers.getOrDefault(MQ_OWNERSHIP_PROCESS_DEFINITION_KEY, "");
log.info("MQ_OWNERSHIP_PROCESS_DEFINITION_KEY: {}", processDefinitionKey);
if (properties.getBroadcast().getFilterProcessDefinitionKeys().contains(processDefinitionKey)) {
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();
String mqOwnerShip = headers.getOrDefault(MQ_OWNERSHIP_APPLICATION, null);
log.info("MQ_OWNERSHIP_APPLICATION: {}", 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());
return false;