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-26 14:44:40 +08:00
parent 3665a8058d
commit 77c8581b4d
1 changed files with 0 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
workflow-engine-core/src/main/java/cn/axzo/workflow/core/mq/CustomRocketMQEventProducer.java
View File

@ -70,7 +70,6 @@ public class CustomRocketMQEventProducer extends RocketMQEventProducer {
newHeaders.put(TraceUtils.CTX_LOG_ID, TraceUtils.getOrCreateTraceId());
newHeaders.put(TraceUtils.TRACE_ID_IN_MDC, TraceUtils.getOrCreateTraceId());
newHeaders.put(MQ_OWNERSHIP_APPLICATION, applicationName);
// newHeaders.put(MQ_OWNERSHIP_APPLICATION, "senna");
final Context copiedContext = context.toBuilder().headers(newHeaders).build();
Runnable runnable = () -> {