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:43:33 +08:00
parent c294187704
commit 3665a8058d
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -69,8 +69,8 @@ public class CustomRocketMQEventProducer extends RocketMQEventProducer {
newHeaders.put(TraceUtils.TRACE_ID, TraceUtils.getOrCreateTraceId());
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");
newHeaders.put(MQ_OWNERSHIP_APPLICATION, applicationName);
// newHeaders.put(MQ_OWNERSHIP_APPLICATION, "senna");
final Context copiedContext = context.toBuilder().headers(newHeaders).build();
Runnable runnable = () -> {