You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by li...@apache.org on 2017/06/08 03:23:13 UTC
incubator-rocketmq-site git commit: Fix indent
Repository: incubator-rocketmq-site
Updated Branches:
refs/heads/master 10f8abe52 -> 899327e32
Fix indent
Project: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/commit/899327e3
Tree: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/tree/899327e3
Diff: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/diff/899327e3
Branch: refs/heads/master
Commit: 899327e32f1f3145fbe8f7e48703c31a695cc140
Parents: 10f8abe
Author: Li Zhanhui <li...@gmail.com>
Authored: Thu Jun 8 11:23:07 2017 +0800
Committer: Li Zhanhui <li...@gmail.com>
Committed: Thu Jun 8 11:23:07 2017 +0800
----------------------------------------------------------------------
_docs/17-rmq-schedule-example.md | 116 +++++++++++++++++-----------------
1 file changed, 58 insertions(+), 58 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/blob/899327e3/_docs/17-rmq-schedule-example.md
----------------------------------------------------------------------
diff --git a/_docs/17-rmq-schedule-example.md b/_docs/17-rmq-schedule-example.md
index 1fa1d64..7af7045 100644
--- a/_docs/17-rmq-schedule-example.md
+++ b/_docs/17-rmq-schedule-example.md
@@ -17,70 +17,70 @@ Scheduled messages differ from normal messages in that they won't be delivered u
### Application
1. Start consumer to wait for incoming subscribed messages
-
-```java
-import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;
-import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext;
-import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus;
-import org.apache.rocketmq.client.consumer.listener.MessageListenerConcurrently;
-import org.apache.rocketmq.common.message.MessageExt;
-import java.util.List;
-
-public class ScheduledMessageConsumer {
-
- public static void main(String[] args) throws Exception {
- // Instantiate message consumer
- DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("ExampleConsumer");
- // Subscribe topics
- consumer.subscribe("TestTopic", "*");
- // Register message listener
- consumer.registerMessageListener(new MessageListenerConcurrently() {
- @Override
- public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> messages, ConsumeConcurrentlyContext context) {
- for (MessageExt message : messages) {
- // Print approximate delay time period
- System.out.println("Receive message[msgId=" + message.getMsgId() + "] "
- + (System.currentTimeMillis() - message.getStoreTimestamp()) + "ms later");
+
+ ```java
+ import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;
+ import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext;
+ import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus;
+ import org.apache.rocketmq.client.consumer.listener.MessageListenerConcurrently;
+ import org.apache.rocketmq.common.message.MessageExt;
+ import java.util.List;
+
+ public class ScheduledMessageConsumer {
+
+ public static void main(String[] args) throws Exception {
+ // Instantiate message consumer
+ DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("ExampleConsumer");
+ // Subscribe topics
+ consumer.subscribe("TestTopic", "*");
+ // Register message listener
+ consumer.registerMessageListener(new MessageListenerConcurrently() {
+ @Override
+ public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> messages, ConsumeConcurrentlyContext context) {
+ for (MessageExt message : messages) {
+ // Print approximate delay time period
+ System.out.println("Receive message[msgId=" + message.getMsgId() + "] "
+ + (System.currentTimeMillis() - message.getStoreTimestamp()) + "ms later");
+ }
+ return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
}
- return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
- }
- });
- // Launch consumer
- consumer.start();
+ });
+ // Launch consumer
+ consumer.start();
+ }
}
-}
-```
+ ```
2. Send scheduled messages
-
-```java
-import org.apache.rocketmq.client.producer.DefaultMQProducer;
-import org.apache.rocketmq.common.message.Message;
-
-public class ScheduledMessageProducer {
-
- public static void main(String[] args) throws Exception {
- // Instantiate a producer to send scheduled messages
- DefaultMQProducer producer = new DefaultMQProducer("ExampleProducerGroup");
- // Launch producer
- producer.start();
- int totalMessagesToSend = 100;
- for (int i = 0; i < totalMessagesToSend; i++) {
- Message message = new Message("TestTopic", ("Hello scheduled message " + i).getBytes());
- // This message will be delivered to consumer 10 seconds later.
- message.setDelayTimeLevel(3);
- // Send the message
- producer.send(message);
+
+ ```java
+ import org.apache.rocketmq.client.producer.DefaultMQProducer;
+ import org.apache.rocketmq.common.message.Message;
+
+ public class ScheduledMessageProducer {
+
+ public static void main(String[] args) throws Exception {
+ // Instantiate a producer to send scheduled messages
+ DefaultMQProducer producer = new DefaultMQProducer("ExampleProducerGroup");
+ // Launch producer
+ producer.start();
+ int totalMessagesToSend = 100;
+ for (int i = 0; i < totalMessagesToSend; i++) {
+ Message message = new Message("TestTopic", ("Hello scheduled message " + i).getBytes());
+ // This message will be delivered to consumer 10 seconds later.
+ message.setDelayTimeLevel(3);
+ // Send the message
+ producer.send(message);
+ }
+
+ // Shutdown producer after use.
+ producer.shutdown();
}
-
- // Shutdown producer after use.
- producer.shutdown();
+
}
-
-}
-```
+ ```
3. Verification
-
-You should see messages are consumed about 10 seconds later than their storing time.
\ No newline at end of file
+
+ You should see messages are consumed about 10 seconds later than their storing time.
\ No newline at end of file