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:26:04 UTC
[1/7] incubator-rocketmq-site git commit: Update example of scheduled
message
Repository: incubator-rocketmq-site
Updated Branches:
refs/heads/asf-site 94c21bba6 -> c6a0f07ed
Update example of scheduled message
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/3bb95024
Tree: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/tree/3bb95024
Diff: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/diff/3bb95024
Branch: refs/heads/asf-site
Commit: 3bb950241e1e2d07aed7f7ed788d968a3dcece97
Parents: a84f68d
Author: Li Zhanhui <li...@gmail.com>
Authored: Wed Jun 7 11:57:11 2017 +0800
Committer: Li Zhanhui <li...@gmail.com>
Committed: Wed Jun 7 11:57:11 2017 +0800
----------------------------------------------------------------------
_docs/17-rmq-schedule-example.md | 105 +++++++++++++++++++---------------
1 file changed, 58 insertions(+), 47 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/blob/3bb95024/_docs/17-rmq-schedule-example.md
----------------------------------------------------------------------
diff --git a/_docs/17-rmq-schedule-example.md b/_docs/17-rmq-schedule-example.md
index e9610ee..0340f21 100644
--- a/_docs/17-rmq-schedule-example.md
+++ b/_docs/17-rmq-schedule-example.md
@@ -11,61 +11,72 @@ modified: 2017-04-24T15:01:43-04:00
### What is scheduled message?
-Scheduled messages differ from normal messages such that they won't be delivered until a provided time later.
-If you use `DefaultMQPullConsumer` to consume message, you have to fetch message manually. There are other options availible but `MQPullConsumerScheduleService` is the easiest.
-#### DefaultMQPullConsumer use case
+Scheduled messages differ from normal messages in that they won't be delivered until a provided time later.
-> First fetch subscribed queues of a topic
+### Application
+
+1. Start consumer to wait for incoming subscribed messages
```java
-Set<MessageQueue> testTopic = consumer.fetchSubscribeMessageQueues("testTopic");
+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;
+ }
+ });
+ // Launch consumer
+ consumer.start();
+ }
+}
```
-> Second chose a queue to fetch message,and save queue offset manually.
-#### Use MQPullConsumerScheduleService consume message
+2. Send scheduled messages
```java
-final MQPullConsumerScheduleService scheduleService = new MQPullConsumerScheduleService("GroupName1");
-
-scheduleService.setMessageModel(MessageModel.CLUSTERING);
-scheduleService.registerPullTaskCallback("TopicTest1", new PullTaskCallback() {
-
- @Override
- public void doPullTask(MessageQueue mq, PullTaskContext context) {
- MQPullConsumer consumer = context.getPullConsumer();
- try {
-
- long offset = consumer.fetchConsumeOffset(mq, false);
- if (offset < 0)
- offset = 0;
-
- PullResult pullResult = consumer.pull(mq, "*", offset, 32);
- System.out.printf("%s%n", offset + "\t" + mq + "\t" + pullResult);
- switch (pullResult.getPullStatus()) {
- case FOUND:
- break;
- case NO_MATCHED_MSG:
- break;
- case NO_NEW_MSG:
- case OFFSET_ILLEGAL:
- break;
- default:
- break;
- }
- consumer.updateConsumeOffset(mq, pullResult.getNextBeginOffset());
-
- //consume message auto
- context.setPullNextDelayTimeMillis(100);
- } catch (Exception e) {
- e.printStackTrace();
+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);
}
- }
-});
-
-scheduleService.start();
-```
-
-#### Have fun with `MQPullConsumerScheduleService`.
+ // Shutdown producer after use.
+ producer.shutdown();
+ }
+
+}
+```
\ No newline at end of file
[6/7] incubator-rocketmq-site git commit: Update scheduled message
example
Posted by li...@apache.org.
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/blob/c6a0f07e/content/feed.xslt.xml
----------------------------------------------------------------------
diff --git a/content/feed.xslt.xml b/content/feed.xslt.xml
deleted file mode 100644
index 15901c1..0000000
--- a/content/feed.xslt.xml
+++ /dev/null
@@ -1,4 +0,0 @@
-<?xml version="1.0" encoding="utf-8"?><xsl:transform version="1.0"
- xmlns:a="http://www.w3.org/2005/Atom"
- xmlns:xsl="http://www.w3.org/1999/XSL/Transform"
-><xsl:strip-space elements="*"/><xsl:output method="text"/><xsl:template match="*"/><xsl:template match="a:feed"><xsl:text>Atom Feed:</xsl:text><xsl:value-of select="a:id"/><xsl:text> </xsl:text><xsl:apply-templates/></xsl:template><xsl:template match="a:entry"><xsl:text> ---------------------------------------- </xsl:text><xsl:text> Feed entry:</xsl:text><xsl:value-of select="a:id"/><xsl:text> </xsl:text><xsl:apply-templates/></xsl:template><xsl:template match="a:title"><xsl:if test="parent::a:entry"><xsl:value-of select="' '"/></xsl:if><xsl:value-of select="local-name()"/>:<xsl:apply-templates/><xsl:text> </xsl:text></xsl:template><xsl:template match="a:published|a:updated"><xsl:if test="parent::a:entry"><xsl:value-of select="' '"/></xsl:if><xsl:value-of select="local-name()"/>:<xsl:apply-templates/><xsl:text> </xsl:text></xsl:template></xsl:transform>
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/blob/c6a0f07e/content/robots.txt
----------------------------------------------------------------------
diff --git a/content/robots.txt b/content/robots.txt
new file mode 100644
index 0000000..e087884
--- /dev/null
+++ b/content/robots.txt
@@ -0,0 +1 @@
+Sitemap: /sitemap.xml
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/blob/c6a0f07e/content/sitemap.xml
----------------------------------------------------------------------
diff --git a/content/sitemap.xml b/content/sitemap.xml
index c9e7993..9edb2ec 100644
--- a/content/sitemap.xml
+++ b/content/sitemap.xml
@@ -1,160 +1,157 @@
<?xml version="1.0" encoding="UTF-8"?>
<urlset xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.sitemaps.org/schemas/sitemap/0.9 http://www.sitemaps.org/schemas/sitemap/0.9/sitemap.xsd" xmlns="http://www.sitemaps.org/schemas/sitemap/0.9">
<url>
-<loc>/release-notes-4.1.0-incubating/</loc>
-<lastmod>2017-06-02T00:00:00+08:00</lastmod>
-</url>
-<url>
-<loc>/rocketmq/filter-messages-by-sql92-in-rocketmq/</loc>
-<lastmod>2017-04-26T00:00:00+08:00</lastmod>
-</url>
-<url>
-<loc>/activity/launch-rocketmq-code-marathon/</loc>
-<lastmod>2017-03-31T00:00:00+08:00</lastmod>
-</url>
-<url>
-<loc>/the-correct-posture-of-submitting-pull-request/</loc>
-<lastmod>2017-03-24T00:00:00+08:00</lastmod>
-</url>
-<url>
-<loc>/rocketmq/four-methods-to-feed-name-server-address-list/</loc>
-<lastmod>2017-02-10T00:00:00+08:00</lastmod>
-</url>
-<url>
-<loc>/release_notes/release-notes-4.0.0-incubating/</loc>
-<lastmod>2017-01-24T00:00:00+08:00</lastmod>
-</url>
-<url>
-<loc>/activity/launch-rocketmq-code-marathon/</loc>
-<lastmod>2017-01-05T00:00:00+08:00</lastmod>
+<loc>/about/team/</loc>
+<lastmod>2017-06-08T11:24:44+08:00</lastmod>
</url>
<url>
-<loc>/maven/mastering-component-compatible-dependency/</loc>
-<lastmod>2016-12-23T00:00:00+08:00</lastmod>
+<loc>/about/contact/</loc>
+<lastmod>2017-06-08T11:24:44+08:00</lastmod>
</url>
<url>
-<loc>/rocketmq/how-to-support-more-queues-in-rocketmq/</loc>
-<lastmod>2016-12-23T00:00:00+08:00</lastmod>
+<loc>/about/rewards/</loc>
+<lastmod>2017-06-08T11:24:44+08:00</lastmod>
</url>
<url>
<loc>/docs/quick-start/</loc>
-</url>
-<url>
-<loc>/about/team/</loc>
-</url>
-<url>
-<loc>/about/contact/</loc>
+<lastmod>2017-06-08T11:24:44+08:00</lastmod>
</url>
<url>
<loc>/docs/motivation/</loc>
+<lastmod>2017-06-08T11:24:44+08:00</lastmod>
</url>
<url>
<loc>/docs/core-concept/</loc>
-</url>
-<url>
-<loc>/about/rewards/</loc>
+<lastmod>2017-06-08T11:24:44+08:00</lastmod>
</url>
<url>
<loc>/docs/cli-admin-tool/</loc>
+<lastmod>2017-06-08T11:24:44+08:00</lastmod>
</url>
<url>
<loc>/docs/cluster-deployment/</loc>
+<lastmod>2017-06-08T11:24:44+08:00</lastmod>
</url>
<url>
<loc>/docs/pull-request/</loc>
+<lastmod>2017-06-08T11:24:44+08:00</lastmod>
</url>
<url>
<loc>/docs/code-guidelines/</loc>
+<lastmod>2017-06-08T11:24:44+08:00</lastmod>
</url>
<url>
<loc>/docs/documentation/</loc>
+<lastmod>2017-06-08T11:24:44+08:00</lastmod>
</url>
<url>
<loc>/docs/faq/</loc>
+<lastmod>2017-06-08T11:24:44+08:00</lastmod>
</url>
<url>
<loc>/docs/release-manual</loc>
+<lastmod>2017-06-08T11:24:44+08:00</lastmod>
</url>
<url>
<loc>/dowloading/releases/</loc>
+<lastmod>2017-06-08T11:24:44+08:00</lastmod>
</url>
<url>
<loc>/docs/roadmap/</loc>
+<lastmod>2017-06-08T11:24:44+08:00</lastmod>
</url>
<url>
<loc>/docs/batch-example/</loc>
+<lastmod>2017-06-08T11:24:44+08:00</lastmod>
</url>
<url>
<loc>/docs/broadcast-example/</loc>
+<lastmod>2017-06-08T11:24:44+08:00</lastmod>
</url>
<url>
<loc>/docs/rmq-deployment/</loc>
+<lastmod>2017-06-08T11:24:44+08:00</lastmod>
</url>
<url>
<loc>/docs/order-example/</loc>
+<lastmod>2017-06-08T11:24:44+08:00</lastmod>
</url>
<url>
<loc>/docs/rmq-arc/</loc>
+<lastmod>2017-06-08T11:24:44+08:00</lastmod>
</url>
<url>
<loc>/docs/schedule-example/</loc>
+<lastmod>2017-06-08T11:24:44+08:00</lastmod>
</url>
<url>
<loc>/docs/simple-example/</loc>
+<lastmod>2017-06-08T11:24:44+08:00</lastmod>
</url>
<url>
<loc>/docs/filter-by-sql92-example/</loc>
-</url>
-<url>
-<loc>/about/</loc>
-</url>
-<url>
-<loc>/archive-layout-with-content/</loc>
+<lastmod>2017-06-08T11:24:44+08:00</lastmod>
</url>
<url>
<loc>/docs/best-practice-broker/</loc>
+<lastmod>2017-06-08T11:24:44+08:00</lastmod>
</url>
<url>
<loc>/docs/best-practice-consumer/</loc>
+<lastmod>2017-06-08T11:24:44+08:00</lastmod>
</url>
<url>
<loc>/docs/best-practice-namesvr/</loc>
+<lastmod>2017-06-08T11:24:44+08:00</lastmod>
</url>
<url>
<loc>/docs/best-practice-producer/</loc>
+<lastmod>2017-06-08T11:24:44+08:00</lastmod>
</url>
<url>
-<loc>/categories/</loc>
+<loc>/rocketmq/how-to-support-more-queues-in-rocketmq/</loc>
+<lastmod>2016-12-23T00:00:00+08:00</lastmod>
</url>
<url>
-<loc>/collection-archive/</loc>
+<loc>/maven/mastering-component-compatible-dependency/</loc>
+<lastmod>2016-12-23T00:00:00+08:00</lastmod>
</url>
<url>
-<loc>/community/</loc>
+<loc>/activity/launch-rocketmq-code-marathon/</loc>
+<lastmod>2017-01-05T00:00:00+08:00</lastmod>
</url>
<url>
-<loc>/customer/</loc>
+<loc>/release_notes/release-notes-4.0.0-incubating/</loc>
+<lastmod>2017-01-24T00:00:00+08:00</lastmod>
</url>
<url>
-<loc>/</loc>
+<loc>/rocketmq/four-methods-to-feed-name-server-address-list/</loc>
+<lastmod>2017-02-10T00:00:00+08:00</lastmod>
</url>
<url>
-<loc>/tags/</loc>
+<loc>/the-correct-posture-of-submitting-pull-request/</loc>
+<lastmod>2017-03-24T00:00:00+08:00</lastmod>
</url>
<url>
-<loc>/year-archive/</loc>
+<loc>/activity/launch-rocketmq-code-marathon/</loc>
+<lastmod>2017-03-31T00:00:00+08:00</lastmod>
</url>
<url>
-<loc>/about/team/</loc>
+<loc>/rocketmq/filter-messages-by-sql92-in-rocketmq/</loc>
+<lastmod>2017-04-26T00:00:00+08:00</lastmod>
</url>
<url>
-<loc>/about/contact/</loc>
+<loc>/release-notes-4.1.0-incubating/</loc>
+<lastmod>2017-06-02T00:00:00+08:00</lastmod>
</url>
<url>
-<loc>/about/rewards/</loc>
+<loc>/docs/quick-start/</loc>
</url>
<url>
-<loc>/docs/quick-start/</loc>
+<loc>/about/team/</loc>
+</url>
+<url>
+<loc>/about/contact/</loc>
</url>
<url>
<loc>/docs/motivation/</loc>
@@ -163,6 +160,9 @@
<loc>/docs/core-concept/</loc>
</url>
<url>
+<loc>/about/rewards/</loc>
+</url>
+<url>
<loc>/docs/cli-admin-tool/</loc>
</url>
<url>
@@ -214,6 +214,12 @@
<loc>/docs/filter-by-sql92-example/</loc>
</url>
<url>
+<loc>/about/</loc>
+</url>
+<url>
+<loc>/archive-layout-with-content/</loc>
+</url>
+<url>
<loc>/docs/best-practice-broker/</loc>
</url>
<url>
@@ -226,11 +232,32 @@
<loc>/docs/best-practice-producer/</loc>
</url>
<url>
+<loc>/categories/</loc>
+</url>
+<url>
+<loc>/collection-archive/</loc>
+</url>
+<url>
+<loc>/community/</loc>
+</url>
+<url>
+<loc>/customer/</loc>
+</url>
+<url>
+<loc>/</loc>
+</url>
+<url>
+<loc>/tags/</loc>
+</url>
+<url>
+<loc>/year-archive/</loc>
+</url>
+<url>
<loc>/assets/attachment/launch-rocketmq-code-marathon.pdf</loc>
-<lastmod>2017-03-16T18:55:20+08:00</lastmod>
+<lastmod>2017-06-07T11:10:53+08:00</lastmod>
</url>
<url>
<loc>/assets/attachment/launch-second-rocketmq-code-marathon.pdf</loc>
-<lastmod>2017-04-26T16:48:16+08:00</lastmod>
+<lastmod>2017-06-07T11:10:53+08:00</lastmod>
</url>
</urlset>
[2/7] incubator-rocketmq-site git commit: Add a verfication section
Posted by li...@apache.org.
Add a verfication section
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/10f8abe5
Tree: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/tree/10f8abe5
Diff: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/diff/10f8abe5
Branch: refs/heads/asf-site
Commit: 10f8abe52ce5c1fe81281400ef8d2fc9b77b76b9
Parents: 3bb9502
Author: Li Zhanhui <li...@gmail.com>
Authored: Wed Jun 7 12:41:13 2017 +0800
Committer: Li Zhanhui <li...@gmail.com>
Committed: Wed Jun 7 12:41:13 2017 +0800
----------------------------------------------------------------------
.gitignore | 1 +
_docs/17-rmq-schedule-example.md | 6 +++++-
2 files changed, 6 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/blob/10f8abe5/.gitignore
----------------------------------------------------------------------
diff --git a/.gitignore b/.gitignore
index 928dad0..ed99deb 100644
--- a/.gitignore
+++ b/.gitignore
@@ -14,3 +14,4 @@ example/_site
Gemfile.lock
node_modules
npm-debug.log*
+*.iml
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/blob/10f8abe5/_docs/17-rmq-schedule-example.md
----------------------------------------------------------------------
diff --git a/_docs/17-rmq-schedule-example.md b/_docs/17-rmq-schedule-example.md
index 0340f21..1fa1d64 100644
--- a/_docs/17-rmq-schedule-example.md
+++ b/_docs/17-rmq-schedule-example.md
@@ -79,4 +79,8 @@ public class ScheduledMessageProducer {
}
}
-```
\ No newline at end of file
+```
+
+3. Verification
+
+You should see messages are consumed about 10 seconds later than their storing time.
\ No newline at end of file
[7/7] incubator-rocketmq-site git commit: Update scheduled message
example
Posted by li...@apache.org.
Update scheduled message example
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/c6a0f07e
Tree: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/tree/c6a0f07e
Diff: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/diff/c6a0f07e
Branch: refs/heads/asf-site
Commit: c6a0f07edb64bc8e4b25af54ae23c755be42ca46
Parents: 62d3286
Author: Li Zhanhui <li...@gmail.com>
Authored: Thu Jun 8 11:25:28 2017 +0800
Committer: Li Zhanhui <li...@gmail.com>
Committed: Thu Jun 8 11:25:28 2017 +0800
----------------------------------------------------------------------
content/about/contact/index.html | 8 +-
content/about/rewards/index.html | 8 +-
content/about/team/index.html | 8 +-
content/archive-layout-with-content/index.html | 17 ++-
content/docs/batch-example/index.html | 8 +-
content/docs/best-practice-broker/index.html | 8 +-
content/docs/best-practice-consumer/index.html | 8 +-
content/docs/best-practice-namesvr/index.html | 8 +-
content/docs/best-practice-producer/index.html | 8 +-
content/docs/broadcast-example/index.html | 8 +-
content/docs/cli-admin-tool/index.html | 8 +-
content/docs/cluster-deployment/index.html | 8 +-
content/docs/code-guidelines/index.html | 8 +-
content/docs/core-concept/index.html | 8 +-
content/docs/documentation/index.html | 8 +-
content/docs/faq/index.html | 8 +-
content/docs/filter-by-sql92-example/index.html | 8 +-
content/docs/motivation/index.html | 8 +-
content/docs/order-example/index.html | 8 +-
content/docs/pull-request/index.html | 8 +-
content/docs/quick-start/index.html | 8 +-
content/docs/release-manual.html | 8 +-
content/docs/rmq-arc/index.html | 8 +-
content/docs/rmq-deployment/index.html | 8 +-
content/docs/roadmap/index.html | 8 +-
content/docs/schedule-example/index.html | 142 +++++++++---------
content/docs/simple-example/index.html | 8 +-
content/dowloading/releases/index.html | 8 +-
content/feed.xml | 13 +-
content/feed.xslt.xml | 4 -
content/robots.txt | 1 +
content/sitemap.xml | 143 +++++++++++--------
32 files changed, 287 insertions(+), 241 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/blob/c6a0f07e/content/about/contact/index.html
----------------------------------------------------------------------
diff --git a/content/about/contact/index.html b/content/about/contact/index.html
index 00117ad..29ceb65 100644
--- a/content/about/contact/index.html
+++ b/content/about/contact/index.html
@@ -57,7 +57,7 @@
<meta property="og:type" content="article">
- <meta property="article:published_time" content="2017-06-06T21:20:18+08:00">
+ <meta property="article:published_time" content="2017-06-08T11:24:44+08:00">
@@ -212,8 +212,8 @@
<article class="page" itemscope itemtype="http://schema.org/CreativeWork">
<meta itemprop="headline" content="CONTACT">
<meta itemprop="description" content="Contact.">
- <meta itemprop="datePublished" content="June 06, 2017">
- <meta itemprop="dateModified" content="December 29, 2016">
+ <meta itemprop="datePublished" content="June 08, 2017">
+ <meta itemprop="dateModified" content="December 28, 2016">
<div class="page__inner-wrap">
@@ -283,7 +283,7 @@
- <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2016-12-29">December 29, 2016</time></p>
+ <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2016-12-28">December 28, 2016</time></p>
</footer>
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/blob/c6a0f07e/content/about/rewards/index.html
----------------------------------------------------------------------
diff --git a/content/about/rewards/index.html b/content/about/rewards/index.html
index 3f3a08e..43142c1 100644
--- a/content/about/rewards/index.html
+++ b/content/about/rewards/index.html
@@ -57,7 +57,7 @@
<meta property="og:type" content="article">
- <meta property="article:published_time" content="2017-06-06T21:20:18+08:00">
+ <meta property="article:published_time" content="2017-06-08T11:24:44+08:00">
@@ -212,8 +212,8 @@
<article class="page" itemscope itemtype="http://schema.org/CreativeWork">
<meta itemprop="headline" content="REWARDS">
<meta itemprop="description" content="Rewards.">
- <meta itemprop="datePublished" content="June 06, 2017">
- <meta itemprop="dateModified" content="January 25, 2017">
+ <meta itemprop="datePublished" content="June 08, 2017">
+ <meta itemprop="dateModified" content="January 24, 2017">
<div class="page__inner-wrap">
@@ -240,7 +240,7 @@
- <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2017-01-25">January 25, 2017</time></p>
+ <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2017-01-24">January 24, 2017</time></p>
</footer>
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/blob/c6a0f07e/content/about/team/index.html
----------------------------------------------------------------------
diff --git a/content/about/team/index.html b/content/about/team/index.html
index c6f545e..020ed0c 100644
--- a/content/about/team/index.html
+++ b/content/about/team/index.html
@@ -57,7 +57,7 @@
<meta property="og:type" content="article">
- <meta property="article:published_time" content="2017-06-06T21:20:18+08:00">
+ <meta property="article:published_time" content="2017-06-08T11:24:44+08:00">
@@ -212,8 +212,8 @@
<article class="page" itemscope itemtype="http://schema.org/CreativeWork">
<meta itemprop="headline" content="TEAM">
<meta itemprop="description" content="Project team.">
- <meta itemprop="datePublished" content="June 06, 2017">
- <meta itemprop="dateModified" content="December 29, 2016">
+ <meta itemprop="datePublished" content="June 08, 2017">
+ <meta itemprop="dateModified" content="December 28, 2016">
<div class="page__inner-wrap">
@@ -434,7 +434,7 @@
- <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2016-12-29">December 29, 2016</time></p>
+ <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2016-12-28">December 28, 2016</time></p>
</footer>
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/blob/c6a0f07e/content/archive-layout-with-content/index.html
----------------------------------------------------------------------
diff --git a/content/archive-layout-with-content/index.html b/content/archive-layout-with-content/index.html
index e85d70b..37a6a25 100644
--- a/content/archive-layout-with-content/index.html
+++ b/content/archive-layout-with-content/index.html
@@ -1083,7 +1083,20 @@
<h2 class="archive__item-title" itemprop="headline">
- <a href="/feed.xml" rel="permalink"></a>
+ <a href="/sitemap.xml" rel="permalink"></a>
+
+ </h2>
+
+
+ </article>
+</div>
+
+<div class="list__item">
+ <article class="archive__item" itemscope="" itemtype="http://schema.org/CreativeWork">
+
+ <h2 class="archive__item-title" itemprop="headline">
+
+ <a href="/robots.txt" rel="permalink"></a>
</h2>
@@ -1096,7 +1109,7 @@
<h2 class="archive__item-title" itemprop="headline">
- <a href="/feed.xslt.xml" rel="permalink"></a>
+ <a href="/feed.xml" rel="permalink"></a>
</h2>
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/blob/c6a0f07e/content/docs/batch-example/index.html
----------------------------------------------------------------------
diff --git a/content/docs/batch-example/index.html b/content/docs/batch-example/index.html
index ee5a91c..da410d2 100644
--- a/content/docs/batch-example/index.html
+++ b/content/docs/batch-example/index.html
@@ -57,7 +57,7 @@
<meta property="og:type" content="article">
- <meta property="article:published_time" content="2017-06-06T21:20:18+08:00">
+ <meta property="article:published_time" content="2017-06-08T11:24:44+08:00">
@@ -429,8 +429,8 @@
<article class="page" itemscope itemtype="http://schema.org/CreativeWork">
<meta itemprop="headline" content="Batch Example">
<meta itemprop="description" content="How to use batch in Rocketmq">
- <meta itemprop="datePublished" content="June 06, 2017">
- <meta itemprop="dateModified" content="April 25, 2017">
+ <meta itemprop="datePublished" content="June 08, 2017">
+ <meta itemprop="dateModified" content="April 24, 2017">
<div class="page__inner-wrap">
@@ -550,7 +550,7 @@
- <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2017-04-25">April 25, 2017</time></p>
+ <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2017-04-24">April 24, 2017</time></p>
</footer>
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/blob/c6a0f07e/content/docs/best-practice-broker/index.html
----------------------------------------------------------------------
diff --git a/content/docs/best-practice-broker/index.html b/content/docs/best-practice-broker/index.html
index 5a8cf90..15090df 100644
--- a/content/docs/best-practice-broker/index.html
+++ b/content/docs/best-practice-broker/index.html
@@ -57,7 +57,7 @@
<meta property="og:type" content="article">
- <meta property="article:published_time" content="2017-06-06T21:20:18+08:00">
+ <meta property="article:published_time" content="2017-06-08T11:24:44+08:00">
@@ -429,8 +429,8 @@
<article class="page" itemscope itemtype="http://schema.org/CreativeWork">
<meta itemprop="headline" content="Best Practice For Broker">
<meta itemprop="description" content="Some useful tips for users.">
- <meta itemprop="datePublished" content="June 06, 2017">
- <meta itemprop="dateModified" content="December 25, 2016">
+ <meta itemprop="datePublished" content="June 08, 2017">
+ <meta itemprop="dateModified" content="December 24, 2016">
<div class="page__inner-wrap">
@@ -479,7 +479,7 @@ If you just want to make it easy, you may only need a ASYNC_MASTER without SLAVE
- <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2016-12-25">December 25, 2016</time></p>
+ <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2016-12-24">December 24, 2016</time></p>
</footer>
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/blob/c6a0f07e/content/docs/best-practice-consumer/index.html
----------------------------------------------------------------------
diff --git a/content/docs/best-practice-consumer/index.html b/content/docs/best-practice-consumer/index.html
index 86232c1..8d2e29c 100644
--- a/content/docs/best-practice-consumer/index.html
+++ b/content/docs/best-practice-consumer/index.html
@@ -57,7 +57,7 @@
<meta property="og:type" content="article">
- <meta property="article:published_time" content="2017-06-06T21:20:18+08:00">
+ <meta property="article:published_time" content="2017-06-08T11:24:44+08:00">
@@ -429,8 +429,8 @@
<article class="page" itemscope itemtype="http://schema.org/CreativeWork">
<meta itemprop="headline" content="Best Practice For Consumer">
<meta itemprop="description" content="Some useful tips for users.">
- <meta itemprop="datePublished" content="June 06, 2017">
- <meta itemprop="dateModified" content="December 25, 2016">
+ <meta itemprop="datePublished" content="June 08, 2017">
+ <meta itemprop="dateModified" content="December 24, 2016">
<div class="page__inner-wrap">
@@ -504,7 +504,7 @@ You can also use CONSUME_FROM_TIMESTAMP to consume messages produced after the s
- <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2016-12-25">December 25, 2016</time></p>
+ <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2016-12-24">December 24, 2016</time></p>
</footer>
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/blob/c6a0f07e/content/docs/best-practice-namesvr/index.html
----------------------------------------------------------------------
diff --git a/content/docs/best-practice-namesvr/index.html b/content/docs/best-practice-namesvr/index.html
index 7105eab..52075fe 100644
--- a/content/docs/best-practice-namesvr/index.html
+++ b/content/docs/best-practice-namesvr/index.html
@@ -57,7 +57,7 @@
<meta property="og:type" content="article">
- <meta property="article:published_time" content="2017-06-06T21:20:18+08:00">
+ <meta property="article:published_time" content="2017-06-08T11:24:44+08:00">
@@ -429,8 +429,8 @@
<article class="page" itemscope itemtype="http://schema.org/CreativeWork">
<meta itemprop="headline" content="Best Practice For NameServer">
<meta itemprop="description" content="In Apache RocketMQ, name servers are designed to coordinate each component of the distributed systemand fulfill much of this responsibility through managing topic route information.">
- <meta itemprop="datePublished" content="June 06, 2017">
- <meta itemprop="dateModified" content="December 25, 2016">
+ <meta itemprop="datePublished" content="June 08, 2017">
+ <meta itemprop="dateModified" content="December 24, 2016">
<div class="page__inner-wrap">
@@ -540,7 +540,7 @@ You may also override <code class="highlighter-rouge">nsaddr</code> part by this
- <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2016-12-25">December 25, 2016</time></p>
+ <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2016-12-24">December 24, 2016</time></p>
</footer>
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/blob/c6a0f07e/content/docs/best-practice-producer/index.html
----------------------------------------------------------------------
diff --git a/content/docs/best-practice-producer/index.html b/content/docs/best-practice-producer/index.html
index ee0888a..698819f 100644
--- a/content/docs/best-practice-producer/index.html
+++ b/content/docs/best-practice-producer/index.html
@@ -57,7 +57,7 @@
<meta property="og:type" content="article">
- <meta property="article:published_time" content="2017-06-06T21:20:18+08:00">
+ <meta property="article:published_time" content="2017-06-08T11:24:44+08:00">
@@ -429,8 +429,8 @@
<article class="page" itemscope itemtype="http://schema.org/CreativeWork">
<meta itemprop="headline" content="Best Practice For Producer">
<meta itemprop="description" content="Some useful tips for users.">
- <meta itemprop="datePublished" content="June 06, 2017">
- <meta itemprop="dateModified" content="December 25, 2016">
+ <meta itemprop="datePublished" content="June 08, 2017">
+ <meta itemprop="dateModified" content="December 24, 2016">
<div class="page__inner-wrap">
@@ -513,7 +513,7 @@ In default, you can only create only one producer with the same producer group i
- <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2016-12-25">December 25, 2016</time></p>
+ <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2016-12-24">December 24, 2016</time></p>
</footer>
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/blob/c6a0f07e/content/docs/broadcast-example/index.html
----------------------------------------------------------------------
diff --git a/content/docs/broadcast-example/index.html b/content/docs/broadcast-example/index.html
index 8343868..3bc9f69 100644
--- a/content/docs/broadcast-example/index.html
+++ b/content/docs/broadcast-example/index.html
@@ -57,7 +57,7 @@
<meta property="og:type" content="article">
- <meta property="article:published_time" content="2017-06-06T21:20:18+08:00">
+ <meta property="article:published_time" content="2017-06-08T11:24:44+08:00">
@@ -429,8 +429,8 @@
<article class="page" itemscope itemtype="http://schema.org/CreativeWork">
<meta itemprop="headline" content="Broadcasting">
<meta itemprop="description" content="How to send broadcast messages in Apache RocketMQ.">
- <meta itemprop="datePublished" content="June 06, 2017">
- <meta itemprop="dateModified" content="April 25, 2017">
+ <meta itemprop="datePublished" content="June 08, 2017">
+ <meta itemprop="dateModified" content="April 24, 2017">
<div class="page__inner-wrap">
@@ -518,7 +518,7 @@
- <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2017-04-25">April 25, 2017</time></p>
+ <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2017-04-24">April 24, 2017</time></p>
</footer>
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/blob/c6a0f07e/content/docs/cli-admin-tool/index.html
----------------------------------------------------------------------
diff --git a/content/docs/cli-admin-tool/index.html b/content/docs/cli-admin-tool/index.html
index a04390f..54e84f2 100644
--- a/content/docs/cli-admin-tool/index.html
+++ b/content/docs/cli-admin-tool/index.html
@@ -57,7 +57,7 @@
<meta property="og:type" content="article">
- <meta property="article:published_time" content="2017-06-06T21:20:18+08:00">
+ <meta property="article:published_time" content="2017-06-08T11:24:44+08:00">
@@ -429,8 +429,8 @@
<article class="page" itemscope itemtype="http://schema.org/CreativeWork">
<meta itemprop="headline" content="CLI Admin Tool">
<meta itemprop="description" content="RocketMQ provides a CLI admin tool belt to query, manage and diagnose various issues.">
- <meta itemprop="datePublished" content="June 06, 2017">
- <meta itemprop="dateModified" content="December 17, 2016">
+ <meta itemprop="datePublished" content="June 08, 2017">
+ <meta itemprop="dateModified" content="December 16, 2016">
<div class="page__inner-wrap">
@@ -540,7 +540,7 @@ See 'mqadmin help <command>' for more information on a specific command.
- <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2016-12-17">December 17, 2016</time></p>
+ <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2016-12-16">December 16, 2016</time></p>
</footer>
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/blob/c6a0f07e/content/docs/cluster-deployment/index.html
----------------------------------------------------------------------
diff --git a/content/docs/cluster-deployment/index.html b/content/docs/cluster-deployment/index.html
index 8ec4cdd..e520172 100644
--- a/content/docs/cluster-deployment/index.html
+++ b/content/docs/cluster-deployment/index.html
@@ -57,7 +57,7 @@
<meta property="og:type" content="article">
- <meta property="article:published_time" content="2017-06-06T21:20:18+08:00">
+ <meta property="article:published_time" content="2017-06-08T11:24:44+08:00">
@@ -429,8 +429,8 @@
<article class="page" itemscope itemtype="http://schema.org/CreativeWork">
<meta itemprop="headline" content="Cluster Configuration and Deployment">
<meta itemprop="description" content="Prerequisite">
- <meta itemprop="datePublished" content="June 06, 2017">
- <meta itemprop="dateModified" content="December 17, 2016">
+ <meta itemprop="datePublished" content="June 08, 2017">
+ <meta itemprop="dateModified" content="December 16, 2016">
<div class="page__inner-wrap">
@@ -544,7 +544,7 @@ Assuming binary RocketMQ is at <code class="highlighter-rouge">/home/rocketmq/di
- <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2016-12-17">December 17, 2016</time></p>
+ <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2016-12-16">December 16, 2016</time></p>
</footer>
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/blob/c6a0f07e/content/docs/code-guidelines/index.html
----------------------------------------------------------------------
diff --git a/content/docs/code-guidelines/index.html b/content/docs/code-guidelines/index.html
index 42558bc..d3a8338 100644
--- a/content/docs/code-guidelines/index.html
+++ b/content/docs/code-guidelines/index.html
@@ -57,7 +57,7 @@
<meta property="og:type" content="article">
- <meta property="article:published_time" content="2017-06-06T21:20:18+08:00">
+ <meta property="article:published_time" content="2017-06-08T11:24:44+08:00">
@@ -429,8 +429,8 @@
<article class="page" itemscope itemtype="http://schema.org/CreativeWork">
<meta itemprop="headline" content="Coding Guidelines">
<meta itemprop="description" content="Apache RocketMQ Coding Guidelines">
- <meta itemprop="datePublished" content="June 06, 2017">
- <meta itemprop="dateModified" content="December 30, 2016">
+ <meta itemprop="datePublished" content="June 08, 2017">
+ <meta itemprop="dateModified" content="December 29, 2016">
<div class="page__inner-wrap">
@@ -489,7 +489,7 @@
- <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2016-12-30">December 30, 2016</time></p>
+ <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2016-12-29">December 29, 2016</time></p>
</footer>
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/blob/c6a0f07e/content/docs/core-concept/index.html
----------------------------------------------------------------------
diff --git a/content/docs/core-concept/index.html b/content/docs/core-concept/index.html
index 0ec46d7..86fb23d 100644
--- a/content/docs/core-concept/index.html
+++ b/content/docs/core-concept/index.html
@@ -57,7 +57,7 @@
<meta property="og:type" content="article">
- <meta property="article:published_time" content="2017-06-06T21:20:18+08:00">
+ <meta property="article:published_time" content="2017-06-08T11:24:44+08:00">
@@ -429,8 +429,8 @@
<article class="page" itemscope itemtype="http://schema.org/CreativeWork">
<meta itemprop="headline" content="Core Concept">
<meta itemprop="description" content="">
- <meta itemprop="datePublished" content="June 06, 2017">
- <meta itemprop="dateModified" content="December 17, 2016">
+ <meta itemprop="datePublished" content="June 08, 2017">
+ <meta itemprop="dateModified" content="December 16, 2016">
<div class="page__inner-wrap">
@@ -579,7 +579,7 @@
- <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2016-12-17">December 17, 2016</time></p>
+ <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2016-12-16">December 16, 2016</time></p>
</footer>
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/blob/c6a0f07e/content/docs/documentation/index.html
----------------------------------------------------------------------
diff --git a/content/docs/documentation/index.html b/content/docs/documentation/index.html
index 13cc0d6..7c38719 100644
--- a/content/docs/documentation/index.html
+++ b/content/docs/documentation/index.html
@@ -57,7 +57,7 @@
<meta property="og:type" content="article">
- <meta property="article:published_time" content="2017-06-06T21:20:18+08:00">
+ <meta property="article:published_time" content="2017-06-08T11:24:44+08:00">
@@ -429,8 +429,8 @@
<article class="page" itemscope itemtype="http://schema.org/CreativeWork">
<meta itemprop="headline" content="Documentation">
<meta itemprop="description" content="Apache RocketMQ Documentation">
- <meta itemprop="datePublished" content="June 06, 2017">
- <meta itemprop="dateModified" content="March 02, 2017">
+ <meta itemprop="datePublished" content="June 08, 2017">
+ <meta itemprop="dateModified" content="March 01, 2017">
<div class="page__inner-wrap">
@@ -513,7 +513,7 @@ Keep in mind that the audience may be a developer who would use RocketMQ for the
- <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2017-03-02">March 02, 2017</time></p>
+ <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2017-03-01">March 01, 2017</time></p>
</footer>
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/blob/c6a0f07e/content/docs/faq/index.html
----------------------------------------------------------------------
diff --git a/content/docs/faq/index.html b/content/docs/faq/index.html
index 2db6b4a..14864cb 100644
--- a/content/docs/faq/index.html
+++ b/content/docs/faq/index.html
@@ -57,7 +57,7 @@
<meta property="og:type" content="article">
- <meta property="article:published_time" content="2017-06-06T21:20:18+08:00">
+ <meta property="article:published_time" content="2017-06-08T11:24:44+08:00">
@@ -429,8 +429,8 @@
<article class="page" itemscope itemtype="http://schema.org/CreativeWork">
<meta itemprop="headline" content="Frequently Asked Questions">
<meta itemprop="description" content="The following questions are frequently asked with regard to the RocketMQ project in general.General1. Why did we create rocketmq project instead of selecting other products?Please refer to Why RocketMQ">
- <meta itemprop="datePublished" content="June 06, 2017">
- <meta itemprop="dateModified" content="December 28, 2016">
+ <meta itemprop="datePublished" content="June 08, 2017">
+ <meta itemprop="dateModified" content="December 27, 2016">
<div class="page__inner-wrap">
@@ -553,7 +553,7 @@ The broadcaset consumption still ensures that a message is consumered at least o
- <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2016-12-28">December 28, 2016</time></p>
+ <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2016-12-27">December 27, 2016</time></p>
</footer>
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/blob/c6a0f07e/content/docs/filter-by-sql92-example/index.html
----------------------------------------------------------------------
diff --git a/content/docs/filter-by-sql92-example/index.html b/content/docs/filter-by-sql92-example/index.html
index 7e98fdb..dd751de 100644
--- a/content/docs/filter-by-sql92-example/index.html
+++ b/content/docs/filter-by-sql92-example/index.html
@@ -57,7 +57,7 @@
<meta property="og:type" content="article">
- <meta property="article:published_time" content="2017-06-06T21:20:18+08:00">
+ <meta property="article:published_time" content="2017-06-08T11:24:44+08:00">
@@ -429,8 +429,8 @@
<article class="page" itemscope itemtype="http://schema.org/CreativeWork">
<meta itemprop="headline" content="Filter Example">
<meta itemprop="description" content="How to filter messages by SQL92 in Apache RocketMQ.">
- <meta itemprop="datePublished" content="June 06, 2017">
- <meta itemprop="dateModified" content="April 27, 2017">
+ <meta itemprop="datePublished" content="June 08, 2017">
+ <meta itemprop="dateModified" content="April 26, 2017">
<div class="page__inner-wrap">
@@ -561,7 +561,7 @@
- <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2017-04-27">April 27, 2017</time></p>
+ <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2017-04-26">April 26, 2017</time></p>
</footer>
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/blob/c6a0f07e/content/docs/motivation/index.html
----------------------------------------------------------------------
diff --git a/content/docs/motivation/index.html b/content/docs/motivation/index.html
index 3f020b9..a062d7d 100644
--- a/content/docs/motivation/index.html
+++ b/content/docs/motivation/index.html
@@ -57,7 +57,7 @@
<meta property="og:type" content="article">
- <meta property="article:published_time" content="2017-06-06T21:20:18+08:00">
+ <meta property="article:published_time" content="2017-06-08T11:24:44+08:00">
@@ -429,8 +429,8 @@
<article class="page" itemscope itemtype="http://schema.org/CreativeWork">
<meta itemprop="headline" content="Motivation">
<meta itemprop="description" content="At early stages, we constructed our distributed messaging middleware based on ActiveMQ 5.x(prior to 5.3). Our multinational business uses it for async communication, search, social network activity stream, data pipeline, even in its trade processes. As our trade business throughput rises, pressure originating from our messaging cluster also become urgent.">
- <meta itemprop="datePublished" content="June 06, 2017">
- <meta itemprop="dateModified" content="December 17, 2016">
+ <meta itemprop="datePublished" content="June 08, 2017">
+ <meta itemprop="dateModified" content="December 16, 2016">
<div class="page__inner-wrap">
@@ -542,7 +542,7 @@
- <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2016-12-17">December 17, 2016</time></p>
+ <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2016-12-16">December 16, 2016</time></p>
</footer>
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/blob/c6a0f07e/content/docs/order-example/index.html
----------------------------------------------------------------------
diff --git a/content/docs/order-example/index.html b/content/docs/order-example/index.html
index 9806af6..6191f5b 100644
--- a/content/docs/order-example/index.html
+++ b/content/docs/order-example/index.html
@@ -57,7 +57,7 @@
<meta property="og:type" content="article">
- <meta property="article:published_time" content="2017-06-06T21:20:18+08:00">
+ <meta property="article:published_time" content="2017-06-08T11:24:44+08:00">
@@ -429,8 +429,8 @@
<article class="page" itemscope itemtype="http://schema.org/CreativeWork">
<meta itemprop="headline" content="Order Message">
<meta itemprop="description" content="How to send and receive ordered messages in Apache RocketMQ.">
- <meta itemprop="datePublished" content="June 06, 2017">
- <meta itemprop="dateModified" content="April 25, 2017">
+ <meta itemprop="datePublished" content="June 08, 2017">
+ <meta itemprop="dateModified" content="April 24, 2017">
<div class="page__inner-wrap">
@@ -540,7 +540,7 @@
- <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2017-04-25">April 25, 2017</time></p>
+ <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2017-04-24">April 24, 2017</time></p>
</footer>
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/blob/c6a0f07e/content/docs/pull-request/index.html
----------------------------------------------------------------------
diff --git a/content/docs/pull-request/index.html b/content/docs/pull-request/index.html
index c533a25..5f25838 100644
--- a/content/docs/pull-request/index.html
+++ b/content/docs/pull-request/index.html
@@ -57,7 +57,7 @@
<meta property="og:type" content="article">
- <meta property="article:published_time" content="2017-06-06T21:20:18+08:00">
+ <meta property="article:published_time" content="2017-06-08T11:24:44+08:00">
@@ -429,8 +429,8 @@
<article class="page" itemscope itemtype="http://schema.org/CreativeWork">
<meta itemprop="headline" content="Best Practice in Pull Request">
<meta itemprop="description" content="This page guides you through Git setup and contribution process.">
- <meta itemprop="datePublished" content="June 06, 2017">
- <meta itemprop="dateModified" content="December 25, 2016">
+ <meta itemprop="datePublished" content="June 08, 2017">
+ <meta itemprop="dateModified" content="December 24, 2016">
<div class="page__inner-wrap">
@@ -645,7 +645,7 @@ In this case all subsequent comments will automatically be copied to jira withou
- <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2016-12-25">December 25, 2016</time></p>
+ <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2016-12-24">December 24, 2016</time></p>
</footer>
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/blob/c6a0f07e/content/docs/quick-start/index.html
----------------------------------------------------------------------
diff --git a/content/docs/quick-start/index.html b/content/docs/quick-start/index.html
index 42f7f5b..e71b367 100644
--- a/content/docs/quick-start/index.html
+++ b/content/docs/quick-start/index.html
@@ -57,7 +57,7 @@
<meta property="og:type" content="article">
- <meta property="article:published_time" content="2017-06-06T21:20:18+08:00">
+ <meta property="article:published_time" content="2017-06-08T11:24:44+08:00">
@@ -429,8 +429,8 @@
<article class="page" itemscope itemtype="http://schema.org/CreativeWork">
<meta itemprop="headline" content="Quick Start">
<meta itemprop="description" content="How to quickly install and setup Apache RocketMQ.">
- <meta itemprop="datePublished" content="June 06, 2017">
- <meta itemprop="dateModified" content="December 30, 2016">
+ <meta itemprop="datePublished" content="June 08, 2017">
+ <meta itemprop="dateModified" content="December 29, 2016">
<div class="page__inner-wrap">
@@ -528,7 +528,7 @@ Send shutdown request to mqnamesrv<span class="o">(</span>36664<span class="o">)
- <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2016-12-30">December 30, 2016</time></p>
+ <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2016-12-29">December 29, 2016</time></p>
</footer>
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/blob/c6a0f07e/content/docs/release-manual.html
----------------------------------------------------------------------
diff --git a/content/docs/release-manual.html b/content/docs/release-manual.html
index 282f62d..ae57037 100644
--- a/content/docs/release-manual.html
+++ b/content/docs/release-manual.html
@@ -57,7 +57,7 @@
<meta property="og:type" content="article">
- <meta property="article:published_time" content="2017-06-06T21:20:18+08:00">
+ <meta property="article:published_time" content="2017-06-08T11:24:44+08:00">
@@ -429,8 +429,8 @@
<article class="page" itemscope itemtype="http://schema.org/CreativeWork">
<meta itemprop="headline" content="Release Manual">
<meta itemprop="description" content="Apache RocketMQ Release Manual">
- <meta itemprop="datePublished" content="June 06, 2017">
- <meta itemprop="dateModified" content="February 08, 2017">
+ <meta itemprop="datePublished" content="June 08, 2017">
+ <meta itemprop="dateModified" content="February 07, 2017">
<div class="page__inner-wrap">
@@ -810,7 +810,7 @@ The Apache RocketMQ Team</p>
- <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2017-02-08">February 08, 2017</time></p>
+ <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2017-02-07">February 07, 2017</time></p>
</footer>
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/blob/c6a0f07e/content/docs/rmq-arc/index.html
----------------------------------------------------------------------
diff --git a/content/docs/rmq-arc/index.html b/content/docs/rmq-arc/index.html
index 286062a..03ea9ae 100644
--- a/content/docs/rmq-arc/index.html
+++ b/content/docs/rmq-arc/index.html
@@ -57,7 +57,7 @@
<meta property="og:type" content="article">
- <meta property="article:published_time" content="2017-06-06T21:20:18+08:00">
+ <meta property="article:published_time" content="2017-06-08T11:24:44+08:00">
@@ -429,8 +429,8 @@
<article class="page" itemscope itemtype="http://schema.org/CreativeWork">
<meta itemprop="headline" content="RocketMQ Architecture">
<meta itemprop="description" content="The main Architecture of Apache RocketMQ.">
- <meta itemprop="datePublished" content="June 06, 2017">
- <meta itemprop="dateModified" content="April 25, 2017">
+ <meta itemprop="datePublished" content="June 08, 2017">
+ <meta itemprop="dateModified" content="April 24, 2017">
<div class="page__inner-wrap">
@@ -525,7 +525,7 @@ RocketMQ’s website provides a simple quick-start guide[3] to interested users.
- <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2017-04-25">April 25, 2017</time></p>
+ <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2017-04-24">April 24, 2017</time></p>
</footer>
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/blob/c6a0f07e/content/docs/rmq-deployment/index.html
----------------------------------------------------------------------
diff --git a/content/docs/rmq-deployment/index.html b/content/docs/rmq-deployment/index.html
index c526bd3..98ee4e6 100644
--- a/content/docs/rmq-deployment/index.html
+++ b/content/docs/rmq-deployment/index.html
@@ -57,7 +57,7 @@
<meta property="og:type" content="article">
- <meta property="article:published_time" content="2017-06-06T21:20:18+08:00">
+ <meta property="article:published_time" content="2017-06-08T11:24:44+08:00">
@@ -429,8 +429,8 @@
<article class="page" itemscope itemtype="http://schema.org/CreativeWork">
<meta itemprop="headline" content="Deployment">
<meta itemprop="description" content="How to deploy the Apache RocketMQ.">
- <meta itemprop="datePublished" content="June 06, 2017">
- <meta itemprop="dateModified" content="April 25, 2017">
+ <meta itemprop="datePublished" content="June 08, 2017">
+ <meta itemprop="dateModified" content="April 24, 2017">
<div class="page__inner-wrap">
@@ -681,7 +681,7 @@ If you want to get more information about a specific command like ‘clusterList
- <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2017-04-25">April 25, 2017</time></p>
+ <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2017-04-24">April 24, 2017</time></p>
</footer>
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/blob/c6a0f07e/content/docs/roadmap/index.html
----------------------------------------------------------------------
diff --git a/content/docs/roadmap/index.html b/content/docs/roadmap/index.html
index 6f42f04..9723b15 100644
--- a/content/docs/roadmap/index.html
+++ b/content/docs/roadmap/index.html
@@ -57,7 +57,7 @@
<meta property="og:type" content="article">
- <meta property="article:published_time" content="2017-06-06T21:20:18+08:00">
+ <meta property="article:published_time" content="2017-06-08T11:24:44+08:00">
@@ -429,8 +429,8 @@
<article class="page" itemscope itemtype="http://schema.org/CreativeWork">
<meta itemprop="headline" content="The RoadMap of Apache RocketMQ">
<meta itemprop="description" content="4.1.0~4.3.0-incubating RoadMap:">
- <meta itemprop="datePublished" content="June 06, 2017">
- <meta itemprop="dateModified" content="March 08, 2017">
+ <meta itemprop="datePublished" content="June 08, 2017">
+ <meta itemprop="dateModified" content="March 07, 2017">
<div class="page__inner-wrap">
@@ -552,7 +552,7 @@
- <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2017-03-08">March 08, 2017</time></p>
+ <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2017-03-07">March 07, 2017</time></p>
</footer>
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/blob/c6a0f07e/content/docs/schedule-example/index.html
----------------------------------------------------------------------
diff --git a/content/docs/schedule-example/index.html b/content/docs/schedule-example/index.html
index 9878d07..162ac02 100644
--- a/content/docs/schedule-example/index.html
+++ b/content/docs/schedule-example/index.html
@@ -57,7 +57,7 @@
<meta property="og:type" content="article">
- <meta property="article:published_time" content="2017-06-06T21:20:18+08:00">
+ <meta property="article:published_time" content="2017-06-08T11:24:44+08:00">
@@ -429,8 +429,8 @@
<article class="page" itemscope itemtype="http://schema.org/CreativeWork">
<meta itemprop="headline" content="Schedule example">
<meta itemprop="description" content="How to use schedule component to reduce pull in RocketMQ.">
- <meta itemprop="datePublished" content="June 06, 2017">
- <meta itemprop="dateModified" content="April 25, 2017">
+ <meta itemprop="datePublished" content="June 08, 2017">
+ <meta itemprop="dateModified" content="April 24, 2017">
<div class="page__inner-wrap">
@@ -446,80 +446,92 @@
<nav class="toc">
<header><h4 class="nav__title"><i class="fa fa-file-text"></i> On This Page</h4></header>
<ul class="toc__menu" id="markdown-toc">
- <li><a href="#what-is-scheduled-message" id="markdown-toc-what-is-scheduled-message">What is scheduled message?</a> <ul>
- <li><a href="#defaultmqpullconsumer-use-case" id="markdown-toc-defaultmqpullconsumer-use-case">DefaultMQPullConsumer use case</a></li>
- <li><a href="#use-mqpullconsumerscheduleservice-consume-message" id="markdown-toc-use-mqpullconsumerscheduleservice-consume-message">Use MQPullConsumerScheduleService consume message</a></li>
- <li><a href="#have-fun-with-mqpullconsumerscheduleservice" id="markdown-toc-have-fun-with-mqpullconsumerscheduleservice">Have fun with <code class="highlighter-rouge">MQPullConsumerScheduleService</code>.</a></li>
- </ul>
- </li>
+ <li><a href="#what-is-scheduled-message" id="markdown-toc-what-is-scheduled-message">What is scheduled message?</a></li>
+ <li><a href="#application" id="markdown-toc-application">Application</a></li>
</ul>
</nav>
</aside>
<h3 id="what-is-scheduled-message">What is scheduled message?</h3>
-<p>Scheduled messages differ from normal messages such that they won’t be delivered until a provided time later.
-If you use <code class="highlighter-rouge">DefaultMQPullConsumer</code> to consume message, you have to fetch message manually. There are other options availible but <code class="highlighter-rouge">MQPullConsumerScheduleService</code> is the easiest.</p>
-<h4 id="defaultmqpullconsumer-use-case">DefaultMQPullConsumer use case</h4>
+<p>Scheduled messages differ from normal messages in that they won’t be delivered until a provided time later.</p>
-<blockquote>
- <p>First fetch subscribed queues of a topic</p>
-</blockquote>
+<h3 id="application">Application</h3>
-<div class="language-java highlighter-rouge"><pre class="highlight"><code><span class="n">Set</span><span class="o"><</span><span class="n">MessageQueue</span><span class="o">></span> <span class="n">testTopic</span> <span class="o">=</span> <span class="n">consumer</span><span class="o">.</span><span class="na">fetchSubscribeMessageQueues</span><span class="o">(</span><span class="s">"testTopic"</span><span class="o">);</span>
-</code></pre>
-</div>
+<ol>
+ <li>
+ <p>Start consumer to wait for incoming subscribed messages</p>
-<blockquote>
- <p>Second chose a queue to fetch message,and save queue offset manually.</p>
-</blockquote>
-
-<h4 id="use-mqpullconsumerscheduleservice-consume-message">Use MQPullConsumerScheduleService consume message</h4>
-
-<div class="language-java highlighter-rouge"><pre class="highlight"><code><span class="kd">final</span> <span class="n">MQPullConsumerScheduleService</span> <span class="n">scheduleService</span> <span class="o">=</span> <span class="k">new</span> <span class="n">MQPullConsumerScheduleService</span><span class="o">(</span><span class="s">"GroupName1"</span><span class="o">);</span>
-
-<span class="n">scheduleService</span><span class="o">.</span><span class="na">setMessageModel</span><span class="o">(</span><span class="n">MessageModel</span><span class="o">.</span><span class="na">CLUSTERING</span><span class="o">);</span>
-<span class="n">scheduleService</span><span class="o">.</span><span class="na">registerPullTaskCallback</span><span class="o">(</span><span class="s">"TopicTest1"</span><span class="o">,</span> <span class="k">new</span> <span class="n">PullTaskCallback</span><span class="o">()</span> <span class="o">{</span>
-
- <span class="nd">@Override</span>
- <span class="kd">public</span> <span class="kt">void</span> <span class="nf">doPullTask</span><span class="o">(</span><span class="n">MessageQueue</span> <span class="n">mq</span><span class="o">,</span> <span class="n">PullTaskContext</span> <span class="n">context</span><span class="o">)</span> <span class="o">{</span>
- <span class="n">MQPullConsumer</span> <span class="n">consumer</span> <span class="o">=</span> <span class="n">context</span><span class="o">.</span><span class="na">getPullConsumer</span><span class="o">();</span>
- <span class="k">try</span> <span class="o">{</span>
-
- <span class="kt">long</span> <span class="n">offset</span> <span class="o">=</span> <span class="n">consumer</span><span class="o">.</span><span class="na">fetchConsumeOffset</span><span class="o">(</span><span class="n">mq</span><span class="o">,</span> <span class="kc">false</span><span class="o">);</span>
- <span class="k">if</span> <span class="o">(</span><span class="n">offset</span> <span class="o"><</span> <span class="mi">0</span><span class="o">)</span>
- <span class="n">offset</span> <span class="o">=</span> <span class="mi">0</span><span class="o">;</span>
-
- <span class="n">PullResult</span> <span class="n">pullResult</span> <span class="o">=</span> <span class="n">consumer</span><span class="o">.</span><span class="na">pull</span><span class="o">(</span><span class="n">mq</span><span class="o">,</span> <span class="s">"*"</span><span class="o">,</span> <span class="n">offset</span><span class="o">,</span> <span class="mi">32</span><span class="o">);</span>
- <span class="n">System</span><span class="o">.</span><span class="na">out</span><span class="o">.</span><span class="na">printf</span><span class="o">(</span><span class="s">"%s%n"</span><span class="o">,</span> <span class="n">offset</span> <span class="o">+</span> <span class="s">"\t"</span> <span class="o">+</span> <span class="n">mq</span> <span class="o">+</span> <span class="s">"\t"</span> <span class="o">+</span> <span class="n">pullResult</span><span class="o">);</span>
- <span class="k">switch</span> <span class="o">(</span><span class="n">pullResult</span><span class="o">.</span><span class="na">getPullStatus</span><span class="o">())</span> <span class="o">{</span>
- <span class="k">case</span> <span class="nl">FOUND:</span>
- <span class="k">break</span><span class="o">;</span>
- <span class="k">case</span> <span class="nl">NO_MATCHED_MSG:</span>
- <span class="k">break</span><span class="o">;</span>
- <span class="k">case</span> <span class="nl">NO_NEW_MSG:</span>
- <span class="k">case</span> <span class="nl">OFFSET_ILLEGAL:</span>
- <span class="k">break</span><span class="o">;</span>
- <span class="k">default</span><span class="o">:</span>
- <span class="k">break</span><span class="o">;</span>
- <span class="o">}</span>
- <span class="n">consumer</span><span class="o">.</span><span class="na">updateConsumeOffset</span><span class="o">(</span><span class="n">mq</span><span class="o">,</span> <span class="n">pullResult</span><span class="o">.</span><span class="na">getNextBeginOffset</span><span class="o">());</span>
-
- <span class="c1">//consume message auto</span>
- <span class="n">context</span><span class="o">.</span><span class="na">setPullNextDelayTimeMillis</span><span class="o">(</span><span class="mi">100</span><span class="o">);</span>
- <span class="o">}</span> <span class="k">catch</span> <span class="o">(</span><span class="n">Exception</span> <span class="n">e</span><span class="o">)</span> <span class="o">{</span>
- <span class="n">e</span><span class="o">.</span><span class="na">printStackTrace</span><span class="o">();</span>
- <span class="o">}</span>
- <span class="o">}</span>
-<span class="o">});</span>
-
-<span class="n">scheduleService</span><span class="o">.</span><span class="na">start</span><span class="o">();</span>
+ <div class="language-java highlighter-rouge"><pre class="highlight"><code> <span class="kn">import</span> <span class="nn">org.apache.rocketmq.client.consumer.DefaultMQPushConsumer</span><span class="o">;</span>
+ <span class="kn">import</span> <span class="nn">org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext</span><span class="o">;</span>
+ <span class="kn">import</span> <span class="nn">org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus</span><span class="o">;</span>
+ <span class="kn">import</span> <span class="nn">org.apache.rocketmq.client.consumer.listener.MessageListenerConcurrently</span><span class="o">;</span>
+ <span class="kn">import</span> <span class="nn">org.apache.rocketmq.common.message.MessageExt</span><span class="o">;</span>
+ <span class="kn">import</span> <span class="nn">java.util.List</span><span class="o">;</span>
+
+ <span class="kd">public</span> <span class="kd">class</span> <span class="nc">ScheduledMessageConsumer</span> <span class="o">{</span>
+
+ <span class="kd">public</span> <span class="kd">static</span> <span class="kt">void</span> <span class="nf">main</span><span class="o">(</span><span class="n">String</span><span class="o">[]</span> <span class="n">args</span><span class="o">)</span> <span class="kd">throws</span> <span class="n">Exception</span> <span class="o">{</span>
+ <span class="c1">// Instantiate message consumer</span>
+ <span class="n">DefaultMQPushConsumer</span> <span class="n">consumer</span> <span class="o">=</span> <span class="k">new</span> <span class="n">DefaultMQPushConsumer</span><span class="o">(</span><span class="s">"ExampleConsumer"</span><span class="o">);</span>
+ <span class="c1">// Subscribe topics</span>
+ <span class="n">consumer</span><span class="o">.</span><span class="na">subscribe</span><span class="o">(</span><span class="s">"TestTopic"</span><span class="o">,</span> <span class="s">"*"</span><span class="o">);</span>
+ <span class="c1">// Register message listener</span>
+ <span class="n">consumer</span><span class="o">.</span><span class="na">registerMessageListener</span><span class="o">(</span><span class="k">new</span> <span class="n">MessageListenerConcurrently</span><span class="o">()</span> <span class="o">{</span>
+ <span class="nd">@Override</span>
+ <span class="kd">public</span> <span class="n">ConsumeConcurrentlyStatus</span> <span class="nf">consumeMessage</span><span class="o">(</span><span class="n">List</span><span class="o"><</span><span class="n">MessageExt</span><span class="o">></span> <span class="n">messages</span><span class="o">,</span> <span class="n">ConsumeConcurrentlyContext</span> <span class="n">context</span><span class="o">)</span> <span class="o">{</span>
+ <span class="k">for</span> <span class="o">(</span><span class="n">MessageExt</span> <span class="n">message</span> <span class="o">:</span> <span class="n">messages</span><span class="o">)</span> <span class="o">{</span>
+ <span class="c1">// Print approximate delay time period</span>
+ <span class="n">System</span><span class="o">.</span><span class="na">out</span><span class="o">.</span><span class="na">println</span><span class="o">(</span><span class="s">"Receive message[msgId="</span> <span class="o">+</span> <span class="n">message</span><span class="o">.</span><span class="na">getMsgId</span><span class="o">()</span> <span class="o">+</span> <span class="s">"] "</span>
+ <span class="o">+</span> <span class="o">(</span><span class="n">System</span><span class="o">.</span><span class="na">currentTimeMillis</span><span class="o">()</span> <span class="o">-</span> <span class="n">message</span><span class="o">.</span><span class="na">getStoreTimestamp</span><span class="o">())</span> <span class="o">+</span> <span class="s">"ms later"</span><span class="o">);</span>
+ <span class="o">}</span>
+ <span class="k">return</span> <span class="n">ConsumeConcurrentlyStatus</span><span class="o">.</span><span class="na">CONSUME_SUCCESS</span><span class="o">;</span>
+ <span class="o">}</span>
+ <span class="o">});</span>
+ <span class="c1">// Launch consumer</span>
+ <span class="n">consumer</span><span class="o">.</span><span class="na">start</span><span class="o">();</span>
+ <span class="o">}</span>
+ <span class="o">}</span>
</code></pre>
-</div>
+ </div>
+ </li>
+ <li>
+ <p>Send scheduled messages</p>
-<h4 id="have-fun-with-mqpullconsumerscheduleservice">Have fun with <code class="highlighter-rouge">MQPullConsumerScheduleService</code>.</h4>
+ <div class="language-java highlighter-rouge"><pre class="highlight"><code> <span class="kn">import</span> <span class="nn">org.apache.rocketmq.client.producer.DefaultMQProducer</span><span class="o">;</span>
+ <span class="kn">import</span> <span class="nn">org.apache.rocketmq.common.message.Message</span><span class="o">;</span>
+
+ <span class="kd">public</span> <span class="kd">class</span> <span class="nc">ScheduledMessageProducer</span> <span class="o">{</span>
+
+ <span class="kd">public</span> <span class="kd">static</span> <span class="kt">void</span> <span class="nf">main</span><span class="o">(</span><span class="n">String</span><span class="o">[]</span> <span class="n">args</span><span class="o">)</span> <span class="kd">throws</span> <span class="n">Exception</span> <span class="o">{</span>
+ <span class="c1">// Instantiate a producer to send scheduled messages</span>
+ <span class="n">DefaultMQProducer</span> <span class="n">producer</span> <span class="o">=</span> <span class="k">new</span> <span class="n">DefaultMQProducer</span><span class="o">(</span><span class="s">"ExampleProducerGroup"</span><span class="o">);</span>
+ <span class="c1">// Launch producer</span>
+ <span class="n">producer</span><span class="o">.</span><span class="na">start</span><span class="o">();</span>
+ <span class="kt">int</span> <span class="n">totalMessagesToSend</span> <span class="o">=</span> <span class="mi">100</span><span class="o">;</span>
+ <span class="k">for</span> <span class="o">(</span><span class="kt">int</span> <span class="n">i</span> <span class="o">=</span> <span class="mi">0</span><span class="o">;</span> <span class="n">i</span> <span class="o"><</span> <span class="n">totalMessagesToSend</span><span class="o">;</span> <span class="n">i</span><span class="o">++)</span> <span class="o">{</span>
+ <span class="n">Message</span> <span class="n">message</span> <span class="o">=</span> <span class="k">new</span> <span class="n">Message</span><span class="o">(</span><span class="s">"TestTopic"</span><span class="o">,</span> <span class="o">(</span><span class="s">"Hello scheduled message "</span> <span class="o">+</span> <span class="n">i</span><span class="o">).</span><span class="na">getBytes</span><span class="o">());</span>
+ <span class="c1">// This message will be delivered to consumer 10 seconds later.</span>
+ <span class="n">message</span><span class="o">.</span><span class="na">setDelayTimeLevel</span><span class="o">(</span><span class="mi">3</span><span class="o">);</span>
+ <span class="c1">// Send the message</span>
+ <span class="n">producer</span><span class="o">.</span><span class="na">send</span><span class="o">(</span><span class="n">message</span><span class="o">);</span>
+ <span class="o">}</span>
+
+ <span class="c1">// Shutdown producer after use.</span>
+ <span class="n">producer</span><span class="o">.</span><span class="na">shutdown</span><span class="o">();</span>
+ <span class="o">}</span>
+
+ <span class="o">}</span>
+</code></pre>
+ </div>
+ </li>
+ <li>
+ <p>Verification</p>
+ <p>You should see messages are consumed about 10 seconds later than their storing time.</p>
+ </li>
+</ol>
</section>
@@ -530,7 +542,7 @@ If you use <code class="highlighter-rouge">DefaultMQPullConsumer</code> to consu
- <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2017-04-25">April 25, 2017</time></p>
+ <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2017-04-24">April 24, 2017</time></p>
</footer>
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/blob/c6a0f07e/content/docs/simple-example/index.html
----------------------------------------------------------------------
diff --git a/content/docs/simple-example/index.html b/content/docs/simple-example/index.html
index 6809304..05f8d01 100644
--- a/content/docs/simple-example/index.html
+++ b/content/docs/simple-example/index.html
@@ -57,7 +57,7 @@
<meta property="og:type" content="article">
- <meta property="article:published_time" content="2017-06-06T21:20:18+08:00">
+ <meta property="article:published_time" content="2017-06-08T11:24:44+08:00">
@@ -429,8 +429,8 @@
<article class="page" itemscope itemtype="http://schema.org/CreativeWork">
<meta itemprop="headline" content="Simple Message Example">
<meta itemprop="description" content="How to send simple message to reduce pull in RocketMQ.">
- <meta itemprop="datePublished" content="June 06, 2017">
- <meta itemprop="dateModified" content="April 25, 2017">
+ <meta itemprop="datePublished" content="June 08, 2017">
+ <meta itemprop="dateModified" content="April 24, 2017">
<div class="page__inner-wrap">
@@ -569,7 +569,7 @@ such as log collection.</p>
- <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2017-04-25">April 25, 2017</time></p>
+ <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2017-04-24">April 24, 2017</time></p>
</footer>
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/blob/c6a0f07e/content/dowloading/releases/index.html
----------------------------------------------------------------------
diff --git a/content/dowloading/releases/index.html b/content/dowloading/releases/index.html
index 68562d9..498e8be 100644
--- a/content/dowloading/releases/index.html
+++ b/content/dowloading/releases/index.html
@@ -57,7 +57,7 @@
<meta property="og:type" content="article">
- <meta property="article:published_time" content="2017-06-06T21:20:18+08:00">
+ <meta property="article:published_time" content="2017-06-08T11:24:44+08:00">
@@ -429,8 +429,8 @@
<article class="page" itemscope itemtype="http://schema.org/CreativeWork">
<meta itemprop="headline" content="Downloading the Apache RocketMQ Releases">
<meta itemprop="description" content="Use the links below to download the Apache RocketMQ Releases, the latest release is 4.0.0-incubating.">
- <meta itemprop="datePublished" content="June 06, 2017">
- <meta itemprop="dateModified" content="February 21, 2017">
+ <meta itemprop="datePublished" content="June 08, 2017">
+ <meta itemprop="dateModified" content="February 20, 2017">
<div class="page__inner-wrap">
@@ -460,7 +460,7 @@
- <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2017-02-21">February 21, 2017</time></p>
+ <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2017-02-20">February 20, 2017</time></p>
</footer>
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/blob/c6a0f07e/content/feed.xml
----------------------------------------------------------------------
diff --git a/content/feed.xml b/content/feed.xml
index e17d0b8..de93222 100644
--- a/content/feed.xml
+++ b/content/feed.xml
@@ -1,4 +1,4 @@
-<?xml version="1.0" encoding="utf-8"?><?xml-stylesheet type="text/xml" href="/feed.xslt.xml"?><feed xmlns="http://www.w3.org/2005/Atom"><generator uri="http://jekyllrb.com" version="3.3.1">Jekyll</generator><link href="/feed.xml" rel="self" type="application/atom+xml" /><link href="/" rel="alternate" type="text/html" /><updated>2017-06-06T21:20:18+08:00</updated><id>//</id><title type="html">Apache RocketMQ</title><subtitle>The homepage of RocketMQ.</subtitle><author><name>{"name"=>nil, "avatar"=>"/assets/images/rmq-logo.png", "bio"=>"A fast, low latency, reliable, scalable, distributed MOM.", "location"=>"Hangzhou, China", "email"=>"dev@rocketmq.incubator.apache.org", "uri"=>"http://incubator.staging.apache.org/projects/rocketmq.html", "bitbucket"=>nil, "codepen"=>nil, "dribbble"=>nil, "flickr"=>nil, &quo
t;facebook"=>nil, "foursquare"=>nil, "github"=>"apache/incubator-rocketmq", "google_plus"=>nil, "keybase"=>nil, "instagram"=>nil, "lastfm"=>nil, "linkedin"=>nil, "pinterest"=>nil, "soundcloud"=>nil, "stackoverflow"=>"questions/tagged/rocketmq", "steam"=>nil, "tumblr"=>nil, "twitter"=>"ApacheRocketMQ", "vine"=>nil, "weibo"=>nil, "xing"=>nil, "youtube"=>nil, "quora"=>"topic/RocketMQ"}</name><email>dev@rocketmq.incubator.apache.org</email><uri>http://incubator.staging.apache.org/projects/rocketmq.html</uri></author><entry><title type="html">Release Notes - Apache RocketMQ - Version 4.1.0-incubating</title><link href="/release-notes-4.1.0-incubating/" rel="alternate" type="text/html" title="Release Notes - Apa
che RocketMQ - Version 4.1.0-incubating" /><published>2017-06-02T00:00:00+08:00</published><updated>2017-06-02T00:00:00+08:00</updated><id>/release-notes-4.1.0-incubating</id><content type="html" xml:base="/release-notes-4.1.0-incubating/"><p>Release Notes - Apache RocketMQ - Version 4.1.0-incubating</p>
+<?xml version="1.0" encoding="utf-8"?><feed xmlns="http://www.w3.org/2005/Atom" ><generator uri="https://jekyllrb.com/" version="3.4.3">Jekyll</generator><link href="/feed.xml" rel="self" type="application/atom+xml" /><link href="/" rel="alternate" type="text/html" /><updated>2017-06-08T11:24:44+08:00</updated><id>/</id><title type="html">Apache RocketMQ</title><subtitle>The homepage of RocketMQ.</subtitle><author><name>{"name"=>nil, "avatar"=>"/assets/images/rmq-logo.png", "bio"=>"A fast, low latency, reliable, scalable, distributed MOM.", "location"=>"Hangzhou, China", "email"=>"dev@rocketmq.incubator.apache.org", "uri"=>"http://incubator.staging.apache.org/projects/rocketmq.html", "bitbucket"=>nil, "codepen"=>nil, "dribbble"=>nil, "flickr"=>nil, "facebook"=>nil, "foursquare"=>n
il, "github"=>"apache/incubator-rocketmq", "google_plus"=>nil, "keybase"=>nil, "instagram"=>nil, "lastfm"=>nil, "linkedin"=>nil, "pinterest"=>nil, "soundcloud"=>nil, "stackoverflow"=>"questions/tagged/rocketmq", "steam"=>nil, "tumblr"=>nil, "twitter"=>"ApacheRocketMQ", "vine"=>nil, "weibo"=>nil, "xing"=>nil, "youtube"=>nil, "quora"=>"topic/RocketMQ"}</name><email>dev@rocketmq.incubator.apache.org</email><uri>http://incubator.staging.apache.org/projects/rocketmq.html</uri></author><entry><title type="html">Release Notes - Apache RocketMQ - Version 4.1.0-incubating</title><link href="/release-notes-4.1.0-incubating/" rel="alternate" type="text/html" title="Release Notes - Apache RocketMQ - Version 4.1.0-incubating" /><published>
2017-06-02T00:00:00+08:00</published><updated>2017-06-02T00:00:00+08:00</updated><id>/release-notes-4.1.0-incubating</id><content type="html" xml:base="/release-notes-4.1.0-incubating/"><p>Release Notes - Apache RocketMQ - Version 4.1.0-incubating</p>
<h2 id="new-feature">New Feature</h2>
@@ -226,8 +226,7 @@
<li>Join by Creating Pull Requests against <a href="https://github.com/apache/incubator-rocketmq-externals">RocketMQ MySQL Repository</a></li>
<li>Join by Creating Pull Requests against <a href="https://github.com/apache/incubator-rocketmq-externals">RocketMQ Redis Repository</a></li>
<li>Join by Creating Pull Requests against <a href="https://github.com/apache/incubator-rocketmq-externals">RocketMQ MongoDB Repository</a></li>
-</ol></content><author><name>{"name"=>nil, "avatar"=>"/assets/images/rmq-logo.png", "bio"=>"A fast, low latency, reliable, scalable, distributed MOM.", "location"=>"Hangzhou, China", "email"=>"dev@rocketmq.incubator.apache.org", "uri"=>"http://incubator.staging.apache.org/projects/rocketmq.html", "bitbucket"=>nil, "codepen"=>nil, "dribbble"=>nil, "flickr"=>nil, "facebook"=>nil, "foursquare"=>nil, "github"=>"apache/incubator-rocketmq", "google_plus"=>nil, "keybase"=>nil, "instagram"=>nil, "lastfm"=>nil, "linkedin"=>nil, "pinterest"=>nil, "soundcloud"=>nil, "stackoverflow"=>"questions/tagged/rocketmq", "steam"=>nil, "tumblr&
quot;=>nil, "twitter"=>"ApacheRocketMQ", "vine"=>nil, "weibo"=>nil, "xing"=>nil, "youtube"=>nil, "quora"=>"topic/RocketMQ"}</name><email>dev@rocketmq.incubator.apache.org</email><uri>http://incubator.staging.apache.org/projects/rocketmq.html</uri></author><category term="Activity" /><category term="Code" /><category term="Marathon" /><summary type="html">ROCKETMQ CODE MARATHON
-March 29th 2017</summary></entry><entry><title type="html">The Correct Posture Of Submitting Pull Request</title><link href="/the-correct-posture-of-submitting-pull-request/" rel="alternate" type="text/html" title="The Correct Posture Of Submitting Pull Request" /><published>2017-03-24T00:00:00+08:00</published><updated>2017-03-24T00:00:00+08:00</updated><id>/the-correct-posture-of-submitting-pull-request</id><content type="html" xml:base="/the-correct-posture-of-submitting-pull-request/"><h2 id="the-correct-posture-of-submitting-a-pr">The correct posture of submitting a PR</h2>
+</ol></content><author><name>{"name"=>nil, "avatar"=>"/assets/images/rmq-logo.png", "bio"=>"A fast, low latency, reliable, scalable, distributed MOM.", "location"=>"Hangzhou, China", "email"=>"dev@rocketmq.incubator.apache.org", "uri"=>"http://incubator.staging.apache.org/projects/rocketmq.html", "bitbucket"=>nil, "codepen"=>nil, "dribbble"=>nil, "flickr"=>nil, "facebook"=>nil, "foursquare"=>nil, "github"=>"apache/incubator-rocketmq", "google_plus"=>nil, "keybase"=>nil, "instagram"=>nil, "lastfm"=>nil, "linkedin"=>nil, "pinterest"=>nil, "soundcloud"=>nil, "stackoverflow"=>"questions/tagged/rocketmq", "steam"=>nil, "tumblr&
quot;=>nil, "twitter"=>"ApacheRocketMQ", "vine"=>nil, "weibo"=>nil, "xing"=>nil, "youtube"=>nil, "quora"=>"topic/RocketMQ"}</name><email>dev@rocketmq.incubator.apache.org</email><uri>http://incubator.staging.apache.org/projects/rocketmq.html</uri></author><category term="Activity" /><category term="Code" /><category term="Marathon" /><summary type="html">ROCKETMQ CODE MARATHON March 29th 2017</summary></entry><entry><title type="html">The Correct Posture Of Submitting Pull Request</title><link href="/the-correct-posture-of-submitting-pull-request/" rel="alternate" type="text/html" title="The Correct Posture Of Submitting Pull Request" /><published>2017-03-24T00:00:00+08:00</published><updated>2017-03-24T00:00:00+08:00</updated><id>/the-correct-posture-of-submitting-pull-request</id><content type="html" xml:base="/the-correct-posture-of-submitting-pull-request/"><h2 id="the-co
rrect-posture-of-submitting-a-pr">The correct posture of submitting a PR</h2>
<h3 id="prepare-the-repo">Prepare the repo</h3>
<ul>
@@ -384,8 +383,7 @@ assuming to query cluster info on the name server node.</p>
<p>Methods introduced first take precedence over the latter, namely, <br />
<code class="highlighter-rouge">Programmatic Way &gt; Java Options &gt; Environment Variable &gt; HTTP Endpoint</code></p>
</li>
-</ul></content><author><name>{"name"=>nil, "avatar"=>"/assets/images/rmq-logo.png", "bio"=>"A fast, low latency, reliable, scalable, distributed MOM.", "location"=>"Hangzhou, China", "email"=>"dev@rocketmq.incubator.apache.org", "uri"=>"http://incubator.staging.apache.org/projects/rocketmq.html", "bitbucket"=>nil, "codepen"=>nil, "dribbble"=>nil, "flickr"=>nil, "facebook"=>nil, "foursquare"=>nil, "github"=>"apache/incubator-rocketmq", "google_plus"=>nil, "keybase"=>nil, "instagram"=>nil, "lastfm"=>nil, "linkedin"=>nil, "pinterest"=>nil, "soundcloud"=>nil, "stackoverflow"=>"questions/tagged/rocketmq", "steam"=>nil, "tumblr&
quot;=>nil, "twitter"=>"ApacheRocketMQ", "vine"=>nil, "weibo"=>nil, "xing"=>nil, "youtube"=>nil, "quora"=>"topic/RocketMQ"}</name><email>dev@rocketmq.incubator.apache.org</email><uri>http://incubator.staging.apache.org/projects/rocketmq.html</uri></author><category term="RocketMQ" /><category term="Name Server" /><summary type="html">In Apache RocketMQ, name servers are designed to coordinate each component of the distributed system
-and fulfill much of this responsibility through managing topic route information.</summary></entry><entry><title type="html">Release Notes - Apache RocketMQ - Version 4.0.0-incubating</title><link href="/release_notes/release-notes-4.0.0-incubating/" rel="alternate" type="text/html" title="Release Notes - Apache RocketMQ - Version 4.0.0-incubating" /><published>2017-01-24T00:00:00+08:00</published><updated>2017-01-24T00:00:00+08:00</updated><id>/release_notes/release-notes-4.0.0-incubating</id><content type="html" xml:base="/release_notes/release-notes-4.0.0-incubating/"><p>Below is a summary of the JIRA issues addressed in the 4.0.0-incubating release of RocketMQ. For full documentation of the release, a guide to get started, please refer to <a href="/docs/quick-start/">Quick Start</a>.</p>
+</ul></content><author><name>{"name"=>nil, "avatar"=>"/assets/images/rmq-logo.png", "bio"=>"A fast, low latency, reliable, scalable, distributed MOM.", "location"=>"Hangzhou, China", "email"=>"dev@rocketmq.incubator.apache.org", "uri"=>"http://incubator.staging.apache.org/projects/rocketmq.html", "bitbucket"=>nil, "codepen"=>nil, "dribbble"=>nil, "flickr"=>nil, "facebook"=>nil, "foursquare"=>nil, "github"=>"apache/incubator-rocketmq", "google_plus"=>nil, "keybase"=>nil, "instagram"=>nil, "lastfm"=>nil, "linkedin"=>nil, "pinterest"=>nil, "soundcloud"=>nil, "stackoverflow"=>"questions/tagged/rocketmq", "steam"=>nil, "tumblr&
quot;=>nil, "twitter"=>"ApacheRocketMQ", "vine"=>nil, "weibo"=>nil, "xing"=>nil, "youtube"=>nil, "quora"=>"topic/RocketMQ"}</name><email>dev@rocketmq.incubator.apache.org</email><uri>http://incubator.staging.apache.org/projects/rocketmq.html</uri></author><category term="RocketMQ" /><category term="Name Server" /><summary type="html">In Apache RocketMQ, name servers are designed to coordinate each component of the distributed system and fulfill much of this responsibility through managing topic route information.</summary></entry><entry><title type="html">Release Notes - Apache RocketMQ - Version 4.0.0-incubating</title><link href="/release_notes/release-notes-4.0.0-incubating/" rel="alternate" type="text/html" title="Release Notes - Apache RocketMQ - Version 4.0.0-incubating" /><published>2017-01-24T00:00:00+08:00</published><updated>2017-01-24T00:00:00+08:00</updated><id>/release_n
otes/release-notes-4.0.0-incubating</id><content type="html" xml:base="/release_notes/release-notes-4.0.0-incubating/"><p>Below is a summary of the JIRA issues addressed in the 4.0.0-incubating release of RocketMQ. For full documentation of the release, a guide to get started, please refer to <a href="/docs/quick-start/">Quick Start</a>.</p>
<h2> Download the 4.0.0-incubating release
</h2>
@@ -576,8 +574,7 @@ and fulfill much of this responsibility through managing topic route information
<li>Supporting Latest <a href="http://flume.apache.org/">Flume</a></li>
<li>Rich Documentation and Good Test Cases Coverage</li>
<li>Join by Creating Pull Requests against <a href="https://github.com/apache/incubator-rocketmq-externals/tree/master/rocketmq-flume">RocketMQ Flume Repository</a></li>
-</ol></content><author><name>{"name"=>nil, "avatar"=>"/assets/images/rmq-logo.png", "bio"=>"A fast, low latency, reliable, scalable, distributed MOM.", "location"=>"Hangzhou, China", "email"=>"dev@rocketmq.incubator.apache.org", "uri"=>"http://incubator.staging.apache.org/projects/rocketmq.html", "bitbucket"=>nil, "codepen"=>nil, "dribbble"=>nil, "flickr"=>nil, "facebook"=>nil, "foursquare"=>nil, "github"=>"apache/incubator-rocketmq", "google_plus"=>nil, "keybase"=>nil, "instagram"=>nil, "lastfm"=>nil, "linkedin"=>nil, "pinterest"=>nil, "soundcloud"=>nil, "stackoverflow"=>"questions/tagged/rocketmq", "steam"=>nil, "tumblr&
quot;=>nil, "twitter"=>"ApacheRocketMQ", "vine"=>nil, "weibo"=>nil, "xing"=>nil, "youtube"=>nil, "quora"=>"topic/RocketMQ"}</name><email>dev@rocketmq.incubator.apache.org</email><uri>http://incubator.staging.apache.org/projects/rocketmq.html</uri></author><category term="Activity" /><category term="Code" /><category term="Marathon" /><summary type="html">ROCKETMQ CODE MARATHON
-January 5th 2017</summary></entry><entry><title type="html">Mastering Component Compatible Dependency</title><link href="/maven/mastering-component-compatible-dependency/" rel="alternate" type="text/html" title="Mastering Component Compatible Dependency" /><published>2016-12-23T00:00:00+08:00</published><updated>2016-12-23T00:00:00+08:00</updated><id>/maven/mastering-component-compatible-dependency</id><content type="html" xml:base="/maven/mastering-component-compatible-dependency/"><p>This article mainly includes three parts.at first,I will introduce compatibility principle(more details see <a href="http://blog.csdn.net/fengjia10/article/details/7799227">here</a>) briefly.followed by a detailed elaborating about Java component compatible dependency,including the interface-oriented programming,single component signature protection,single component compatibility protection and multi-component compatibility compile time checking.Finally is the review and pr
ospect,especially about <strong>Dependency Mediator</strong> project.</p>
+</ol></content><author><name>{"name"=>nil, "avatar"=>"/assets/images/rmq-logo.png", "bio"=>"A fast, low latency, reliable, scalable, distributed MOM.", "location"=>"Hangzhou, China", "email"=>"dev@rocketmq.incubator.apache.org", "uri"=>"http://incubator.staging.apache.org/projects/rocketmq.html", "bitbucket"=>nil, "codepen"=>nil, "dribbble"=>nil, "flickr"=>nil, "facebook"=>nil, "foursquare"=>nil, "github"=>"apache/incubator-rocketmq", "google_plus"=>nil, "keybase"=>nil, "instagram"=>nil, "lastfm"=>nil, "linkedin"=>nil, "pinterest"=>nil, "soundcloud"=>nil, "stackoverflow"=>"questions/tagged/rocketmq", "steam"=>nil, "tumblr&
quot;=>nil, "twitter"=>"ApacheRocketMQ", "vine"=>nil, "weibo"=>nil, "xing"=>nil, "youtube"=>nil, "quora"=>"topic/RocketMQ"}</name><email>dev@rocketmq.incubator.apache.org</email><uri>http://incubator.staging.apache.org/projects/rocketmq.html</uri></author><category term="Activity" /><category term="Code" /><category term="Marathon" /><summary type="html">ROCKETMQ CODE MARATHON January 5th 2017</summary></entry><entry><title type="html">Mastering Component Compatible Dependency</title><link href="/maven/mastering-component-compatible-dependency/" rel="alternate" type="text/html" title="Mastering Component Compatible Dependency" /><published>2016-12-23T00:00:00+08:00</published><updated>2016-12-23T00:00:00+08:00</updated><id>/maven/mastering-component-compatible-dependency</id><content type="html" xml:base="/maven/mastering-component-compatible-dependency/"><p>This article mainly
includes three parts.at first,I will introduce compatibility principle(more details see <a href="http://blog.csdn.net/fengjia10/article/details/7799227">here</a>) briefly.followed by a detailed elaborating about Java component compatible dependency,including the interface-oriented programming,single component signature protection,single component compatibility protection and multi-component compatibility compile time checking.Finally is the review and prospect,especially about <strong>Dependency Mediator</strong> project.</p>
<aside class="sidebar__right">
<nav class="toc">
@@ -931,4 +928,4 @@ setting checkJars to true or nothing to do with this property,it will further an
</li>
<li>Given ConsumeQueue stores fixed-size metadata only, which is mainly used to record consuming progress, random read is well supported. Taking advantage of page cache prefetch, accessing ConsumeQueue is as efficiently fast as accessing main memory, even if it’s in the case of massive message accumulation. As a result，ConsumeQueue will NOT bring in noticeable penalty to the read performance.</li>
<li>CommitLog stores virtually all information, including the message data. Similar to redo log of relational database, consume queues, message key indexes and all other required data can be completely recovered as long as commit log exists..</li>
-</ol></content><author><name>{"name"=>nil, "avatar"=>"/assets/images/rmq-logo.png", "bio"=>"A fast, low latency, reliable, scalable, distributed MOM.", "location"=>"Hangzhou, China", "email"=>"dev@rocketmq.incubator.apache.org", "uri"=>"http://incubator.staging.apache.org/projects/rocketmq.html", "bitbucket"=>nil, "codepen"=>nil, "dribbble"=>nil, "flickr"=>nil, "facebook"=>nil, "foursquare"=>nil, "github"=>"apache/incubator-rocketmq", "google_plus"=>nil, "keybase"=>nil, "instagram"=>nil, "lastfm"=>nil, "linkedin"=>nil, "pinterest"=>nil, "soundcloud"=>nil, "stackoverflow"=>"questions/tagged/rocketmq", "steam"=>nil, "tumblr&
quot;=>nil, "twitter"=>"ApacheRocketMQ", "vine"=>nil, "weibo"=>nil, "xing"=>nil, "youtube"=>nil, "quora"=>"topic/RocketMQ"}</name><email>dev@rocketmq.incubator.apache.org</email><uri>http://incubator.staging.apache.org/projects/rocketmq.html</uri></author><category term="RocketMQ" /><category term="Queue" /><category term="Partition" /><category term="Message Oriented Middleware" /><summary type="html">Summary</summary></entry></feed>
+</ol></content><author><name>{"name"=>nil, "avatar"=>"/assets/images/rmq-logo.png", "bio"=>"A fast, low latency, reliable, scalable, distributed MOM.", "location"=>"Hangzhou, China", "email"=>"dev@rocketmq.incubator.apache.org", "uri"=>"http://incubator.staging.apache.org/projects/rocketmq.html", "bitbucket"=>nil, "codepen"=>nil, "dribbble"=>nil, "flickr"=>nil, "facebook"=>nil, "foursquare"=>nil, "github"=>"apache/incubator-rocketmq", "google_plus"=>nil, "keybase"=>nil, "instagram"=>nil, "lastfm"=>nil, "linkedin"=>nil, "pinterest"=>nil, "soundcloud"=>nil, "stackoverflow"=>"questions/tagged/rocketmq", "steam"=>nil, "tumblr&
quot;=>nil, "twitter"=>"ApacheRocketMQ", "vine"=>nil, "weibo"=>nil, "xing"=>nil, "youtube"=>nil, "quora"=>"topic/RocketMQ"}</name><email>dev@rocketmq.incubator.apache.org</email><uri>http://incubator.staging.apache.org/projects/rocketmq.html</uri></author><category term="RocketMQ" /><category term="Queue" /><category term="Partition" /><category term="Message Oriented Middleware" /><summary type="html">Summary</summary></entry></feed>
\ No newline at end of file
[4/7] incubator-rocketmq-site git commit: Fix indent
Posted by li...@apache.org.
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 <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
[5/7] incubator-rocketmq-site git commit: Merge branch 'master' into
asf-site to fix ident issue
Posted by li...@apache.org.
Merge branch 'master' into asf-site to fix ident issue
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/62d32861
Tree: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/tree/62d32861
Diff: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/diff/62d32861
Branch: refs/heads/asf-site
Commit: 62d3286145729c8949f54cba8ad5e92ebfba7187
Parents: 27e696d 899327e
Author: Li Zhanhui <li...@gmail.com>
Authored: Thu Jun 8 11:23:30 2017 +0800
Committer: Li Zhanhui <li...@gmail.com>
Committed: Thu Jun 8 11:23:30 2017 +0800
----------------------------------------------------------------------
_docs/17-rmq-schedule-example.md | 116 +++++++++++++++++-----------------
1 file changed, 58 insertions(+), 58 deletions(-)
----------------------------------------------------------------------
[3/7] incubator-rocketmq-site git commit: Merge remote-tracking
branch 'origin/master' into asf-site
Posted by li...@apache.org.
Merge remote-tracking branch 'origin/master' into asf-site
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/27e696dc
Tree: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/tree/27e696dc
Diff: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/diff/27e696dc
Branch: refs/heads/asf-site
Commit: 27e696dc23ec176f115911c679efadc2b82b4f69
Parents: 94c21bb 10f8abe
Author: Li Zhanhui <li...@gmail.com>
Authored: Thu Jun 8 11:06:36 2017 +0800
Committer: Li Zhanhui <li...@gmail.com>
Committed: Thu Jun 8 11:06:36 2017 +0800
----------------------------------------------------------------------
.gitignore | 1 +
_docs/17-rmq-schedule-example.md | 103 +++++++++++++++++++---------------
2 files changed, 60 insertions(+), 44 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/blob/27e696dc/.gitignore
----------------------------------------------------------------------