mirror of
https://gitee.com/mirrors/Spring-Cloud-Alibaba.git
synced 2021-06-26 13:25:11 +08:00
modify magic string to constant.
This commit is contained in:
parent
9ab7856947
commit
e4598fb6e8
@ -166,7 +166,7 @@ NOTE: 在使用 RocketMQ Binder 的同时也可以配置 rocketmq.** 用于触
|
|||||||
MessageBuilder builder = MessageBuilder.withPayload(msg)
|
MessageBuilder builder = MessageBuilder.withPayload(msg)
|
||||||
.setHeader(RocketMQHeaders.TAGS, "binder")
|
.setHeader(RocketMQHeaders.TAGS, "binder")
|
||||||
.setHeader(RocketMQHeaders.KEYS, "my-key")
|
.setHeader(RocketMQHeaders.KEYS, "my-key")
|
||||||
.setHeader("DELAY", "1");
|
.setHeader(MessageConst.PROPERTY_DELAY_TIME_LEVEL, "1");
|
||||||
Message message = builder.build();
|
Message message = builder.build();
|
||||||
output().send(message);
|
output().send(message);
|
||||||
```
|
```
|
||||||
|
@ -165,7 +165,7 @@ For example, `TAGS`, `DELAY`, `TRANSACTIONAL_ARG`, `KEYS`, `WAIT_STORE_MSG_OK`,
|
|||||||
MessageBuilder builder = MessageBuilder.withPayload(msg)
|
MessageBuilder builder = MessageBuilder.withPayload(msg)
|
||||||
.setHeader(RocketMQHeaders.TAGS, "binder")
|
.setHeader(RocketMQHeaders.TAGS, "binder")
|
||||||
.setHeader(RocketMQHeaders.KEYS, "my-key")
|
.setHeader(RocketMQHeaders.KEYS, "my-key")
|
||||||
.setHeader("DELAY", "1");
|
.setHeader(MessageConst.PROPERTY_DELAY_TIME_LEVEL, "1");
|
||||||
Message message = builder.build();
|
Message message = builder.build();
|
||||||
output().send(message);
|
output().send(message);
|
||||||
```
|
```
|
||||||
|
Loading…
x
Reference in New Issue
Block a user