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

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);

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