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/asf-site Commit: 899327e32f1f3145fbe8f7e48703c31a695cc140 Parents: 10f8abe Author: Li Zhanhui <[email protected]> Authored: Thu Jun 8 11:23:07 2017 +0800 Committer: Li Zhanhui <[email protected]> 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
