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

feat(REQ-4196) - 调整发送 MQ 时，关联的应用

Browse Source
This commit is contained in:
wangli 2025-05-28 15:40:45 +08:00
parent 49269aa1d5
commit 1f5cbabe94
4 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/activity/RocketMqBpmActivityEvent_100_Listener.java
View File

@ -217,13 +217,13 @@ public class RocketMqBpmActivityEvent_100_Listener extends AbstractBpmnEventList
}
Map<String, String> header = new HashMap<>();
if (StringUtils.hasText(dto.getProcessDefinitionKey())) {
log.warn("record process definition key: {}", dto.getProcessDefinitionKey());
log.info("record process definition key: {}", dto.getProcessDefinitionKey());
header.put(MQ_OWNERSHIP_PROCESS_DEFINITION_KEY, dto.getProcessDefinitionKey());
}
if (dto.getVariables().containsKey(PROCESS_OWNERSHIP_APPLICATION)) {
Object orDefault = dto.getVariables().getOrDefault(PROCESS_OWNERSHIP_APPLICATION, "");
if (Objects.nonNull(orDefault)) {
log.warn("record process ownership app name: {}", orDefault);
log.info("record process ownership app name: {}", orDefault);
header.put(MQ_OWNERSHIP_APPLICATION, orDefault.toString());
}
}

2
workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/notice/RocketMqMessagePushEventListener.java
View File

@ -433,7 +433,7 @@ public class RocketMqMessagePushEventListener extends AbstractBpmnEventListener<
if (dto.getVariables().containsKey(PROCESS_OWNERSHIP_APPLICATION)) {
Object orDefault = dto.getVariables().getOrDefault(PROCESS_OWNERSHIP_APPLICATION, "");
if (Objects.nonNull(orDefault)) {
log.warn("record process ownership app name: {}", orDefault);
log.info("record process ownership app name: {}", orDefault);
header.put(MQ_OWNERSHIP_APPLICATION, orDefault.toString());
}
}

4
workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/process/RocketMqBpmnProcessEventListener.java
View File

@ -298,13 +298,13 @@ public class RocketMqBpmnProcessEventListener extends AbstractBpmnEventListener<
}
Map<String, String> header = new HashMap<>();
if (StringUtils.hasText(dto.getProcessDefinitionKey())) {
log.warn("record process definition key: {}", dto.getProcessDefinitionKey());
log.info("record process definition key: {}", dto.getProcessDefinitionKey());
header.put(MQ_OWNERSHIP_PROCESS_DEFINITION_KEY, dto.getProcessDefinitionKey());
}
if (dto.getVariables().containsKey(PROCESS_OWNERSHIP_APPLICATION)) {
Object orDefault = dto.getVariables().getOrDefault(PROCESS_OWNERSHIP_APPLICATION, "");
if (Objects.nonNull(orDefault)) {
log.warn("record process ownership app name: {}", orDefault);
log.info("record process ownership app name: {}", orDefault);
header.put(MQ_OWNERSHIP_APPLICATION, orDefault.toString());
}
}

4
workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/task/RocketMqBpmnTaskEvent_102_Listener.java
View File

@ -180,14 +180,14 @@ public class RocketMqBpmnTaskEvent_102_Listener extends AbstractBpmnEventListene
Map<String, String> header = new HashMap<>();
if (StringUtils.hasText(dto.getProcessDefinitionKey())) {
if (log.isDebugEnabled()) {
log.debug("record process definition key: {}", dto.getProcessDefinitionKey());
log.info("record process definition key: {}", dto.getProcessDefinitionKey());
}
header.put(MQ_OWNERSHIP_PROCESS_DEFINITION_KEY, dto.getProcessDefinitionKey());
}
if (dto.getVariables().containsKey(PROCESS_OWNERSHIP_APPLICATION)) {
Object orDefault = dto.getVariables().getOrDefault(PROCESS_OWNERSHIP_APPLICATION, "");
if (Objects.nonNull(orDefault)) {
log.warn("record process ownership app name: {}", orDefault);
log.info("record process ownership app name: {}", orDefault);
header.put(MQ_OWNERSHIP_APPLICATION, orDefault.toString());
}
}