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