未验证 提交 3028bda2 编写于 作者: H hackjeremy 提交者: GitHub

Example_Delay.md

[RIP-77]Modify the last paragraph and rid of punctuation between each section number and title
上级 5f8a7545
# Schedule example
### 1.Start consumer to wait for incoming subscribed messages
### 1 Start consumer to wait for incoming subscribed messages
```java
import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;
......@@ -35,7 +35,7 @@ public class ScheduledMessageConsumer {
}
```
### 2.Send scheduled messages
### 2 Send scheduled messages
```java
import org.apache.rocketmq.client.producer.DefaultMQProducer;
......@@ -64,15 +64,15 @@ public class ScheduledMessageProducer {
}
```
### 3.Verification
### 3 Verification
You should see messages are consumed about 10 seconds later than their storing time.
### 4.Use scenarios for scheduled messages
### 4 Use scenarios for scheduled messages
For example, in e-commerce, if an order is submitted, a delay message can be sent, and the status of the order can be checked after 1 hour. If the order is still unpaid, the order can be cancelled and the inventory released.
### 5.Restrictions on the use of scheduled messages
### 5 Restrictions on the use of scheduled messages
```java
// org/apache/rocketmq/store/config/MessageStoreConfig.java
......@@ -82,4 +82,4 @@ private String messageDelayLevel = "1s 5s 10s 30s 1m 2m 3m 4m 5m 6m 7m 8m 9m 10m
Nowadays RocketMq does not support any time delay. It needs to set several fixed delay levels, which correspond to level 1 to 18 from 1s to 2h. Message consumption failure will enter the delay message queue. Message sending time is related to the set delay level and the number of retries.
See `SendMessageProcessor.java`
\ No newline at end of file
See `SendMessageProcessor.java`
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册