From 3007736f2c32e5db16f686b3c31e97f6b9626c65 Mon Sep 17 00:00:00 2001
From: wangli <wangli@axzo.cn>
Date: Tue, 4 Jun 2024 22:52:24 +0800
Subject: [PATCH] =?UTF-8?q?=E5=8F=91=E9=80=81=20MQ=20=E6=94=AF=E6=8C=81,?=
 =?UTF-8?q?=E8=87=AA=E5=AE=9A=E4=B9=89=E8=BF=BD=E5=8A=A0=20header?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../cn/axzo/framework/rocketmq/AbstractEventProducer.java | 1 +
 .../java/cn/axzo/framework/rocketmq/EventProducer.java    | 8 ++++++++
 2 files changed, 9 insertions(+)

diff --git a/axzo-common-rocketmq/src/main/java/cn/axzo/framework/rocketmq/AbstractEventProducer.java b/axzo-common-rocketmq/src/main/java/cn/axzo/framework/rocketmq/AbstractEventProducer.java
index c65d318..2831890 100644
--- a/axzo-common-rocketmq/src/main/java/cn/axzo/framework/rocketmq/AbstractEventProducer.java
+++ b/axzo-common-rocketmq/src/main/java/cn/axzo/framework/rocketmq/AbstractEventProducer.java
@@ -97,6 +97,7 @@ public abstract class AbstractEventProducer<Meta> implements EventProducer<Meta>
         send(event, defaultContext);
     }
 
+    @Override
     public void send(@NonNull Event event, Map<String, String> addHeader) {
         Map<String, String> headers = defaultContext.getHeaders();
         headers.putAll(addHeader);
diff --git a/axzo-common-rocketmq/src/main/java/cn/axzo/framework/rocketmq/EventProducer.java b/axzo-common-rocketmq/src/main/java/cn/axzo/framework/rocketmq/EventProducer.java
index ade5f16..8cdb4c5 100644
--- a/axzo-common-rocketmq/src/main/java/cn/axzo/framework/rocketmq/EventProducer.java
+++ b/axzo-common-rocketmq/src/main/java/cn/axzo/framework/rocketmq/EventProducer.java
@@ -29,6 +29,14 @@ public interface EventProducer<Meta> {
      */
     void send(Event event);
 
+    /**
+     * 发送 event, 使用默认的 context,并在 context 中追加 header 属性
+     *
+     * @param event
+     * @param addHeaders
+     */
+    void send(Event event, Map<String, String> addHeaders);
+
     @Getter
     @Builder(toBuilder = true)
     @NoArgsConstructor