From cddf8745602a35b1ed4f9454b1446873e15fda5f Mon Sep 17 00:00:00 2001 From: fangjian0423 Date: Wed, 13 Mar 2019 11:12:00 +0800 Subject: [PATCH] update rocketmq docs --- .../src/main/asciidoc-zh/rocketmq.adoc | 6 ++++-- spring-cloud-alibaba-docs/src/main/asciidoc/rocketmq.adoc | 6 ++++-- 2 files changed, 8 insertions(+), 4 deletions(-) diff --git a/spring-cloud-alibaba-docs/src/main/asciidoc-zh/rocketmq.adoc b/spring-cloud-alibaba-docs/src/main/asciidoc-zh/rocketmq.adoc index 23776ee8..557fe2e5 100644 --- a/spring-cloud-alibaba-docs/src/main/asciidoc-zh/rocketmq.adoc +++ b/spring-cloud-alibaba-docs/src/main/asciidoc-zh/rocketmq.adoc @@ -153,12 +153,14 @@ RocketMQ Binder 的核心类 RocketMQMessageChannelBinder 实现了 Spring Cloud NOTE: 在使用 RocketMQ Binder 的同时也可以配置 rocketmq.** 用于触发 RocketMQ Spring 相关的 AutoConfiguration -`RocketMQHeaders` 中定义了很多 Header 常量,在发送消息的时候可以设置到 Spring Message 的 Header 中,用于触发 RocketMQ 相关的 feature: +目前 Binder 支持在 `Header` 中设置相关的 key 来进行 RocketMQ Message 消息的特性设置。 + +比如 `TAGS`、`DELAY`、`TRANSACTIONAL_ARG`、`KEYS`、`WAIT_STORE_MSG_OK`、`FLAG` 表示 RocketMQ 消息对应的标签, ```java MessageBuilder builder = MessageBuilder.withPayload(msg) .setHeader(RocketMQHeaders.TAGS, "binder") - .setHeader(RocketMQHeaders.MESSAGE_ID, "my-msg-id") + .setHeader(RocketMQHeaders.KEYS, "my-key") .setHeader("DELAY", "1"); Message message = builder.build(); output().send(message); diff --git a/spring-cloud-alibaba-docs/src/main/asciidoc/rocketmq.adoc b/spring-cloud-alibaba-docs/src/main/asciidoc/rocketmq.adoc index d8406138..b147b87d 100644 --- a/spring-cloud-alibaba-docs/src/main/asciidoc/rocketmq.adoc +++ b/spring-cloud-alibaba-docs/src/main/asciidoc/rocketmq.adoc @@ -152,12 +152,14 @@ RocketMQ Spring framework is an integration of RocketMQ and Spring Boot. It prov NOTE: RocketMQ Binder Application can also be used to configure rocketmq.** to trigger RocketMQ Spring related AutoConfiguration -The headers defined in `RocketMQHeaders`, which can be set to the header of spring message when sending a message to trigger the RocketMQ related feature: +Currently Binder supports setting the relevant key in `Header` to set the properties of the RocketMQ message. + +For example, `TAGS`, `DELAY`, `TRANSACTIONAL_ARG`, `KEYS`, `WAIT_STORE_MSG_OK`, `FLAG` represent the labels corresponding to the RocketMQ message. ```java MessageBuilder builder = MessageBuilder.withPayload(msg) .setHeader(RocketMQHeaders.TAGS, "binder") - .setHeader(RocketMQHeaders.MESSAGE_ID, "my-msg-id") + .setHeader(RocketMQHeaders.KEYS, "my-key") .setHeader("DELAY", "1"); Message message = builder.build(); output().send(message);