wangli/axzo-framework-commons
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

发送 MQ 支持,自定义追加 header

Browse Source
This commit is contained in:
wangli 2024-06-04 22:46:50 +08:00
parent cbe7e726dd
commit 5146756789
1 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
axzo-common-rocketmq/src/main/java/cn/axzo/framework/rocketmq/AbstractEventProducer.java
View File

@ -15,6 +15,7 @@ import org.springframework.transaction.support.TransactionSynchronizationManager
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Optional;
import java.util.function.BiConsumer;
@ -96,6 +97,12 @@ public abstract class AbstractEventProducer<Meta> implements EventProducer<Meta>
send(event, defaultContext);
}
public void send(@NonNull Event event, Map<String, String> addHeader) {
Map<String, String> headers = defaultContext.getHeaders();
headers.putAll(addHeader);
send(event, defaultContext);
}
public AfterCommitExecutorImpl getAfterCommitExecutor() {
return afterCommitExecutor;
}