You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by hu...@apache.org on 2019/08/13 13:00:49 UTC
[rocketmq-site] branch asf-site updated (625b664 -> e1c5b55)
This is an automated email from the ASF dual-hosted git repository.
huzongtang pushed a change to branch asf-site
in repository https://gitbox.apache.org/repos/asf/rocketmq-site.git.
from 625b664 Update asf site
add e901ec9 adjust home.md page for release 4.5.2 version
new 47eb23c Merge remote-tracking branch 'origin/master' into asf-site
new e1c5b55 adjust home content for release 4.5.2 version
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
content/about/contact/index.html | 6 +-
content/about/rewards/index.html | 6 +-
content/about/team/index.html | 2 +-
content/archive-layout-with-content/index.html | 2 +-
content/docs/batch-example/index.html | 46 +++++------
content/docs/best-practice-broker/index.html | 6 +-
content/docs/best-practice-consumer/index.html | 6 +-
content/docs/best-practice-namesvr/index.html | 12 +--
content/docs/best-practice-producer/index.html | 6 +-
content/docs/broadcast-example/index.html | 38 ++++-----
content/docs/cli-admin-tool/index.html | 6 +-
content/docs/cluster-deployment/index.html | 6 +-
content/docs/code-guidelines/index.html | 6 +-
content/docs/core-concept/index.html | 6 +-
content/docs/create-pull-request/index.html | 6 +-
content/docs/documentation/index.html | 6 +-
content/docs/faq/index.html | 6 +-
content/docs/filter-by-sql92-example/index.html | 28 +++----
content/docs/how-to-contribute/index.html | 6 +-
content/docs/logappender-example/index.html | 6 +-
content/docs/motivation/index.html | 6 +-
content/docs/openmessaging-example/index.html | 74 ++++++++---------
content/docs/order-example/index.html | 52 ++++++------
content/docs/pull-request/index.html | 6 +-
content/docs/quick-start/index.html | 6 +-
content/docs/release-manual.html | 8 +-
content/docs/rmq-arc/index.html | 6 +-
content/docs/rmq-deployment/index.html | 92 +++++++++++-----------
content/docs/roadmap/index.html | 6 +-
content/docs/schedule-example/index.html | 28 +++----
content/docs/simple-example/index.html | 62 +++++++--------
content/docs/system-config/index.html | 6 +-
content/docs/transaction-example/index.html | 6 +-
content/dowloading/releases/index.html | 6 +-
content/feed.xml | 2 +-
content/index.html | 10 +--
.../index.html | 60 +++++++-------
content/sitemap.xml | 70 ++++++++--------
home.md | 2 +-
39 files changed, 360 insertions(+), 360 deletions(-)
[rocketmq-site] 02/02: adjust home content for release 4.5.2 version
Posted by hu...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
huzongtang pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/rocketmq-site.git
commit e1c5b55ad3aacde5277aa891c87a7d70c1e991ca
Author: zongtanghu <zo...@gmail.com>
AuthorDate: Tue Aug 13 20:59:50 2019 +0800
adjust home content for release 4.5.2 version
---
content/about/contact/index.html | 6 +-
content/about/rewards/index.html | 6 +-
content/about/team/index.html | 2 +-
content/archive-layout-with-content/index.html | 2 +-
content/docs/batch-example/index.html | 46 +++++------
content/docs/best-practice-broker/index.html | 6 +-
content/docs/best-practice-consumer/index.html | 6 +-
content/docs/best-practice-namesvr/index.html | 12 +--
content/docs/best-practice-producer/index.html | 6 +-
content/docs/broadcast-example/index.html | 38 ++++-----
content/docs/cli-admin-tool/index.html | 6 +-
content/docs/cluster-deployment/index.html | 6 +-
content/docs/code-guidelines/index.html | 6 +-
content/docs/core-concept/index.html | 6 +-
content/docs/create-pull-request/index.html | 6 +-
content/docs/documentation/index.html | 6 +-
content/docs/faq/index.html | 6 +-
content/docs/filter-by-sql92-example/index.html | 28 +++----
content/docs/how-to-contribute/index.html | 6 +-
content/docs/logappender-example/index.html | 6 +-
content/docs/motivation/index.html | 6 +-
content/docs/openmessaging-example/index.html | 74 ++++++++---------
content/docs/order-example/index.html | 52 ++++++------
content/docs/pull-request/index.html | 6 +-
content/docs/quick-start/index.html | 6 +-
content/docs/release-manual.html | 8 +-
content/docs/rmq-arc/index.html | 6 +-
content/docs/rmq-deployment/index.html | 92 +++++++++++-----------
content/docs/roadmap/index.html | 6 +-
content/docs/schedule-example/index.html | 28 +++----
content/docs/simple-example/index.html | 62 +++++++--------
content/docs/system-config/index.html | 6 +-
content/docs/transaction-example/index.html | 6 +-
content/dowloading/releases/index.html | 6 +-
content/feed.xml | 2 +-
content/index.html | 10 +--
.../index.html | 60 +++++++-------
content/sitemap.xml | 70 ++++++++--------
38 files changed, 359 insertions(+), 359 deletions(-)
diff --git a/content/about/contact/index.html b/content/about/contact/index.html
index 60b73f5..230c28e 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="2019-08-05T10:42:32+08:00">
+ <meta property="article:published_time" content="2019-08-13T20:57:29+08:00">
@@ -213,7 +213,7 @@
<meta itemprop="headline" content="CONTACT">
<meta itemprop="description" content="Contact.">
- <meta itemprop="dateModified" content="December 29, 2016">
+ <meta itemprop="dateModified" content="December 28, 2016">
<div class="page__inner-wrap">
@@ -299,7 +299,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>
diff --git a/content/about/rewards/index.html b/content/about/rewards/index.html
index 7d489a7..ac2c5d7 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="2019-08-05T10:42:32+08:00">
+ <meta property="article:published_time" content="2019-08-13T20:57:29+08:00">
@@ -213,7 +213,7 @@
<meta itemprop="headline" content="REWARDS">
<meta itemprop="description" content="Rewards.">
- <meta itemprop="dateModified" content="January 24, 2019">
+ <meta itemprop="dateModified" content="January 23, 2019">
<div class="page__inner-wrap">
@@ -246,7 +246,7 @@
- <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2019-01-24">January 24, 2019</time></p>
+ <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2019-01-23">January 23, 2019</time></p>
</footer>
diff --git a/content/about/team/index.html b/content/about/team/index.html
index 0c9d606..bd5970e 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="2019-08-05T10:42:32+08:00">
+ <meta property="article:published_time" content="2019-08-13T20:57:29+08:00">
diff --git a/content/archive-layout-with-content/index.html b/content/archive-layout-with-content/index.html
index 7ec0480..dbf977b 100644
--- a/content/archive-layout-with-content/index.html
+++ b/content/archive-layout-with-content/index.html
@@ -1098,7 +1098,7 @@
</h2>
- <p class="archive__item-excerpt" itemprop="description">Apache RocketMQ™ is an open source distributed messaging and streaming data platform. Latest release v4.5.1
+ <p class="archive__item-excerpt" itemprop="description">Apache RocketMQ™ is an open source distributed messaging and streaming data platform. Latest release v4.5.2
</p>
</article>
</div>
diff --git a/content/docs/batch-example/index.html b/content/docs/batch-example/index.html
index 30639b9..17ce68e 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="2019-08-05T10:42:32+08:00">
+ <meta property="article:published_time" content="2019-08-13T20:57:29+08:00">
@@ -459,7 +459,7 @@
<meta itemprop="headline" content="Batch Example">
<meta itemprop="description" content="How to use batch in Rocketmq">
- <meta itemprop="dateModified" content="April 25, 2017">
+ <meta itemprop="dateModified" content="April 24, 2017">
<div class="page__inner-wrap">
@@ -495,14 +495,14 @@
<h4 id="how-to-use-batch">How to use batch</h4>
<p>If you just send messages of no more than 1MiB at a time, it is easy to use batch:</p>
-<div class="language-java highlighter-rouge"><div class="highlight"><pre class="highlight"><code><span class="n">String</span> <span class="n">topic</span> <span class="o">=</span> <span class="s">"BatchTest"</span><span class="o">;</span>
-<span class="n">List</span><span class="o"><</span><span class="n">Message</span><span class="o">></span> <span class="n">messages</span> <span class="o">=</span> <span class="k">new</span> <span class="n">ArrayList</span><span class="o"><>();</span>
-<span class="n">messages</span><span class="o">.</span><span class="na">add</span><span class="o">(</span><span class="k">new</span> <span class="n">Message</span><span class="o">(</span><span class="n">topic</span><span class="o">,</span> <span class="s">"TagA"</span><span class="o">,</span> <span class="s">"OrderID001"</span><span class="o">,</span> <span class="s">"Hello world 0"</span><span class="o">.</span><span class="na">getBytes</span><span class="o">()));</span>
-<span class="n">messages</span><span class="o">.</span><span class="na">add</span><span class="o">(</span><span class="k">new</span> <span class="n">Message</span><span class="o">(</span><span class="n">topic</span><span class="o">,</span> <span class="s">"TagA"</span><span class="o">,</span> <span class="s">"OrderID002"</span><span class="o">,</span> <span class="s">"Hello world 1"</span><span class="o">.</span><span class="na">getBytes</span><span class="o">()));</span>
-<span class="n">messages</span><span class="o">.</span><span class="na">add</span><span class="o">(</span><span class="k">new</span> <span class="n">Message</span><span class="o">(</span><span class="n">topic</span><span class="o">,</span> <span class="s">"TagA"</span><span class="o">,</span> <span class="s">"OrderID003"</span><span class="o">,</span> <span class="s">"Hello world 2"</span><span class="o">.</span><span class="na">getBytes</span><span class="o">()));</span>
+<div class="language-java highlighter-rouge"><div class="highlight"><pre class="highlight"><code><span class="nc">String</span> <span class="n">topic</span> <span class="o">=</span> <span class="s">"BatchTest"</span><span class="o">;</span>
+<span class="nc">List</span><span class="o"><</span><span class="nc">Message</span><span class="o">></span> <span class="n">messages</span> <span class="o">=</span> <span class="k">new</span> <span class="nc">ArrayList</span><span class="o"><>();</span>
+<span class="n">messages</span><span class="o">.</span><span class="na">add</span><span class="o">(</span><span class="k">new</span> <span class="nc">Message</span><span class="o">(</span><span class="n">topic</span><span class="o">,</span> <span class="s">"TagA"</span><span class="o">,</span> <span class="s">"OrderID001"</span><span class="o">,</span> <span class="s">"Hello world 0"</span><span class="o">.</span><span class="na">getBytes</span><span class="o">()));</span>
+<span class="n">messages</span><span class="o">.</span><span class="na">add</span><span class="o">(</span><span class="k">new</span> <span class="nc">Message</span><span class="o">(</span><span class="n">topic</span><span class="o">,</span> <span class="s">"TagA"</span><span class="o">,</span> <span class="s">"OrderID002"</span><span class="o">,</span> <span class="s">"Hello world 1"</span><span class="o">.</span><span class="na">getBytes</span><span class="o">()));</span>
+<span class="n">messages</span><span class="o">.</span><span class="na">add</span><span class="o">(</span><span class="k">new</span> <span class="nc">Message</span><span class="o">(</span><span class="n">topic</span><span class="o">,</span> <span class="s">"TagA"</span><span class="o">,</span> <span class="s">"OrderID003"</span><span class="o">,</span> <span class="s">"Hello world 2"</span><span class="o">.</span><span class="na">getBytes</span><span class="o">()));</span>
<span class="k">try</span> <span class="o">{</span>
<span class="n">producer</span><span class="o">.</span><span class="na">send</span><span class="o">(</span><span class="n">messages</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="o">}</span> <span class="k">catch</span> <span class="o">(</span><span class="nc">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="c1">//handle the error</span>
<span class="o">}</span>
@@ -513,28 +513,28 @@
<p>At this time, you’d better split the lists:</p>
-<div class="language-java highlighter-rouge"><div class="highlight"><pre class="highlight"><code><span class="kd">public</span> <span class="kd">class</span> <span class="nc">ListSplitter</span> <span class="kd">implements</span> <span class="n">Iterator</span><span class="o"><</span><span class="n">List</span><span class="o"><</span><span class="n">Message</span><span class="o">>></span> <span class="o">{</span>
- <span class="kd">private</span> <span class="kd">final</span> <span class="kt">int</span> <span class="n">SIZE_LIMIT</span> <span class="o">=</span> <span class="mi">1000</span> <span class="o">*</span> <span class="mi">1000</span><span class="o">;</span>
- <span class="kd">private</span> <span class="kd">final</span> <span class="n">List</span><span class="o"><</span><span class="n">Message</span><span class="o">></span> <span class="n">messages</span><span class="o">;</span>
+<div class="language-java highlighter-rouge"><div class="highlight"><pre class="highlight"><code><span class="kd">public</span> <span class="kd">class</span> <span class="nc">ListSplitter</span> <span class="kd">implements</span> <span class="nc">Iterator</span><span class="o"><</span><span class="nc">List</span><span class="o"><</span><span class="nc">Message</span><span class="o">>></span> <span class="o">{</span>
+ <span class="kd">private</span> <span class="kd">final</span> <span class="kt">int</span> <span class="no">SIZE_LIMIT</span> <span class="o">=</span> <span class="mi">1000</span> <span class="o">*</span> <span class="mi">1000</span><span class="o">;</span>
+ <span class="kd">private</span> <span class="kd">final</span> <span class="nc">List</span><span class="o"><</span><span class="nc">Message</span><span class="o">></span> <span class="n">messages</span><span class="o">;</span>
<span class="kd">private</span> <span class="kt">int</span> <span class="n">currIndex</span><span class="o">;</span>
- <span class="kd">public</span> <span class="nf">ListSplitter</span><span class="o">(</span><span class="n">List</span><span class="o"><</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="kd">public</span> <span class="nf">ListSplitter</span><span class="o">(</span><span class="nc">List</span><span class="o"><</span><span class="nc">Message</span><span class="o">></span> <span class="n">messages</span><span class="o">)</span> <span class="o">{</span>
<span class="k">this</span><span class="o">.</span><span class="na">messages</span> <span class="o">=</span> <span class="n">messages</span><span class="o">;</span>
<span class="o">}</span>
<span class="nd">@Override</span> <span class="kd">public</span> <span class="kt">boolean</span> <span class="nf">hasNext</span><span class="o">()</span> <span class="o">{</span>
<span class="k">return</span> <span class="n">currIndex</span> <span class="o"><</span> <span class="n">messages</span><span class="o">.</span><span class="na">size</span><span class="o">();</span>
<span class="o">}</span>
- <span class="nd">@Override</span> <span class="kd">public</span> <span class="n">List</span><span class="o"><</span><span class="n">Message</span><span class="o">></span> <span class="nf">next</span><span class="o">()</span> <span class="o">{</span>
+ <span class="nd">@Override</span> <span class="kd">public</span> <span class="nc">List</span><span class="o"><</span><span class="nc">Message</span><span class="o">></span> <span class="nf">next</span><span class="o">()</span> <span class="o">{</span>
<span class="kt">int</span> <span class="n">nextIndex</span> <span class="o">=</span> <span class="n">currIndex</span><span class="o">;</span>
<span class="kt">int</span> <span class="n">totalSize</span> <span class="o">=</span> <span class="mi">0</span><span class="o">;</span>
<span class="k">for</span> <span class="o">(;</span> <span class="n">nextIndex</span> <span class="o"><</span> <span class="n">messages</span><span class="o">.</span><span class="na">size</span><span class="o">();</span> <span class="n">nextIndex</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="n">messages</span><span class="o">.</span><span class="na">get</span><span class="o">(</span><span class="n">nextIndex</span><span class="o">);</span>
+ <span class="nc">Message</span> <span class="n">message</span> <span class="o">=</span> <span class="n">messages</span><span class="o">.</span><span class="na">get</span><span class="o">(</span><span class="n">nextIndex</span><span class="o">);</span>
<span class="kt">int</span> <span class="n">tmpSize</span> <span class="o">=</span> <span class="n">message</span><span class="o">.</span><span class="na">getTopic</span><span class="o">().</span><span class="na">length</span><span class="o">()</span> <span class="o">+</span> <span class="n">message</span><span class="o">.</span><span class="na">getBody</span><span class="o">().</span><span class="na">length</span><span class="o">;</span>
- <span class="n">Map</span><span class="o"><</span><span class="n">String</span><span class="o">,</span> <span class="n">String</span><span class="o">></span> <span class="n">properties</span> <span class="o">=</span> <span class="n">message</span><span class="o">.</span><span class="na">getProperties</span><span class="o">();</span>
- <span class="k">for</span> <span class="o">(</span><span class="n">Map</span><span class="o">.</span><span class="na">Entry</span><span class="o"><</span><span class="n">String</span><span class="o">,</span> <span class="n">String</span><span class="o">></span> <span class="n">entry</span> <span class="o">:</span> <span class="n">properties</span><span class="o">.</span><span class="na">entrySet</span><span class="o">())</span> <span class="o">{</span>
+ <span class="nc">Map</span><span class="o"><</span><span class="nc">String</span><span class="o">,</span> <span class="nc">String</span><span class="o">></span> <span class="n">properties</span> <span class="o">=</span> <span class="n">message</span><span class="o">.</span><span class="na">getProperties</span><span class="o">();</span>
+ <span class="k">for</span> <span class="o">(</span><span class="nc">Map</span><span class="o">.</span><span class="na">Entry</span><span class="o"><</span><span class="nc">String</span><span class="o">,</span> <span class="nc">String</span><span class="o">></span> <span class="n">entry</span> <span class="o">:</span> <span class="n">properties</span><span class="o">.</span><span class="na">entrySet</span><span class="o">())</span> <span class="o">{</span>
<span class="n">tmpSize</span> <span class="o">+=</span> <span class="n">entry</span><span class="o">.</span><span class="na">getKey</span><span class="o">().</span><span class="na">length</span><span class="o">()</span> <span class="o">+</span> <span class="n">entry</span><span class="o">.</span><span class="na">getValue</span><span class="o">().</span><span class="na">length</span><span class="o">();</span>
<span class="o">}</span>
<span class="n">tmpSize</span> <span class="o">=</span> <span class="n">tmpSize</span> <span class="o">+</span> <span class="mi">20</span><span class="o">;</span> <span class="c1">//for log overhead</span>
- <span class="k">if</span> <span class="o">(</span><span class="n">tmpSize</span> <span class="o">></span> <span class="n">SIZE_LIMIT</span><span class="o">)</span> <span class="o">{</span>
+ <span class="k">if</span> <span class="o">(</span><span class="n">tmpSize</span> <span class="o">></span> <span class="no">SIZE_LIMIT</span><span class="o">)</span> <span class="o">{</span>
<span class="c1">//it is unexpected that single message exceeds the SIZE_LIMIT</span>
<span class="c1">//here just let it go, otherwise it will block the splitting process</span>
<span class="k">if</span> <span class="o">(</span><span class="n">nextIndex</span> <span class="o">-</span> <span class="n">currIndex</span> <span class="o">==</span> <span class="mi">0</span><span class="o">)</span> <span class="o">{</span>
@@ -543,25 +543,25 @@
<span class="o">}</span>
<span class="k">break</span><span class="o">;</span>
<span class="o">}</span>
- <span class="k">if</span> <span class="o">(</span><span class="n">tmpSize</span> <span class="o">+</span> <span class="n">totalSize</span> <span class="o">></span> <span class="n">SIZE_LIMIT</span><span class="o">)</span> <span class="o">{</span>
+ <span class="k">if</span> <span class="o">(</span><span class="n">tmpSize</span> <span class="o">+</span> <span class="n">totalSize</span> <span class="o">></span> <span class="no">SIZE_LIMIT</span><span class="o">)</span> <span class="o">{</span>
<span class="k">break</span><span class="o">;</span>
<span class="o">}</span> <span class="k">else</span> <span class="o">{</span>
<span class="n">totalSize</span> <span class="o">+=</span> <span class="n">tmpSize</span><span class="o">;</span>
<span class="o">}</span>
<span class="o">}</span>
- <span class="n">List</span><span class="o"><</span><span class="n">Message</span><span class="o">></span> <span class="n">subList</span> <span class="o">=</span> <span class="n">messages</span><span class="o">.</span><span class="na">subList</span><span class="o">(</span><span class="n">currIndex</span><span class="o">,</span> <span class="n">nextIndex</span><span class="o">);</span>
+ <span class="nc">List</span><span class="o"><</span><span class="nc">Message</span><span class="o">></span> <span class="n">subList</span> <span class="o">=</span> <span class="n">messages</span><span class="o">.</span><span class="na">subList</span><span class="o">(</span><span class="n">currIndex</span><span class="o">,</span> <span class="n">nextIndex</span><span class="o">);</span>
<span class="n">currIndex</span> <span class="o">=</span> <span class="n">nextIndex</span><span class="o">;</span>
<span class="k">return</span> <span class="n">subList</span><span class="o">;</span>
<span class="o">}</span>
<span class="o">}</span>
<span class="c1">//then you could split the large list into small ones:</span>
-<span class="n">ListSplitter</span> <span class="n">splitter</span> <span class="o">=</span> <span class="k">new</span> <span class="n">ListSplitter</span><span class="o">(</span><span class="n">messages</span><span class="o">);</span>
+<span class="nc">ListSplitter</span> <span class="n">splitter</span> <span class="o">=</span> <span class="k">new</span> <span class="nc">ListSplitter</span><span class="o">(</span><span class="n">messages</span><span class="o">);</span>
<span class="k">while</span> <span class="o">(</span><span class="n">splitter</span><span class="o">.</span><span class="na">hasNext</span><span class="o">())</span> <span class="o">{</span>
<span class="k">try</span> <span class="o">{</span>
- <span class="n">List</span><span class="o"><</span><span class="n">Message</span><span class="o">></span> <span class="n">listItem</span> <span class="o">=</span> <span class="n">splitter</span><span class="o">.</span><span class="na">next</span><span class="o">();</span>
+ <span class="nc">List</span><span class="o"><</span><span class="nc">Message</span><span class="o">></span> <span class="n">listItem</span> <span class="o">=</span> <span class="n">splitter</span><span class="o">.</span><span class="na">next</span><span class="o">();</span>
<span class="n">producer</span><span class="o">.</span><span class="na">send</span><span class="o">(</span><span class="n">listItem</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="o">}</span> <span class="k">catch</span> <span class="o">(</span><span class="nc">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="c1">//handle the error</span>
<span class="o">}</span>
@@ -577,7 +577,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>
diff --git a/content/docs/best-practice-broker/index.html b/content/docs/best-practice-broker/index.html
index 0e744d3..d61d707 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="2019-08-05T10:42:32+08:00">
+ <meta property="article:published_time" content="2019-08-13T20:57:29+08:00">
@@ -459,7 +459,7 @@
<meta itemprop="headline" content="Best Practice For Broker">
<meta itemprop="description" content="Some useful tips for users.">
- <meta itemprop="dateModified" content="December 25, 2016">
+ <meta itemprop="dateModified" content="December 24, 2016">
<div class="page__inner-wrap">
@@ -508,7 +508,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>
diff --git a/content/docs/best-practice-consumer/index.html b/content/docs/best-practice-consumer/index.html
index b34e13f..ab19646 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="2019-08-05T10:42:32+08:00">
+ <meta property="article:published_time" content="2019-08-13T20:57:29+08:00">
@@ -459,7 +459,7 @@
<meta itemprop="headline" content="Best Practice For Consumer">
<meta itemprop="description" content="Some useful tips for users.">
- <meta itemprop="dateModified" content="December 25, 2016">
+ <meta itemprop="dateModified" content="December 24, 2016">
<div class="page__inner-wrap">
@@ -533,7 +533,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>
diff --git a/content/docs/best-practice-namesvr/index.html b/content/docs/best-practice-namesvr/index.html
index 12af3a2..97a6e37 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="2019-08-05T10:42:32+08:00">
+ <meta property="article:published_time" content="2019-08-13T20:57:29+08:00">
@@ -459,7 +459,7 @@
<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 the coordination is mainly achieved through managing topic routing information.">
- <meta itemprop="dateModified" content="December 25, 2016">
+ <meta itemprop="dateModified" content="December 24, 2016">
<div class="page__inner-wrap">
@@ -503,10 +503,10 @@ In Apache RocketMQ, this can be done in four ways.</p>
<p>For producers and consumers, we can feed name server address list to them as follows:</p>
-<div class="language-java highlighter-rouge"><div class="highlight"><pre class="highlight"><code><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">"please_rename_unique_group_name"</span><span class="o">);</span>
+<div class="language-java highlighter-rouge"><div class="highlight"><pre class="highlight"><code><span class="nc">DefaultMQProducer</span> <span class="n">producer</span> <span class="o">=</span> <span class="k">new</span> <span class="nc">DefaultMQProducer</span><span class="o">(</span><span class="s">"please_rename_unique_group_name"</span><span class="o">);</span>
<span class="n">producer</span><span class="o">.</span><span class="na">setNamesrvAddr</span><span class="o">(</span><span class="s">"name-server1-ip:port;name-server2-ip:port"</span><span class="o">);</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">"please_rename_unique_group_name"</span><span class="o">);</span>
+<span class="nc">DefaultMQPushConsumer</span> <span class="n">consumer</span> <span class="o">=</span> <span class="k">new</span> <span class="nc">DefaultMQPushConsumer</span><span class="o">(</span><span class="s">"please_rename_unique_group_name"</span><span class="o">);</span>
<span class="n">consumer</span><span class="o">.</span><span class="na">setNamesrvAddr</span><span class="o">(</span><span class="s">"name-server1-ip:port;name-server2-ip:port"</span><span class="o">);</span>
</code></pre></div></div>
@@ -521,7 +521,7 @@ assuming to query cluster info on the name server node.</p>
<p>If you have integrated admin tool into your own dashboard, you can:</p>
-<div class="language-java highlighter-rouge"><div class="highlight"><pre class="highlight"><code><span class="n">DefaultMQAdminExt</span> <span class="n">defaultMQAdminExt</span> <span class="o">=</span> <span class="k">new</span> <span class="n">DefaultMQAdminExt</span><span class="o">(</span><span class="s">"please_rename_unique_group_name"</span><span class="o">);</span>
+<div class="language-java highlighter-rouge"><div class="highlight"><pre class="highlight"><code><span class="nc">DefaultMQAdminExt</span> <span class="n">defaultMQAdminExt</span> <span class="o">=</span> <span class="k">new</span> <span class="nc">DefaultMQAdminExt</span><span class="o">(</span><span class="s">"please_rename_unique_group_name"</span><span class="o">);</span>
<span class="n">defaultMQAdminExt</span><span class="o">.</span><span class="na">setNamesrvAddr</span><span class="o">(</span><span class="s">"name-server1-ip:port;name-server2-ip:port"</span><span class="o">);</span>
</code></pre></div></div>
@@ -566,7 +566,7 @@ You may also override <code class="highlighter-rouge">nsaddr</code> part using t
- <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>
diff --git a/content/docs/best-practice-producer/index.html b/content/docs/best-practice-producer/index.html
index 1170282..831edcc 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="2019-08-05T10:42:32+08:00">
+ <meta property="article:published_time" content="2019-08-13T20:57:29+08:00">
@@ -459,7 +459,7 @@
<meta itemprop="headline" content="Best Practice For Producer">
<meta itemprop="description" content="Some useful tips for users.">
- <meta itemprop="dateModified" content="December 25, 2016">
+ <meta itemprop="dateModified" content="December 24, 2016">
<div class="page__inner-wrap">
@@ -542,7 +542,7 @@ By 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>
diff --git a/content/docs/broadcast-example/index.html b/content/docs/broadcast-example/index.html
index b3c4174..14df94a 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="2019-08-05T10:42:32+08:00">
+ <meta property="article:published_time" content="2019-08-13T20:57:29+08:00">
@@ -459,7 +459,7 @@
<meta itemprop="headline" content="Broadcasting">
<meta itemprop="description" content="How to send broadcast messages in Apache RocketMQ.">
- <meta itemprop="dateModified" content="April 25, 2017">
+ <meta itemprop="dateModified" content="April 24, 2017">
<div class="page__inner-wrap">
@@ -489,17 +489,17 @@
<h4 id="producer-example">Producer example</h4>
<div class="language-java highlighter-rouge"><div class="highlight"><pre class="highlight"><code><span class="kd">public</span> <span class="kd">class</span> <span class="nc">BroadcastProducer</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="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">"ProducerGroupName"</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="nc">String</span><span class="o">[]</span> <span class="n">args</span><span class="o">)</span> <span class="kd">throws</span> <span class="nc">Exception</span> <span class="o">{</span>
+ <span class="nc">DefaultMQProducer</span> <span class="n">producer</span> <span class="o">=</span> <span class="k">new</span> <span class="nc">DefaultMQProducer</span><span class="o">(</span><span class="s">"ProducerGroupName"</span><span class="o">);</span>
<span class="n">producer</span><span class="o">.</span><span class="na">start</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="mi">100</span><span class="o">;</span> <span class="n">i</span><span class="o">++){</span>
- <span class="n">Message</span> <span class="n">msg</span> <span class="o">=</span> <span class="k">new</span> <span class="n">Message</span><span class="o">(</span><span class="s">"TopicTest"</span><span class="o">,</span>
+ <span class="nc">Message</span> <span class="n">msg</span> <span class="o">=</span> <span class="k">new</span> <span class="nc">Message</span><span class="o">(</span><span class="s">"TopicTest"</span><span class="o">,</span>
<span class="s">"TagA"</span><span class="o">,</span>
<span class="s">"OrderID188"</span><span class="o">,</span>
- <span class="s">"Hello world"</span><span class="o">.</span><span class="na">getBytes</span><span class="o">(</span><span class="n">RemotingHelper</span><span class="o">.</span><span class="na">DEFAULT_CHARSET</span><span class="o">));</span>
- <span class="n">SendResult</span> <span class="n">sendResult</span> <span class="o">=</span> <span class="n">producer</span><span class="o">.</span><span class="na">send</span><span class="o">(</span><span class="n">msg</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">sendResult</span><span class="o">);</span>
+ <span class="s">"Hello world"</span><span class="o">.</span><span class="na">getBytes</span><span class="o">(</span><span class="nc">RemotingHelper</span><span class="o">.</span><span class="na">DEFAULT_CHARSET</span><span class="o">));</span>
+ <span class="nc">SendResult</span> <span class="n">sendResult</span> <span class="o">=</span> <span class="n">producer</span><span class="o">.</span><span class="na">send</span><span class="o">(</span><span class="n">msg</span><span class="o">);</span>
+ <span class="nc">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">sendResult</span><span class="o">);</span>
<span class="o">}</span>
<span class="n">producer</span><span class="o">.</span><span class="na">shutdown</span><span class="o">();</span>
<span class="o">}</span>
@@ -509,28 +509,28 @@
<h4 id="consumer-example">Consumer example</h4>
<div class="language-java highlighter-rouge"><div class="highlight"><pre class="highlight"><code><span class="kd">public</span> <span class="kd">class</span> <span class="nc">BroadcastConsumer</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="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">"example_group_name"</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="nc">String</span><span class="o">[]</span> <span class="n">args</span><span class="o">)</span> <span class="kd">throws</span> <span class="nc">Exception</span> <span class="o">{</span>
+ <span class="nc">DefaultMQPushConsumer</span> <span class="n">consumer</span> <span class="o">=</span> <span class="k">new</span> <span class="nc">DefaultMQPushConsumer</span><span class="o">(</span><span class="s">"example_group_name"</span><span class="o">);</span>
- <span class="n">consumer</span><span class="o">.</span><span class="na">setConsumeFromWhere</span><span class="o">(</span><span class="n">ConsumeFromWhere</span><span class="o">.</span><span class="na">CONSUME_FROM_FIRST_OFFSET</span><span class="o">);</span>
+ <span class="n">consumer</span><span class="o">.</span><span class="na">setConsumeFromWhere</span><span class="o">(</span><span class="nc">ConsumeFromWhere</span><span class="o">.</span><span class="na">CONSUME_FROM_FIRST_OFFSET</span><span class="o">);</span>
<span class="c1">//set to broadcast mode</span>
- <span class="n">consumer</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">BROADCASTING</span><span class="o">);</span>
+ <span class="n">consumer</span><span class="o">.</span><span class="na">setMessageModel</span><span class="o">(</span><span class="nc">MessageModel</span><span class="o">.</span><span class="na">BROADCASTING</span><span class="o">);</span>
<span class="n">consumer</span><span class="o">.</span><span class="na">subscribe</span><span class="o">(</span><span class="s">"TopicTest"</span><span class="o">,</span> <span class="s">"TagA || TagC || TagD"</span><span class="o">);</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="n">consumer</span><span class="o">.</span><span class="na">registerMessageListener</span><span class="o">(</span><span class="k">new</span> <span class="nc">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">msgs</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="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="n">Thread</span><span class="o">.</span><span class="na">currentThread</span><span class="o">().</span><span class="na">getName</span><span class="o">()</span> <span class="o">+</span> <span class="s">" Receive New Messages: "</span> <span class="o">+</span> <span class="n">msgs</span> <span class="o">+< [...]
- <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="kd">public</span> <span class="nc">ConsumeConcurrentlyStatus</span> <span class="nf">consumeMessage</span><span class="o">(</span><span class="nc">List</span><span class="o"><</span><span class="nc">MessageExt</span><span class="o">></span> <span class="n">msgs</span><span class="o">,</span>
+ <span class="nc">ConsumeConcurrentlyContext</span> <span class="n">context</span><span class="o">)</span> <span class="o">{</span>
+ <span class="nc">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="nc">Thread</span><span class="o">.</span><span class="na">currentThread</span><span class="o">().</span><span class="na">getName</span><span class="o">()</span> <span class="o">+</span> <span class="s">" Receive New Messages: "</span> <span class="o">+</span> <span class="n">msgs</span> <span class="o"> [...]
+ <span class="k">return</span> <span class="nc">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="n">consumer</span><span class="o">.</span><span class="na">start</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">"Broadcast Consumer Started.%n"</span><span class="o">);</span>
+ <span class="nc">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">"Broadcast Consumer Started.%n"</span><span class="o">);</span>
<span class="o">}</span>
<span class="o">}</span>
</code></pre></div></div>
@@ -545,7 +545,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>
diff --git a/content/docs/cli-admin-tool/index.html b/content/docs/cli-admin-tool/index.html
index 4939e44..041a7e3 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="2019-08-05T10:42:32+08:00">
+ <meta property="article:published_time" content="2019-08-13T20:57:29+08:00">
@@ -459,7 +459,7 @@
<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="dateModified" content="December 17, 2016">
+ <meta itemprop="dateModified" content="December 16, 2016">
<div class="page__inner-wrap">
@@ -567,7 +567,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>
diff --git a/content/docs/cluster-deployment/index.html b/content/docs/cluster-deployment/index.html
index 8c1b329..41ea7ba 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="2019-08-05T10:42:32+08:00">
+ <meta property="article:published_time" content="2019-08-13T20:57:29+08:00">
@@ -459,7 +459,7 @@
<meta itemprop="headline" content="Cluster Configuration and Deployment">
<meta itemprop="description" content="Prerequisite">
- <meta itemprop="dateModified" content="December 17, 2016">
+ <meta itemprop="dateModified" content="December 16, 2016">
<div class="page__inner-wrap">
@@ -573,7 +573,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>
diff --git a/content/docs/code-guidelines/index.html b/content/docs/code-guidelines/index.html
index 3bd2d13..31425bb 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="2019-08-05T10:42:32+08:00">
+ <meta property="article:published_time" content="2019-08-13T20:57:29+08:00">
@@ -459,7 +459,7 @@
<meta itemprop="headline" content="Coding Guidelines">
<meta itemprop="description" content="Apache RocketMQ Coding Guidelines">
- <meta itemprop="dateModified" content="December 30, 2016">
+ <meta itemprop="dateModified" content="December 29, 2016">
<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="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>
diff --git a/content/docs/core-concept/index.html b/content/docs/core-concept/index.html
index 10e16ac..c6e6b14 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="2019-08-05T10:42:32+08:00">
+ <meta property="article:published_time" content="2019-08-13T20:57:29+08:00">
@@ -459,7 +459,7 @@
<meta itemprop="headline" content="Core Concept">
<meta itemprop="description" content="">
- <meta itemprop="dateModified" content="December 17, 2016">
+ <meta itemprop="dateModified" content="December 16, 2016">
<div class="page__inner-wrap">
@@ -608,7 +608,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>
diff --git a/content/docs/create-pull-request/index.html b/content/docs/create-pull-request/index.html
index ed2d5f5..8a49e60 100644
--- a/content/docs/create-pull-request/index.html
+++ b/content/docs/create-pull-request/index.html
@@ -57,7 +57,7 @@
<meta property="og:type" content="article">
- <meta property="article:published_time" content="2019-08-05T10:42:32+08:00">
+ <meta property="article:published_time" content="2019-08-13T20:57:29+08:00">
@@ -459,7 +459,7 @@
<meta itemprop="headline" content="How to create Pull Request">
<meta itemprop="description" content="This page guides you through the pull request creation process.">
- <meta itemprop="dateModified" content="December 25, 2016">
+ <meta itemprop="dateModified" content="December 24, 2016">
<div class="page__inner-wrap">
@@ -584,7 +584,7 @@ You pull request will be reviewed and commented by committers, and issues can be
- <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>
diff --git a/content/docs/documentation/index.html b/content/docs/documentation/index.html
index 555da40..dfe90c4 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="2019-08-05T10:42:32+08:00">
+ <meta property="article:published_time" content="2019-08-13T20:57:29+08:00">
@@ -459,7 +459,7 @@
<meta itemprop="headline" content="Documentation">
<meta itemprop="description" content="Apache RocketMQ Documentation">
- <meta itemprop="dateModified" content="March 02, 2017">
+ <meta itemprop="dateModified" content="March 01, 2017">
<div class="page__inner-wrap">
@@ -541,7 +541,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>
diff --git a/content/docs/faq/index.html b/content/docs/faq/index.html
index 580a792..c89991a 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="2019-08-05T10:42:32+08:00">
+ <meta property="article:published_time" content="2019-08-13T20:57:29+08:00">
@@ -459,7 +459,7 @@
<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="dateModified" content="December 28, 2016">
+ <meta itemprop="dateModified" content="December 27, 2016">
<div class="page__inner-wrap">
@@ -589,7 +589,7 @@ consumer.setConsumeThreadMax(20);
- <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>
diff --git a/content/docs/filter-by-sql92-example/index.html b/content/docs/filter-by-sql92-example/index.html
index b172514..218f9d0 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="2019-08-05T10:42:32+08:00">
+ <meta property="article:published_time" content="2019-08-13T20:57:29+08:00">
@@ -459,7 +459,7 @@
<meta itemprop="headline" content="Filter Example">
<meta itemprop="description" content="How to filter messages by SQL92 in Apache RocketMQ.">
- <meta itemprop="dateModified" content="April 27, 2017">
+ <meta itemprop="dateModified" content="April 26, 2017">
<div class="page__inner-wrap">
@@ -473,7 +473,7 @@
<section class="page__content" itemprop="text">
<p>In most cases, tag is a simple and useful design to select message you want. For example:</p>
-<div class="language-java highlighter-rouge"><div class="highlight"><pre class="highlight"><code><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">"CID_EXAMPLE"</span><span class="o">);</span>
+<div class="language-java highlighter-rouge"><div class="highlight"><pre class="highlight"><code><span class="nc">DefaultMQPushConsumer</span> <span class="n">consumer</span> <span class="o">=</span> <span class="k">new</span> <span class="nc">DefaultMQPushConsumer</span><span class="o">(</span><span class="s">"CID_EXAMPLE"</span><span class="o">);</span>
<span class="n">consumer</span><span class="o">.</span><span class="na">subscribe</span><span class="o">(</span><span class="s">"TOPIC"</span><span class="o">,</span> <span class="s">"TAGA || TAGB || TAGC"</span><span class="o">);</span>
</code></pre></div></div>
@@ -544,17 +544,17 @@
<p>You can put properties in message through method <code class="highlighter-rouge">putUserProperty</code> when sending.</p>
-<div class="language-java highlighter-rouge"><div class="highlight"><pre class="highlight"><code><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">"please_rename_unique_group_name"</span><span class="o">);</span>
+<div class="language-java highlighter-rouge"><div class="highlight"><pre class="highlight"><code><span class="nc">DefaultMQProducer</span> <span class="n">producer</span> <span class="o">=</span> <span class="k">new</span> <span class="nc">DefaultMQProducer</span><span class="o">(</span><span class="s">"please_rename_unique_group_name"</span><span class="o">);</span>
<span class="n">producer</span><span class="o">.</span><span class="na">start</span><span class="o">();</span>
-<span class="n">Message</span> <span class="n">msg</span> <span class="o">=</span> <span class="k">new</span> <span class="n">Message</span><span class="o">(</span><span class="s">"TopicTest"</span><span class="o">,</span>
+<span class="nc">Message</span> <span class="n">msg</span> <span class="o">=</span> <span class="k">new</span> <span class="nc">Message</span><span class="o">(</span><span class="s">"TopicTest"</span><span class="o">,</span>
<span class="n">tag</span><span class="o">,</span>
- <span class="o">(</span><span class="s">"Hello RocketMQ "</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="n">RemotingHelper</span><span class="o">.</span><span class="na">DEFAULT_CHARSET</span><span class="o">)</span>
+ <span class="o">(</span><span class="s">"Hello RocketMQ "</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="nc">RemotingHelper</span><span class="o">.</span><span class="na">DEFAULT_CHARSET</span><span class="o">)</span>
<span class="o">);</span>
<span class="c1">// Set some properties.</span>
-<span class="n">msg</span><span class="o">.</span><span class="na">putUserProperty</span><span class="o">(</span><span class="s">"a"</span><span class="o">,</span> <span class="n">String</span><span class="o">.</span><span class="na">valueOf</span><span class="o">(</span><span class="n">i</span><span class="o">));</span>
+<span class="n">msg</span><span class="o">.</span><span class="na">putUserProperty</span><span class="o">(</span><span class="s">"a"</span><span class="o">,</span> <span class="nc">String</span><span class="o">.</span><span class="na">valueOf</span><span class="o">(</span><span class="n">i</span><span class="o">));</span>
-<span class="n">SendResult</span> <span class="n">sendResult</span> <span class="o">=</span> <span class="n">producer</span><span class="o">.</span><span class="na">send</span><span class="o">(</span><span class="n">msg</span><span class="o">);</span>
+<span class="nc">SendResult</span> <span class="n">sendResult</span> <span class="o">=</span> <span class="n">producer</span><span class="o">.</span><span class="na">send</span><span class="o">(</span><span class="n">msg</span><span class="o">);</span>
<span class="n">producer</span><span class="o">.</span><span class="na">shutdown</span><span class="o">();</span>
</code></pre></div></div>
@@ -563,15 +563,15 @@
<p>Use <code class="highlighter-rouge">MessageSelector.bySql</code> to select messages through SQL92 when consuming.</p>
-<div class="language-java highlighter-rouge"><div class="highlight"><pre class="highlight"><code><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">"please_rename_unique_group_name_4"</span><span class="o">);</span>
+<div class="language-java highlighter-rouge"><div class="highlight"><pre class="highlight"><code><span class="nc">DefaultMQPushConsumer</span> <span class="n">consumer</span> <span class="o">=</span> <span class="k">new</span> <span class="nc">DefaultMQPushConsumer</span><span class="o">(</span><span class="s">"please_rename_unique_group_name_4"</span><span class="o">);</span>
<span class="c1">// only subsribe messages have property a, also a >=0 and a <= 3</span>
-<span class="n">consumer</span><span class="o">.</span><span class="na">subscribe</span><span class="o">(</span><span class="s">"TopicTest"</span><span class="o">,</span> <span class="n">MessageSelector</span><span class="o">.</span><span class="na">bySql</span><span class="o">(</span><span class="s">"a between 0 and 3"</span><span class="o">);</span>
+<span class="n">consumer</span><span class="o">.</span><span class="na">subscribe</span><span class="o">(</span><span class="s">"TopicTest"</span><span class="o">,</span> <span class="nc">MessageSelector</span><span class="o">.</span><span class="na">bySql</span><span class="o">(</span><span class="s">"a between 0 and 3"</span><span class="o">);</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="n">consumer</span><span class="o">.</span><span class="na">registerMessageListener</span><span class="o">(</span><span class="k">new</span> <span class="nc">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">msgs</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">return</span> <span class="n">ConsumeConcurrentlyStatus</span><span class="o">.</span><span class="na">CONSUME_SUCCESS</span><span class="o">;</span>
+ <span class="kd">public</span> <span class="nc">ConsumeConcurrentlyStatus</span> <span class="nf">consumeMessage</span><span class="o">(</span><span class="nc">List</span><span class="o"><</span><span class="nc">MessageExt</span><span class="o">></span> <span class="n">msgs</span><span class="o">,</span> <span class="nc">ConsumeConcurrentlyContext</span> <span class="n">context</span><span class="o">)</span> <span class="o">{</span>
+ <span class="k">return</span> <span class="nc">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="n">consumer</span><span class="o">.</span><span class="na">start</span><span class="o">();</span>
@@ -587,7 +587,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>
diff --git a/content/docs/how-to-contribute/index.html b/content/docs/how-to-contribute/index.html
index c20c9da..1d1d60f 100644
--- a/content/docs/how-to-contribute/index.html
+++ b/content/docs/how-to-contribute/index.html
@@ -57,7 +57,7 @@
<meta property="og:type" content="article">
- <meta property="article:published_time" content="2019-08-05T10:42:32+08:00">
+ <meta property="article:published_time" content="2019-08-13T20:57:29+08:00">
@@ -459,7 +459,7 @@
<meta itemprop="headline" content="How to Contribute">
<meta itemprop="description" content="Apache RocketMQ is developed by an open and friendly community. Everybody is cordially welcome to join the community and contribute to Apache RocketMQ. There are several ways to interact with the community and to contribute to RocketMQ including asking questions, filing bug reports, proposing new features, joining discussions on the mailing lists, contributing code or documentation, improving the website, or testing release candidates.">
- <meta itemprop="dateModified" content="August 24, 2017">
+ <meta itemprop="dateModified" content="August 23, 2017">
<div class="page__inner-wrap">
@@ -610,7 +610,7 @@ Please follow the Improve the <a href="https://github.com/apache/rocketmq-site">
- <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2017-08-24">August 24, 2017</time></p>
+ <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2017-08-23">August 23, 2017</time></p>
</footer>
diff --git a/content/docs/logappender-example/index.html b/content/docs/logappender-example/index.html
index 3c86078..1efdcf3 100644
--- a/content/docs/logappender-example/index.html
+++ b/content/docs/logappender-example/index.html
@@ -57,7 +57,7 @@
<meta property="og:type" content="article">
- <meta property="article:published_time" content="2019-08-05T10:42:32+08:00">
+ <meta property="article:published_time" content="2019-08-13T20:57:29+08:00">
@@ -459,7 +459,7 @@
<meta itemprop="headline" content="Logappender Example">
<meta itemprop="description" content="How to use logappender in RocketMQ.">
- <meta itemprop="dateModified" content="June 09, 2017">
+ <meta itemprop="dateModified" content="June 08, 2017">
<div class="page__inner-wrap">
@@ -560,7 +560,7 @@ log4j.appender.mq.layout.ConversionPattern=%d{yyyy-MM-dd HH:mm:ss} %-4r [%t] (%F
- <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2017-06-09">June 09, 2017</time></p>
+ <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2017-06-08">June 08, 2017</time></p>
</footer>
diff --git a/content/docs/motivation/index.html b/content/docs/motivation/index.html
index 92e22c3..a72013e 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="2019-08-05T10:42:32+08:00">
+ <meta property="article:published_time" content="2019-08-13T20:57:29+08:00">
@@ -459,7 +459,7 @@
<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 asynchronous communication, search, social network activity stream, data pipeline,even in its trade processes. As our trade business throughput rises, pressure originating from our messaging clusteralso becomes urgent.">
- <meta itemprop="dateModified" content="December 17, 2016">
+ <meta itemprop="dateModified" content="December 16, 2016">
<div class="page__inner-wrap">
@@ -596,7 +596,7 @@ open source version of RocketMQ in their business. We also published a commercia
- <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>
diff --git a/content/docs/openmessaging-example/index.html b/content/docs/openmessaging-example/index.html
index f3619ff..aa0ebae 100644
--- a/content/docs/openmessaging-example/index.html
+++ b/content/docs/openmessaging-example/index.html
@@ -57,7 +57,7 @@
<meta property="og:type" content="article">
- <meta property="article:published_time" content="2019-08-05T10:42:32+08:00">
+ <meta property="article:published_time" content="2019-08-13T20:57:29+08:00">
@@ -459,7 +459,7 @@
<meta itemprop="headline" content="OpenMessaging Example">
<meta itemprop="description" content="How to use OpenMessaging in RocketMQ.">
- <meta itemprop="dateModified" content="June 09, 2017">
+ <meta itemprop="dateModified" content="June 08, 2017">
<div class="page__inner-wrap">
@@ -492,42 +492,42 @@
<p>The following example shows how to send message to RocketMQ broker in synchronous, asynchronous, or one-way transmissions.</p>
<div class="language-java highlighter-rouge"><div class="highlight"><pre class="highlight"><code><span class="kd">public</span> <span class="kd">class</span> <span class="nc">OMSProducer</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="o">{</span>
- <span class="kd">final</span> <span class="n">MessagingAccessPoint</span> <span class="n">messagingAccessPoint</span> <span class="o">=</span> <span class="n">MessagingAccessPointFactory</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="nc">String</span><span class="o">[]</span> <span class="n">args</span><span class="o">)</span> <span class="o">{</span>
+ <span class="kd">final</span> <span class="nc">MessagingAccessPoint</span> <span class="n">messagingAccessPoint</span> <span class="o">=</span> <span class="nc">MessagingAccessPointFactory</span>
<span class="o">.</span><span class="na">getMessagingAccessPoint</span><span class="o">(</span><span class="s">"openmessaging:rocketmq://IP1:9876,IP2:9876/namespace"</span><span class="o">);</span>
- <span class="kd">final</span> <span class="n">Producer</span> <span class="n">producer</span> <span class="o">=</span> <span class="n">messagingAccessPoint</span><span class="o">.</span><span class="na">createProducer</span><span class="o">();</span>
+ <span class="kd">final</span> <span class="nc">Producer</span> <span class="n">producer</span> <span class="o">=</span> <span class="n">messagingAccessPoint</span><span class="o">.</span><span class="na">createProducer</span><span class="o">();</span>
<span class="n">messagingAccessPoint</span><span class="o">.</span><span class="na">startup</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">"MessagingAccessPoint startup OK%n"</span><span class="o">);</span>
+ <span class="nc">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">"MessagingAccessPoint startup OK%n"</span><span class="o">);</span>
<span class="n">producer</span><span class="o">.</span><span class="na">startup</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">"Producer startup OK%n"</span><span class="o">);</span>
+ <span class="nc">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">"Producer startup OK%n"</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="n">producer</span><span class="o">.</span><span class="na">createBytesMessageToTopic</span><span class="o">(</span><span class="s">"OMS_HELLO_TOPIC"</span><span class="o">,</span> <span class="s">"OMS_HELLO_BODY"</span><span class="o">.</span><span class="na">getBytes</span><span class="o">(</span><span class="n">Charset</span><span class="o">.</span><span class="na">forName</s [...]
- <span class="n">SendResult</span> <span class="n">sendResult</span> <span class="o">=</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="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">"Send sync message OK, msgId: %s%n"</span><span class="o">,</span> <span class="n">sendResult</span><span class="o">.</span><span class="na">messageId</span><span class="o">());</span>
+ <span class="nc">Message</span> <span class="n">message</span> <span class="o">=</span> <span class="n">producer</span><span class="o">.</span><span class="na">createBytesMessageToTopic</span><span class="o">(</span><span class="s">"OMS_HELLO_TOPIC"</span><span class="o">,</span> <span class="s">"OMS_HELLO_BODY"</span><span class="o">.</span><span class="na">getBytes</span><span class="o">(</span><span class="nc">Charset</span><span class="o">.</span><span class="na">forName< [...]
+ <span class="nc">SendResult</span> <span class="n">sendResult</span> <span class="o">=</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="nc">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">"Send sync message OK, msgId: %s%n"</span><span class="o">,</span> <span class="n">sendResult</span><span class="o">.</span><span class="na">messageId</span><span class="o">());</span>
<span class="o">}</span>
<span class="o">{</span>
- <span class="kd">final</span> <span class="n">Promise</span><span class="o"><</span><span class="n">SendResult</span><span class="o">></span> <span class="n">result</span> <span class="o">=</span> <span class="n">producer</span><span class="o">.</span><span class="na">sendAsync</span><span class="o">(</span><span class="n">producer</span><span class="o">.</span><span class="na">createBytesMessageToTopic</span><span class="o">(</span><span class="s">"OMS_HELLO_TOPIC"</sp [...]
- <span class="n">result</span><span class="o">.</span><span class="na">addListener</span><span class="o">(</span><span class="k">new</span> <span class="n">PromiseListener</span><span class="o"><</span><span class="n">SendResult</span><span class="o">>()</span> <span class="o">{</span>
+ <span class="kd">final</span> <span class="nc">Promise</span><span class="o"><</span><span class="nc">SendResult</span><span class="o">></span> <span class="n">result</span> <span class="o">=</span> <span class="n">producer</span><span class="o">.</span><span class="na">sendAsync</span><span class="o">(</span><span class="n">producer</span><span class="o">.</span><span class="na">createBytesMessageToTopic</span><span class="o">(</span><span class="s">"OMS_HELLO_TOPIC"</ [...]
+ <span class="n">result</span><span class="o">.</span><span class="na">addListener</span><span class="o">(</span><span class="k">new</span> <span class="nc">PromiseListener</span><span class="o"><</span><span class="nc">SendResult</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">operationCompleted</span><span class="o">(</span><span class="n">Promise</span><span class="o"><</span><span class="n">SendResult</span><span class="o">></span> <span class="n">promise</span><span class="o">)</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">"Send async message OK, msgId: %s%n"</span><span class="o">,</span> <span class="n">promise</span><span class="o">.</span><span class="na">get</span><span class="o">().</span><span class="na">messageId</span><span class="o">());</span>
+ <span class="kd">public</span> <span class="kt">void</span> <span class="nf">operationCompleted</span><span class="o">(</span><span class="nc">Promise</span><span class="o"><</span><span class="nc">SendResult</span><span class="o">></span> <span class="n">promise</span><span class="o">)</span> <span class="o">{</span>
+ <span class="nc">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">"Send async message OK, msgId: %s%n"</span><span class="o">,</span> <span class="n">promise</span><span class="o">.</span><span class="na">get</span><span class="o">().</span><span class="na">messageId</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">operationFailed</span><span class="o">(</span><span class="n">Promise</span><span class="o"><</span><span class="n">SendResult</span><span class="o">></span> <span class="n">promise</span><span class="o">)</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">"Send async message Failed, error: %s%n"</span><span class="o">,</span> <span class="n">promise</span><span class="o">.</span><span class="na">getThrowable</span><span class="o">().</span><span class="na">getMessage</span><span class="o">());</span>
+ <span class="kd">public</span> <span class="kt">void</span> <span class="nf">operationFailed</span><span class="o">(</span><span class="nc">Promise</span><span class="o"><</span><span class="nc">SendResult</span><span class="o">></span> <span class="n">promise</span><span class="o">)</span> <span class="o">{</span>
+ <span class="nc">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">"Send async message Failed, error: %s%n"</span><span class="o">,</span> <span class="n">promise</span><span class="o">.</span><span class="na">getThrowable</span><span class="o">().</span><span class="na">getMessage</span><span class="o">());</span>
<span class="o">}</span>
<span class="o">});</span>
<span class="o">}</span>
<span class="o">{</span>
- <span class="n">producer</span><span class="o">.</span><span class="na">sendOneway</span><span class="o">(</span><span class="n">producer</span><span class="o">.</span><span class="na">createBytesMessageToTopic</span><span class="o">(</span><span class="s">"OMS_HELLO_TOPIC"</span><span class="o">,</span> <span class="s">"OMS_HELLO_BODY"</span><span class="o">.</span><span class="na">getBytes</span><span class="o">(</span><span class="n">Charset</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">"Send oneway message OK%n"</span><span class="o">);</span>
+ <span class="n">producer</span><span class="o">.</span><span class="na">sendOneway</span><span class="o">(</span><span class="n">producer</span><span class="o">.</span><span class="na">createBytesMessageToTopic</span><span class="o">(</span><span class="s">"OMS_HELLO_TOPIC"</span><span class="o">,</span> <span class="s">"OMS_HELLO_BODY"</span><span class="o">.</span><span class="na">getBytes</span><span class="o">(</span><span class="nc">Charset</span><span class="o">.</span> [...]
+ <span class="nc">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">"Send oneway message OK%n"</span><span class="o">);</span>
<span class="o">}</span>
<span class="n">producer</span><span class="o">.</span><span class="na">shutdown</span><span class="o">();</span>
@@ -541,23 +541,23 @@
<p>Use OMS PullConsumer to poll messages from a specified queue.</p>
<div class="language-java highlighter-rouge"><div class="highlight"><pre class="highlight"><code><span class="kd">public</span> <span class="kd">class</span> <span class="nc">OMSPullConsumer</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="o">{</span>
- <span class="kd">final</span> <span class="n">MessagingAccessPoint</span> <span class="n">messagingAccessPoint</span> <span class="o">=</span> <span class="n">MessagingAccessPointFactory</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="nc">String</span><span class="o">[]</span> <span class="n">args</span><span class="o">)</span> <span class="o">{</span>
+ <span class="kd">final</span> <span class="nc">MessagingAccessPoint</span> <span class="n">messagingAccessPoint</span> <span class="o">=</span> <span class="nc">MessagingAccessPointFactory</span>
<span class="o">.</span><span class="na">getMessagingAccessPoint</span><span class="o">(</span><span class="s">"openmessaging:rocketmq://IP1:9876,IP2:9876/namespace"</span><span class="o">);</span>
- <span class="kd">final</span> <span class="n">PullConsumer</span> <span class="n">consumer</span> <span class="o">=</span> <span class="n">messagingAccessPoint</span><span class="o">.</span><span class="na">createPullConsumer</span><span class="o">(</span><span class="s">"OMS_HELLO_TOPIC"</span><span class="o">,</span>
- <span class="n">OMS</span><span class="o">.</span><span class="na">newKeyValue</span><span class="o">().</span><span class="na">put</span><span class="o">(</span><span class="n">NonStandardKeys</span><span class="o">.</span><span class="na">CONSUMER_GROUP</span><span class="o">,</span> <span class="s">"OMS_CONSUMER"</span><span class="o">));</span>
+ <span class="kd">final</span> <span class="nc">PullConsumer</span> <span class="n">consumer</span> <span class="o">=</span> <span class="n">messagingAccessPoint</span><span class="o">.</span><span class="na">createPullConsumer</span><span class="o">(</span><span class="s">"OMS_HELLO_TOPIC"</span><span class="o">,</span>
+ <span class="no">OMS</span><span class="o">.</span><span class="na">newKeyValue</span><span class="o">().</span><span class="na">put</span><span class="o">(</span><span class="nc">NonStandardKeys</span><span class="o">.</span><span class="na">CONSUMER_GROUP</span><span class="o">,</span> <span class="s">"OMS_CONSUMER"</span><span class="o">));</span>
<span class="n">messagingAccessPoint</span><span class="o">.</span><span class="na">startup</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">"MessagingAccessPoint startup OK%n"</span><span class="o">);</span>
+ <span class="nc">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">"MessagingAccessPoint startup OK%n"</span><span class="o">);</span>
<span class="n">consumer</span><span class="o">.</span><span class="na">startup</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">"Consumer startup OK%n"</span><span class="o">);</span>
+ <span class="nc">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">"Consumer startup OK%n"</span><span class="o">);</span>
- <span class="n">Message</span> <span class="n">message</span> <span class="o">=</span> <span class="n">consumer</span><span class="o">.</span><span class="na">poll</span><span class="o">();</span>
+ <span class="nc">Message</span> <span class="n">message</span> <span class="o">=</span> <span class="n">consumer</span><span class="o">.</span><span class="na">poll</span><span class="o">();</span>
<span class="k">if</span> <span class="o">(</span><span class="n">message</span> <span class="o">!=</span> <span class="kc">null</span><span class="o">)</span> <span class="o">{</span>
- <span class="n">String</span> <span class="n">msgId</span> <span class="o">=</span> <span class="n">message</span><span class="o">.</span><span class="na">headers</span><span class="o">().</span><span class="na">getString</span><span class="o">(</span><span class="n">MessageHeader</span><span class="o">.</span><span class="na">MESSAGE_ID</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">"Received one message: %s%n"</span><span class="o">,</span> <span class="n">msgId</span><span class="o">);</span>
+ <span class="nc">String</span> <span class="n">msgId</span> <span class="o">=</span> <span class="n">message</span><span class="o">.</span><span class="na">headers</span><span class="o">().</span><span class="na">getString</span><span class="o">(</span><span class="nc">MessageHeader</span><span class="o">.</span><span class="na">MESSAGE_ID</span><span class="o">);</span>
+ <span class="nc">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">"Received one message: %s%n"</span><span class="o">,</span> <span class="n">msgId</span><span class="o">);</span>
<span class="n">consumer</span><span class="o">.</span><span class="na">ack</span><span class="o">(</span><span class="n">msgId</span><span class="o">);</span>
<span class="o">}</span>
@@ -572,17 +572,17 @@
<p>Attaches OMS PushConsumer to a specified queue and consumes messages by MessageListener</p>
<div class="language-java highlighter-rouge"><div class="highlight"><pre class="highlight"><code><span class="kd">public</span> <span class="kd">class</span> <span class="nc">OMSPushConsumer</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="o">{</span>
- <span class="kd">final</span> <span class="n">MessagingAccessPoint</span> <span class="n">messagingAccessPoint</span> <span class="o">=</span> <span class="n">MessagingAccessPointFactory</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="nc">String</span><span class="o">[]</span> <span class="n">args</span><span class="o">)</span> <span class="o">{</span>
+ <span class="kd">final</span> <span class="nc">MessagingAccessPoint</span> <span class="n">messagingAccessPoint</span> <span class="o">=</span> <span class="nc">MessagingAccessPointFactory</span>
<span class="o">.</span><span class="na">getMessagingAccessPoint</span><span class="o">(</span><span class="s">"openmessaging:rocketmq://IP1:9876,IP2:9876/namespace"</span><span class="o">);</span>
- <span class="kd">final</span> <span class="n">PushConsumer</span> <span class="n">consumer</span> <span class="o">=</span> <span class="n">messagingAccessPoint</span><span class="o">.</span>
- <span class="nf">createPushConsumer</span><span class="o">(</span><span class="n">OMS</span><span class="o">.</span><span class="na">newKeyValue</span><span class="o">().</span><span class="na">put</span><span class="o">(</span><span class="n">NonStandardKeys</span><span class="o">.</span><span class="na">CONSUMER_GROUP</span><span class="o">,</span> <span class="s">"OMS_CONSUMER"</span><span class="o">));</span>
+ <span class="kd">final</span> <span class="nc">PushConsumer</span> <span class="n">consumer</span> <span class="o">=</span> <span class="n">messagingAccessPoint</span><span class="o">.</span>
+ <span class="nf">createPushConsumer</span><span class="o">(</span><span class="no">OMS</span><span class="o">.</span><span class="na">newKeyValue</span><span class="o">().</span><span class="na">put</span><span class="o">(</span><span class="nc">NonStandardKeys</span><span class="o">.</span><span class="na">CONSUMER_GROUP</span><span class="o">,</span> <span class="s">"OMS_CONSUMER"</span><span class="o">));</span>
<span class="n">messagingAccessPoint</span><span class="o">.</span><span class="na">startup</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">"MessagingAccessPoint startup OK%n"</span><span class="o">);</span>
+ <span class="nc">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">"MessagingAccessPoint startup OK%n"</span><span class="o">);</span>
- <span class="n">Runtime</span><span class="o">.</span><span class="na">getRuntime</span><span class="o">().</span><span class="na">addShutdownHook</span><span class="o">(</span><span class="k">new</span> <span class="n">Thread</span><span class="o">(</span><span class="k">new</span> <span class="n">Runnable</span><span class="o">()</span> <span class="o">{</span>
+ <span class="nc">Runtime</span><span class="o">.</span><span class="na">getRuntime</span><span class="o">().</span><span class="na">addShutdownHook</span><span class="o">(</span><span class="k">new</span> <span class="nc">Thread</span><span class="o">(</span><span class="k">new</span> <span class="nc">Runnable</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">run</span><span class="o">()</span> <span class="o">{</span>
<span class="n">consumer</span><span class="o">.</span><span class="na">shutdown</span><span class="o">();</span>
@@ -590,10 +590,10 @@
<span class="o">}</span>
<span class="o">}));</span>
- <span class="n">consumer</span><span class="o">.</span><span class="na">attachQueue</span><span class="o">(</span><span class="s">"OMS_HELLO_TOPIC"</span><span class="o">,</span> <span class="k">new</span> <span class="n">MessageListener</span><span class="o">()</span> <span class="o">{</span>
+ <span class="n">consumer</span><span class="o">.</span><span class="na">attachQueue</span><span class="o">(</span><span class="s">"OMS_HELLO_TOPIC"</span><span class="o">,</span> <span class="k">new</span> <span class="nc">MessageListener</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">onMessage</span><span class="o">(</span><span class="kd">final</span> <span class="n">Message</span> <span class="n">message</span><span class="o">,</span> <span class="kd">final</span> <span class="n">ReceivedMessageContext</span> <span class="n">context</span><span class="o">)</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">"Received one message: %s%n"</span><span class="o">,</span> <span class="n">message</span><span class="o">.</span><span class="na">headers</span><span class="o">().</span><span class="na">getString</span><span class="o">(</span><span class="n">MessageHeader</span><span class="o">.</span><span class="n [...]
+ <span class="kd">public</span> <span class="kt">void</span> <span class="nf">onMessage</span><span class="o">(</span><span class="kd">final</span> <span class="nc">Message</span> <span class="n">message</span><span class="o">,</span> <span class="kd">final</span> <span class="nc">ReceivedMessageContext</span> <span class="n">context</span><span class="o">)</span> <span class="o">{</span>
+ <span class="nc">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">"Received one message: %s%n"</span><span class="o">,</span> <span class="n">message</span><span class="o">.</span><span class="na">headers</span><span class="o">().</span><span class="na">getString</span><span class="o">(</span><span class="nc">MessageHeader</span><span class="o">.</span><span class= [...]
<span class="n">context</span><span class="o">.</span><span class="na">ack</span><span class="o">();</span>
<span class="o">}</span>
<span class="o">});</span>
@@ -612,7 +612,7 @@
- <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2017-06-09">June 09, 2017</time></p>
+ <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2017-06-08">June 08, 2017</time></p>
</footer>
diff --git a/content/docs/order-example/index.html b/content/docs/order-example/index.html
index 643e55f..6d4a41e 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="2019-08-05T10:42:32+08:00">
+ <meta property="article:published_time" content="2019-08-13T20:57:29+08:00">
@@ -459,7 +459,7 @@
<meta itemprop="headline" content="Order Message">
<meta itemprop="description" content="How to send and receive ordered messages in Apache RocketMQ.">
- <meta itemprop="dateModified" content="April 25, 2017">
+ <meta itemprop="dateModified" content="April 24, 2017">
<div class="page__inner-wrap">
@@ -488,27 +488,27 @@
<h4 id="send-message-sample-code">Send message sample code</h4>
<div class="language-java highlighter-rouge"><div class="highlight"><pre class="highlight"><code><span class="kd">public</span> <span class="kd">class</span> <span class="nc">OrderedProducer</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="kd">public</span> <span class="kd">static</span> <span class="kt">void</span> <span class="nf">main</span><span class="o">(</span><span class="nc">String</span><span class="o">[]</span> <span class="n">args</span><span class="o">)</span> <span class="kd">throws</span> <span class="nc">Exception</span> <span class="o">{</span>
<span class="c1">//Instantiate with a producer group name.</span>
- <span class="n">MQProducer</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">"example_group_name"</span><span class="o">);</span>
+ <span class="nc">MQProducer</span> <span class="n">producer</span> <span class="o">=</span> <span class="k">new</span> <span class="nc">DefaultMQProducer</span><span class="o">(</span><span class="s">"example_group_name"</span><span class="o">);</span>
<span class="c1">//Launch the instance.</span>
<span class="n">producer</span><span class="o">.</span><span class="na">start</span><span class="o">();</span>
- <span class="n">String</span><span class="o">[]</span> <span class="n">tags</span> <span class="o">=</span> <span class="k">new</span> <span class="n">String</span><span class="o">[]</span> <span class="o">{</span><span class="s">"TagA"</span><span class="o">,</span> <span class="s">"TagB"</span><span class="o">,</span> <span class="s">"TagC"</span><span class="o">,</span> <span class="s">"TagD"</span><span class="o">,</span> <span class="s">"TagE"</span><span class="o">};</span>
+ <span class="nc">String</span><span class="o">[]</span> <span class="n">tags</span> <span class="o">=</span> <span class="k">new</span> <span class="nc">String</span><span class="o">[]</span> <span class="o">{</span><span class="s">"TagA"</span><span class="o">,</span> <span class="s">"TagB"</span><span class="o">,</span> <span class="s">"TagC"</span><span class="o">,</span> <span class="s">"TagD"</span><span class="o">,</span> <span class="s">"TagE"</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="mi">100</span><span class="o">;</span> <span class="n">i</span><span class="o">++)</span> <span class="o">{</span>
<span class="kt">int</span> <span class="n">orderId</span> <span class="o">=</span> <span class="n">i</span> <span class="o">%</span> <span class="mi">10</span><span class="o">;</span>
<span class="c1">//Create a message instance, specifying topic, tag and message body.</span>
- <span class="n">Message</span> <span class="n">msg</span> <span class="o">=</span> <span class="k">new</span> <span class="n">Message</span><span class="o">(</span><span class="s">"TopicTestjjj"</span><span class="o">,</span> <span class="n">tags</span><span class="o">[</span><span class="n">i</span> <span class="o">%</span> <span class="n">tags</span><span class="o">.</span><span class="na">length</span><span class="o">],</span> <span class="s">"KEY"</span> <span class="o">+ [...]
- <span class="o">(</span><span class="s">"Hello RocketMQ "</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="n">RemotingHelper</span><span class="o">.</span><span class="na">DEFAULT_CHARSET</span><span class="o">));</span>
- <span class="n">SendResult</span> <span class="n">sendResult</span> <span class="o">=</span> <span class="n">producer</span><span class="o">.</span><span class="na">send</span><span class="o">(</span><span class="n">msg</span><span class="o">,</span> <span class="k">new</span> <span class="n">MessageQueueSelector</span><span class="o">()</span> <span class="o">{</span>
+ <span class="nc">Message</span> <span class="n">msg</span> <span class="o">=</span> <span class="k">new</span> <span class="nc">Message</span><span class="o">(</span><span class="s">"TopicTestjjj"</span><span class="o">,</span> <span class="n">tags</span><span class="o">[</span><span class="n">i</span> <span class="o">%</span> <span class="n">tags</span><span class="o">.</span><span class="na">length</span><span class="o">],</span> <span class="s">"KEY"</span> <span class="o" [...]
+ <span class="o">(</span><span class="s">"Hello RocketMQ "</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="nc">RemotingHelper</span><span class="o">.</span><span class="na">DEFAULT_CHARSET</span><span class="o">));</span>
+ <span class="nc">SendResult</span> <span class="n">sendResult</span> <span class="o">=</span> <span class="n">producer</span><span class="o">.</span><span class="na">send</span><span class="o">(</span><span class="n">msg</span><span class="o">,</span> <span class="k">new</span> <span class="nc">MessageQueueSelector</span><span class="o">()</span> <span class="o">{</span>
<span class="nd">@Override</span>
- <span class="kd">public</span> <span class="n">MessageQueue</span> <span class="nf">select</span><span class="o">(</span><span class="n">List</span><span class="o"><</span><span class="n">MessageQueue</span><span class="o">></span> <span class="n">mqs</span><span class="o">,</span> <span class="n">Message</span> <span class="n">msg</span><span class="o">,</span> <span class="n">Object</span> <span class="n">arg</span><span class="o">)</span> <span class="o">{</span>
- <span class="n">Integer</span> <span class="n">id</span> <span class="o">=</span> <span class="o">(</span><span class="n">Integer</span><span class="o">)</span> <span class="n">arg</span><span class="o">;</span>
+ <span class="kd">public</span> <span class="nc">MessageQueue</span> <span class="nf">select</span><span class="o">(</span><span class="nc">List</span><span class="o"><</span><span class="nc">MessageQueue</span><span class="o">></span> <span class="n">mqs</span><span class="o">,</span> <span class="nc">Message</span> <span class="n">msg</span><span class="o">,</span> <span class="nc">Object</span> <span class="n">arg</span><span class="o">)</span> <span class="o">{</span>
+ <span class="nc">Integer</span> <span class="n">id</span> <span class="o">=</span> <span class="o">(</span><span class="nc">Integer</span><span class="o">)</span> <span class="n">arg</span><span class="o">;</span>
<span class="kt">int</span> <span class="n">index</span> <span class="o">=</span> <span class="n">id</span> <span class="o">%</span> <span class="n">mqs</span><span class="o">.</span><span class="na">size</span><span class="o">();</span>
<span class="k">return</span> <span class="n">mqs</span><span class="o">.</span><span class="na">get</span><span class="o">(</span><span class="n">index</span><span class="o">);</span>
<span class="o">}</span>
<span class="o">},</span> <span class="n">orderId</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">sendResult</span><span class="o">);</span>
+ <span class="nc">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">sendResult</span><span class="o">);</span>
<span class="o">}</span>
<span class="c1">//server shutdown</span>
<span class="n">producer</span><span class="o">.</span><span class="na">shutdown</span><span class="o">();</span>
@@ -519,40 +519,40 @@
<h4 id="subscription-message-sample-code">Subscription message sample code</h4>
<div class="language-java highlighter-rouge"><div class="highlight"><pre class="highlight"><code><span class="kd">public</span> <span class="kd">class</span> <span class="nc">OrderedConsumer</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="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">"example_group_name"</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="nc">String</span><span class="o">[]</span> <span class="n">args</span><span class="o">)</span> <span class="kd">throws</span> <span class="nc">Exception</span> <span class="o">{</span>
+ <span class="nc">DefaultMQPushConsumer</span> <span class="n">consumer</span> <span class="o">=</span> <span class="k">new</span> <span class="nc">DefaultMQPushConsumer</span><span class="o">(</span><span class="s">"example_group_name"</span><span class="o">);</span>
- <span class="n">consumer</span><span class="o">.</span><span class="na">setConsumeFromWhere</span><span class="o">(</span><span class="n">ConsumeFromWhere</span><span class="o">.</span><span class="na">CONSUME_FROM_FIRST_OFFSET</span><span class="o">);</span>
+ <span class="n">consumer</span><span class="o">.</span><span class="na">setConsumeFromWhere</span><span class="o">(</span><span class="nc">ConsumeFromWhere</span><span class="o">.</span><span class="na">CONSUME_FROM_FIRST_OFFSET</span><span class="o">);</span>
<span class="n">consumer</span><span class="o">.</span><span class="na">subscribe</span><span class="o">(</span><span class="s">"TopicTest"</span><span class="o">,</span> <span class="s">"TagA || TagC || TagD"</span><span class="o">);</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">MessageListenerOrderly</span><span class="o">()</span> <span class="o">{</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="nc">MessageListenerOrderly</span><span class="o">()</span> <span class="o">{</span>
- <span class="n">AtomicLong</span> <span class="n">consumeTimes</span> <span class="o">=</span> <span class="k">new</span> <span class="n">AtomicLong</span><span class="o">(</span><span class="mi">0</span><span class="o">);</span>
+ <span class="nc">AtomicLong</span> <span class="n">consumeTimes</span> <span class="o">=</span> <span class="k">new</span> <span class="nc">AtomicLong</span><span class="o">(</span><span class="mi">0</span><span class="o">);</span>
<span class="nd">@Override</span>
- <span class="kd">public</span> <span class="n">ConsumeOrderlyStatus</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">msgs</span><span class="o">,</span>
- <span class="n">ConsumeOrderlyContext</span> <span class="n">context</span><span class="o">)</span> <span class="o">{</span>
+ <span class="kd">public</span> <span class="nc">ConsumeOrderlyStatus</span> <span class="nf">consumeMessage</span><span class="o">(</span><span class="nc">List</span><span class="o"><</span><span class="nc">MessageExt</span><span class="o">></span> <span class="n">msgs</span><span class="o">,</span>
+ <span class="nc">ConsumeOrderlyContext</span> <span class="n">context</span><span class="o">)</span> <span class="o">{</span>
<span class="n">context</span><span class="o">.</span><span class="na">setAutoCommit</span><span class="o">(</span><span class="kc">false</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="n">Thread</span><span class="o">.</span><span class="na">currentThread</span><span class="o">().</span><span class="na">getName</span><span class="o">()</span> <span class="o">+</span> <span class="s">" Receive New Messages: "</span> <span class="o">+</span> <span class="n">msgs</span> <span class="o">+< [...]
+ <span class="nc">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="nc">Thread</span><span class="o">.</span><span class="na">currentThread</span><span class="o">().</span><span class="na">getName</span><span class="o">()</span> <span class="o">+</span> <span class="s">" Receive New Messages: "</span> <span class="o">+</span> <span class="n">msgs</span> <span class="o"> [...]
<span class="k">this</span><span class="o">.</span><span class="na">consumeTimes</span><span class="o">.</span><span class="na">incrementAndGet</span><span class="o">();</span>
<span class="k">if</span> <span class="o">((</span><span class="k">this</span><span class="o">.</span><span class="na">consumeTimes</span><span class="o">.</span><span class="na">get</span><span class="o">()</span> <span class="o">%</span> <span class="mi">2</span><span class="o">)</span> <span class="o">==</span> <span class="mi">0</span><span class="o">)</span> <span class="o">{</span>
- <span class="k">return</span> <span class="n">ConsumeOrderlyStatus</span><span class="o">.</span><span class="na">SUCCESS</span><span class="o">;</span>
+ <span class="k">return</span> <span class="nc">ConsumeOrderlyStatus</span><span class="o">.</span><span class="na">SUCCESS</span><span class="o">;</span>
<span class="o">}</span> <span class="k">else</span> <span class="k">if</span> <span class="o">((</span><span class="k">this</span><span class="o">.</span><span class="na">consumeTimes</span><span class="o">.</span><span class="na">get</span><span class="o">()</span> <span class="o">%</span> <span class="mi">3</span><span class="o">)</span> <span class="o">==</span> <span class="mi">0</span><span class="o">)</span> <span class="o">{</span>
- <span class="k">return</span> <span class="n">ConsumeOrderlyStatus</span><span class="o">.</span><span class="na">ROLLBACK</span><span class="o">;</span>
+ <span class="k">return</span> <span class="nc">ConsumeOrderlyStatus</span><span class="o">.</span><span class="na">ROLLBACK</span><span class="o">;</span>
<span class="o">}</span> <span class="k">else</span> <span class="k">if</span> <span class="o">((</span><span class="k">this</span><span class="o">.</span><span class="na">consumeTimes</span><span class="o">.</span><span class="na">get</span><span class="o">()</span> <span class="o">%</span> <span class="mi">4</span><span class="o">)</span> <span class="o">==</span> <span class="mi">0</span><span class="o">)</span> <span class="o">{</span>
- <span class="k">return</span> <span class="n">ConsumeOrderlyStatus</span><span class="o">.</span><span class="na">COMMIT</span><span class="o">;</span>
+ <span class="k">return</span> <span class="nc">ConsumeOrderlyStatus</span><span class="o">.</span><span class="na">COMMIT</span><span class="o">;</span>
<span class="o">}</span> <span class="k">else</span> <span class="k">if</span> <span class="o">((</span><span class="k">this</span><span class="o">.</span><span class="na">consumeTimes</span><span class="o">.</span><span class="na">get</span><span class="o">()</span> <span class="o">%</span> <span class="mi">5</span><span class="o">)</span> <span class="o">==</span> <span class="mi">0</span><span class="o">)</span> <span class="o">{</span>
<span class="n">context</span><span class="o">.</span><span class="na">setSuspendCurrentQueueTimeMillis</span><span class="o">(</span><span class="mi">3000</span><span class="o">);</span>
- <span class="k">return</span> <span class="n">ConsumeOrderlyStatus</span><span class="o">.</span><span class="na">SUSPEND_CURRENT_QUEUE_A_MOMENT</span><span class="o">;</span>
+ <span class="k">return</span> <span class="nc">ConsumeOrderlyStatus</span><span class="o">.</span><span class="na">SUSPEND_CURRENT_QUEUE_A_MOMENT</span><span class="o">;</span>
<span class="o">}</span>
- <span class="k">return</span> <span class="n">ConsumeOrderlyStatus</span><span class="o">.</span><span class="na">SUCCESS</span><span class="o">;</span>
+ <span class="k">return</span> <span class="nc">ConsumeOrderlyStatus</span><span class="o">.</span><span class="na">SUCCESS</span><span class="o">;</span>
<span class="o">}</span>
<span class="o">});</span>
<span class="n">consumer</span><span class="o">.</span><span class="na">start</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">"Consumer Started.%n"</span><span class="o">);</span>
+ <span class="nc">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">"Consumer Started.%n"</span><span class="o">);</span>
<span class="o">}</span>
<span class="o">}</span>
</code></pre></div></div>
@@ -567,7 +567,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>
diff --git a/content/docs/pull-request/index.html b/content/docs/pull-request/index.html
index 5daf151..a8fa448 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="2019-08-05T10:42:32+08:00">
+ <meta property="article:published_time" content="2019-08-13T20:57:29+08:00">
@@ -459,7 +459,7 @@
<meta itemprop="headline" content="How to manage Pull Request">
<meta itemprop="description" content="This page guides you through Git setup and contribution process.">
- <meta itemprop="dateModified" content="December 25, 2016">
+ <meta itemprop="dateModified" content="December 24, 2016">
<div class="page__inner-wrap">
@@ -614,7 +614,7 @@ git push apache master
- <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>
diff --git a/content/docs/quick-start/index.html b/content/docs/quick-start/index.html
index cf57423..bc5233d 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="2019-08-05T10:42:32+08:00">
+ <meta property="article:published_time" content="2019-08-13T20:57:29+08:00">
@@ -459,7 +459,7 @@
<meta itemprop="headline" content="Quick Start">
<meta itemprop="description" content="How to quickly install and setup Apache RocketMQ.">
- <meta itemprop="dateModified" content="December 30, 2016">
+ <meta itemprop="dateModified" content="December 29, 2016">
<div class="page__inner-wrap">
@@ -558,7 +558,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>
diff --git a/content/docs/release-manual.html b/content/docs/release-manual.html
index 8f8c9ff..de3d37e 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="2019-08-05T10:42:32+08:00">
+ <meta property="article:published_time" content="2019-08-13T20:57:29+08:00">
@@ -459,7 +459,7 @@
<meta itemprop="headline" content="Release Manual">
<meta itemprop="description" content="Apache RocketMQ Release Manual">
- <meta itemprop="dateModified" content="February 08, 2017">
+ <meta itemprop="dateModified" content="February 07, 2017">
<div class="page__inner-wrap">
@@ -585,7 +585,7 @@
<h4 id="21-check-the-mqversion">2.1 Check the MQVersion</h4>
<p>Remember to check the current version of MQVersion again, which should be equal to this released version like <code class="highlighter-rouge">release-4.5.0</code>.</p>
-<div class="language-java highlighter-rouge"><div class="highlight"><pre class="highlight"><code> <span class="kd">public</span> <span class="kd">static</span> <span class="kd">final</span> <span class="kt">int</span> <span class="n">CURRENT_VERSION</span> <span class="o">=</span> <span class="n">Version</span><span class="o">.</span><span class="na">V4_5_0</span><span class="o">.</span><span class="na">ordinal</span><span class="o">();</span>
+<div class="language-java highlighter-rouge"><div class="highlight"><pre class="highlight"><code> <span class="kd">public</span> <span class="kd">static</span> <span class="kd">final</span> <span class="kt">int</span> <span class="no">CURRENT_VERSION</span> <span class="o">=</span> <span class="nc">Version</span><span class="o">.</span><span class="na">V4_5_0</span><span class="o">.</span><span class="na">ordinal</span><span class="o">();</span>
</code></pre></div></div>
<h4 id="22-release-to-the-maven-repository">2.2 Release to the maven repository</h4>
@@ -800,7 +800,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>
diff --git a/content/docs/rmq-arc/index.html b/content/docs/rmq-arc/index.html
index c28fc94..30d11b6 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="2019-08-05T10:42:32+08:00">
+ <meta property="article:published_time" content="2019-08-13T20:57:29+08:00">
@@ -459,7 +459,7 @@
<meta itemprop="headline" content="RocketMQ Architecture">
<meta itemprop="description" content="The main Architecture of Apache RocketMQ.">
- <meta itemprop="dateModified" content="April 25, 2017">
+ <meta itemprop="dateModified" content="April 24, 2017">
<div class="page__inner-wrap">
@@ -554,7 +554,7 @@ RocketMQ’s website provides a simple quick-start guide to interested users.</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>
diff --git a/content/docs/rmq-deployment/index.html b/content/docs/rmq-deployment/index.html
index 07bb8ab..3264cf2 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="2019-08-05T10:42:32+08:00">
+ <meta property="article:published_time" content="2019-08-13T20:57:29+08:00">
@@ -459,7 +459,7 @@
<meta itemprop="headline" content="Deployment">
<meta itemprop="description" content="How to deploy the Apache RocketMQ.">
- <meta itemprop="dateModified" content="April 25, 2017">
+ <meta itemprop="dateModified" content="April 24, 2017">
<div class="page__inner-wrap">
@@ -614,55 +614,55 @@
<p>Change directory to ${PACKAGE}/bin, command bash mqadmin, you should see the following help menu:</p>
-<div class="language-java highlighter-rouge"><div class="highlight"><pre class="highlight"><code><span class="n">The</span> <span class="n">most</span> <span class="n">commonly</span> <span class="n">used</span> <span class="n">mqadmin</span> <span class="n">commands</span> <span class="nl">are:</span>
- <span class="n">updateTopic</span> <span class="n">Update</span> <span class="n">or</span> <span class="n">create</span> <span class="n">topic</span>
- <span class="n">deleteTopic</span> <span class="n">Delete</span> <span class="n">topic</span> <span class="n">from</span> <span class="n">broker</span> <span class="n">and</span> <span class="n">NameServer</span>
- <span class="n">updateSubGroup</span> <span class="n">Update</span> <span class="n">or</span> <span class="n">create</span> <span class="n">subscription</span> <span class="n">group</span>
- <span class="n">deleteSubGroup</span> <span class="n">Delete</span> <span class="n">subscription</span> <span class="n">group</span> <span class="n">from</span> <span class="n">broker</span>
- <span class="n">updateBrokerConfig</span> <span class="n">Update</span> <span class="n">broker</span><span class="err">'</span><span class="n">s</span> <span class="n">config</span>
- <span class="n">updateTopicPerm</span> <span class="n">Update</span> <span class="n">topic</span> <span class="n">perm</span>
- <span class="n">topicRoute</span> <span class="n">Examine</span> <span class="n">topic</span> <span class="n">route</span> <span class="n">info</span>
- <span class="n">topicStatus</span> <span class="n">Examine</span> <span class="n">topic</span> <span class="n">Status</span> <span class="n">info</span>
+<div class="language-java highlighter-rouge"><div class="highlight"><pre class="highlight"><code><span class="nc">The</span> <span class="n">most</span> <span class="n">commonly</span> <span class="n">used</span> <span class="n">mqadmin</span> <span class="n">commands</span> <span class="nl">are:</span>
+ <span class="n">updateTopic</span> <span class="nc">Update</span> <span class="n">or</span> <span class="n">create</span> <span class="n">topic</span>
+ <span class="n">deleteTopic</span> <span class="nc">Delete</span> <span class="n">topic</span> <span class="n">from</span> <span class="n">broker</span> <span class="n">and</span> <span class="nc">NameServer</span>
+ <span class="n">updateSubGroup</span> <span class="nc">Update</span> <span class="n">or</span> <span class="n">create</span> <span class="n">subscription</span> <span class="n">group</span>
+ <span class="n">deleteSubGroup</span> <span class="nc">Delete</span> <span class="n">subscription</span> <span class="n">group</span> <span class="n">from</span> <span class="n">broker</span>
+ <span class="n">updateBrokerConfig</span> <span class="nc">Update</span> <span class="n">broker</span><span class="err">'</span><span class="n">s</span> <span class="n">config</span>
+ <span class="n">updateTopicPerm</span> <span class="nc">Update</span> <span class="n">topic</span> <span class="n">perm</span>
+ <span class="n">topicRoute</span> <span class="nc">Examine</span> <span class="n">topic</span> <span class="n">route</span> <span class="n">info</span>
+ <span class="n">topicStatus</span> <span class="nc">Examine</span> <span class="n">topic</span> <span class="nc">Status</span> <span class="n">info</span>
<span class="n">topicClusterList</span> <span class="n">get</span> <span class="n">cluster</span> <span class="n">info</span> <span class="k">for</span> <span class="n">topic</span>
- <span class="n">brokerStatus</span> <span class="n">Fetch</span> <span class="n">broker</span> <span class="n">runtime</span> <span class="n">status</span> <span class="n">data</span>
- <span class="n">queryMsgById</span> <span class="n">Query</span> <span class="n">Message</span> <span class="n">by</span> <span class="n">Id</span>
- <span class="n">queryMsgByKey</span> <span class="n">Query</span> <span class="n">Message</span> <span class="n">by</span> <span class="n">Key</span>
- <span class="n">queryMsgByUniqueKey</span> <span class="n">Query</span> <span class="n">Message</span> <span class="n">by</span> <span class="n">Unique</span> <span class="n">key</span>
- <span class="n">queryMsgByOffset</span> <span class="n">Query</span> <span class="n">Message</span> <span class="n">by</span> <span class="n">offset</span>
- <span class="n">queryMsgByUniqueKey</span> <span class="n">Query</span> <span class="n">Message</span> <span class="n">by</span> <span class="n">Unique</span> <span class="n">key</span>
- <span class="n">printMsg</span> <span class="n">Print</span> <span class="n">Message</span> <span class="n">Detail</span>
- <span class="n">sendMsgStatus</span> <span class="n">Send</span> <span class="n">msg</span> <span class="n">to</span> <span class="n">broker</span>
- <span class="n">brokerConsumeStats</span> <span class="n">Fetch</span> <span class="n">broker</span> <span class="n">consume</span> <span class="n">stats</span> <span class="n">data</span>
- <span class="n">producerConnection</span> <span class="n">Query</span> <span class="n">producer</span><span class="err">'</span><span class="n">s</span> <span class="n">socket</span> <span class="n">connection</span> <span class="n">and</span> <span class="n">client</span> <span class="n">version</span>
- <span class="n">consumerConnection</span> <span class="n">Query</span> <span class="n">consumer</span><span class="err">'</span><span class="n">s</span> <span class="n">socket</span> <span class="n">connection</span><span class="o">,</span> <span class="n">client</span> <span class="n">version</span> <span class="n">and</span> <span class="n">subscription</span>
- <span class="n">consumerProgress</span> <span class="n">Query</span> <span class="n">consumers</span><span class="err">'</span><span class="n">s</span> <span class="n">progress</span><span class="o">,</span> <span class="n">speed</span>
- <span class="n">consumerStatus</span> <span class="n">Query</span> <span class="n">consumer</span><span class="err">'</span><span class="n">s</span> <span class="n">internal</span> <span class="n">data</span> <span class="n">structure</span>
- <span class="n">cloneGroupOffset</span> <span class="n">Clone</span> <span class="n">offset</span> <span class="n">from</span> <span class="n">other</span> <span class="n">group</span>
- <span class="n">clusterList</span> <span class="n">List</span> <span class="n">all</span> <span class="n">of</span> <span class="n">clusters</span>
- <span class="n">topicList</span> <span class="n">Fetch</span> <span class="n">all</span> <span class="n">topic</span> <span class="n">list</span> <span class="n">from</span> <span class="n">name</span> <span class="n">server</span>
- <span class="n">updateKvConfig</span> <span class="n">Create</span> <span class="n">or</span> <span class="n">update</span> <span class="n">KV</span> <span class="n">config</span>
- <span class="n">deleteKvConfig</span> <span class="n">Delete</span> <span class="n">KV</span> <span class="n">config</span>
- <span class="n">wipeWritePerm</span> <span class="n">Wipe</span> <span class="n">write</span> <span class="n">perm</span> <span class="n">of</span> <span class="n">broker</span> <span class="n">in</span> <span class="n">all</span> <span class="n">name</span> <span class="n">server</span>
- <span class="n">resetOffsetByTime</span> <span class="n">Reset</span> <span class="n">consumer</span> <span class="n">offset</span> <span class="n">by</span> <span class="nf">timestamp</span><span class="o">(</span><span class="n">without</span> <span class="n">client</span> <span class="n">restart</span><span class="o">)</span>
- <span class="n">updateOrderConf</span> <span class="n">Create</span> <span class="n">or</span> <span class="n">update</span> <span class="n">or</span> <span class="n">delete</span> <span class="n">order</span> <span class="n">conf</span>
- <span class="n">cleanExpiredCQ</span> <span class="n">Clean</span> <span class="n">expired</span> <span class="n">ConsumeQueue</span> <span class="n">on</span> <span class="n">broker</span><span class="o">.</span>
- <span class="n">cleanUnusedTopic</span> <span class="n">Clean</span> <span class="n">unused</span> <span class="n">topic</span> <span class="n">on</span> <span class="n">broker</span>
- <span class="n">startMonitoring</span> <span class="n">Start</span> <span class="n">Monitoring</span>
- <span class="n">statsAll</span> <span class="n">Topic</span> <span class="n">and</span> <span class="n">Consumer</span> <span class="n">tps</span> <span class="n">stats</span>
- <span class="n">syncDocs</span> <span class="n">Synchronize</span> <span class="n">wiki</span> <span class="n">and</span> <span class="n">issue</span> <span class="n">to</span> <span class="n">github</span><span class="o">.</span><span class="na">com</span>
- <span class="n">allocateMQ</span> <span class="n">Allocate</span> <span class="n">MQ</span>
- <span class="n">checkMsgSendRT</span> <span class="n">Check</span> <span class="n">message</span> <span class="n">send</span> <span class="n">response</span> <span class="n">time</span>
- <span class="n">clusterRT</span> <span class="n">List</span> <span class="n">All</span> <span class="n">clusters</span> <span class="n">Message</span> <span class="n">Send</span> <span class="n">RT</span>
+ <span class="n">brokerStatus</span> <span class="nc">Fetch</span> <span class="n">broker</span> <span class="n">runtime</span> <span class="n">status</span> <span class="n">data</span>
+ <span class="n">queryMsgById</span> <span class="nc">Query</span> <span class="nc">Message</span> <span class="n">by</span> <span class="nc">Id</span>
+ <span class="n">queryMsgByKey</span> <span class="nc">Query</span> <span class="nc">Message</span> <span class="n">by</span> <span class="nc">Key</span>
+ <span class="n">queryMsgByUniqueKey</span> <span class="nc">Query</span> <span class="nc">Message</span> <span class="n">by</span> <span class="nc">Unique</span> <span class="n">key</span>
+ <span class="n">queryMsgByOffset</span> <span class="nc">Query</span> <span class="nc">Message</span> <span class="n">by</span> <span class="n">offset</span>
+ <span class="n">queryMsgByUniqueKey</span> <span class="nc">Query</span> <span class="nc">Message</span> <span class="n">by</span> <span class="nc">Unique</span> <span class="n">key</span>
+ <span class="n">printMsg</span> <span class="nc">Print</span> <span class="nc">Message</span> <span class="nc">Detail</span>
+ <span class="n">sendMsgStatus</span> <span class="nc">Send</span> <span class="n">msg</span> <span class="n">to</span> <span class="n">broker</span>
+ <span class="n">brokerConsumeStats</span> <span class="nc">Fetch</span> <span class="n">broker</span> <span class="n">consume</span> <span class="n">stats</span> <span class="n">data</span>
+ <span class="n">producerConnection</span> <span class="nc">Query</span> <span class="n">producer</span><span class="err">'</span><span class="n">s</span> <span class="n">socket</span> <span class="n">connection</span> <span class="n">and</span> <span class="n">client</span> <span class="n">version</span>
+ <span class="n">consumerConnection</span> <span class="nc">Query</span> <span class="n">consumer</span><span class="err">'</span><span class="n">s</span> <span class="n">socket</span> <span class="n">connection</span><span class="o">,</span> <span class="n">client</span> <span class="n">version</span> <span class="n">and</span> <span class="n">subscription</span>
+ <span class="n">consumerProgress</span> <span class="nc">Query</span> <span class="n">consumers</span><span class="err">'</span><span class="n">s</span> <span class="n">progress</span><span class="o">,</span> <span class="n">speed</span>
+ <span class="n">consumerStatus</span> <span class="nc">Query</span> <span class="n">consumer</span><span class="err">'</span><span class="n">s</span> <span class="n">internal</span> <span class="n">data</span> <span class="n">structure</span>
+ <span class="n">cloneGroupOffset</span> <span class="nc">Clone</span> <span class="n">offset</span> <span class="n">from</span> <span class="n">other</span> <span class="n">group</span>
+ <span class="n">clusterList</span> <span class="nc">List</span> <span class="n">all</span> <span class="n">of</span> <span class="n">clusters</span>
+ <span class="n">topicList</span> <span class="nc">Fetch</span> <span class="n">all</span> <span class="n">topic</span> <span class="n">list</span> <span class="n">from</span> <span class="n">name</span> <span class="n">server</span>
+ <span class="n">updateKvConfig</span> <span class="nc">Create</span> <span class="n">or</span> <span class="n">update</span> <span class="no">KV</span> <span class="n">config</span>
+ <span class="n">deleteKvConfig</span> <span class="nc">Delete</span> <span class="no">KV</span> <span class="n">config</span>
+ <span class="n">wipeWritePerm</span> <span class="nc">Wipe</span> <span class="n">write</span> <span class="n">perm</span> <span class="n">of</span> <span class="n">broker</span> <span class="n">in</span> <span class="n">all</span> <span class="n">name</span> <span class="n">server</span>
+ <span class="n">resetOffsetByTime</span> <span class="nc">Reset</span> <span class="n">consumer</span> <span class="n">offset</span> <span class="n">by</span> <span class="nf">timestamp</span><span class="o">(</span><span class="n">without</span> <span class="n">client</span> <span class="n">restart</span><span class="o">)</span>
+ <span class="n">updateOrderConf</span> <span class="nc">Create</span> <span class="n">or</span> <span class="n">update</span> <span class="n">or</span> <span class="n">delete</span> <span class="n">order</span> <span class="n">conf</span>
+ <span class="n">cleanExpiredCQ</span> <span class="nc">Clean</span> <span class="n">expired</span> <span class="nc">ConsumeQueue</span> <span class="n">on</span> <span class="n">broker</span><span class="o">.</span>
+ <span class="n">cleanUnusedTopic</span> <span class="nc">Clean</span> <span class="n">unused</span> <span class="n">topic</span> <span class="n">on</span> <span class="n">broker</span>
+ <span class="n">startMonitoring</span> <span class="nc">Start</span> <span class="nc">Monitoring</span>
+ <span class="n">statsAll</span> <span class="nc">Topic</span> <span class="n">and</span> <span class="nc">Consumer</span> <span class="n">tps</span> <span class="n">stats</span>
+ <span class="n">syncDocs</span> <span class="nc">Synchronize</span> <span class="n">wiki</span> <span class="n">and</span> <span class="n">issue</span> <span class="n">to</span> <span class="n">github</span><span class="o">.</span><span class="na">com</span>
+ <span class="n">allocateMQ</span> <span class="nc">Allocate</span> <span class="no">MQ</span>
+ <span class="n">checkMsgSendRT</span> <span class="nc">Check</span> <span class="n">message</span> <span class="n">send</span> <span class="n">response</span> <span class="n">time</span>
+ <span class="n">clusterRT</span> <span class="nc">List</span> <span class="nc">All</span> <span class="n">clusters</span> <span class="nc">Message</span> <span class="nc">Send</span> <span class="no">RT</span>
</code></pre></div></div>
<p>See ‘mqadmin help <command />’ for more information on a specific command.
If you want to get more information about a specific command like ‘clusterList’, just type bash mqadmin help clusterList and you will see:</p>
<div class="language-java highlighter-rouge"><div class="highlight"><pre class="highlight"><code><span class="nl">usage:</span> <span class="n">mqadmin</span> <span class="n">clusterList</span> <span class="o">[-</span><span class="n">h</span><span class="o">]</span> <span class="o">[-</span><span class="n">i</span> <span class="o"><</span><span class="n">arg</span><span class="o">>]</span> <span class="o">[-</span><span class="n">m</span><span class="o">]</span> <span class="o">[- [...]
- <span class="o">-</span><span class="n">h</span><span class="o">,--</span><span class="n">help</span> <span class="n">Print</span> <span class="n">help</span>
+ <span class="o">-</span><span class="n">h</span><span class="o">,--</span><span class="n">help</span> <span class="nc">Print</span> <span class="n">help</span>
<span class="o">-</span><span class="n">i</span><span class="o">,--</span><span class="n">interval</span> <span class="o"><</span><span class="n">arg</span><span class="o">></span> <span class="n">specify</span> <span class="n">intervals</span> <span class="n">numbers</span><span class="o">,</span> <span class="n">it</span> <span class="n">is</span> <span class="n">in</span> <span class="n">seconds</span>
- <span class="o">-</span><span class="n">m</span><span class="o">,--</span><span class="n">moreStats</span> <span class="n">Print</span> <span class="n">more</span> <span class="n">stats</span>
- <span class="o">-</span><span class="n">n</span><span class="o">,--</span><span class="n">namesrvAddr</span> <span class="o"><</span><span class="n">arg</span><span class="o">></span> <span class="n">Name</span> <span class="n">server</span> <span class="n">address</span> <span class="n">list</span><span class="o">,</span> <span class="nl">eg:</span> <span class="mf">192.168</span><span class="o">.</span><span class="mf">0.1</span><span class="o">:</span><span class="mi">9876</s [...]
+ <span class="o">-</span><span class="n">m</span><span class="o">,--</span><span class="n">moreStats</span> <span class="nc">Print</span> <span class="n">more</span> <span class="n">stats</span>
+ <span class="o">-</span><span class="n">n</span><span class="o">,--</span><span class="n">namesrvAddr</span> <span class="o"><</span><span class="n">arg</span><span class="o">></span> <span class="nc">Name</span> <span class="n">server</span> <span class="n">address</span> <span class="n">list</span><span class="o">,</span> <span class="nl">eg:</span> <span class="mf">192.168</span><span class="o">.</span><span class="mf">0.1</span><span class="o">:</span><span class="mi">9876</ [...]
</code></pre></div></div>
<h3 id="replication-mode">Replication mode</h3>
@@ -691,8 +691,8 @@ If you want to get more information about a specific command like ‘clusterList
<span class="o">></span><span class="n">bash</span> <span class="n">mqbroker</span> <span class="o">-</span><span class="n">c</span> <span class="o">../</span><span class="n">conf</span><span class="o">/</span><span class="mi">2</span><span class="n">m</span><span class="o">-</span><span class="mi">2</span><span class="n">s</span><span class="o">-</span><span class="n">sync</span><span class="o">/</span><span class="n">broker</span><span class="o">-</span><span class="n">a</span><span [...]
<span class="o">></span><span class="n">bash</span> <span class="n">mqbroker</span> <span class="o">-</span><span class="n">c</span> <span class="o">../</span><span class="n">conf</span><span class="o">/</span><span class="mi">2</span><span class="n">m</span><span class="o">-</span><span class="mi">2</span><span class="n">s</span><span class="o">-</span><span class="n">sync</span><span class="o">/</span><span class="n">broker</span><span class="o">-</span><span class="n">b</span><span [...]
<span class="o">></span><span class="n">bash</span> <span class="n">mqbroker</span> <span class="o">-</span><span class="n">c</span> <span class="o">../</span><span class="n">conf</span><span class="o">/</span><span class="mi">2</span><span class="n">m</span><span class="o">-</span><span class="mi">2</span><span class="n">s</span><span class="o">-</span><span class="n">sync</span><span class="o">/</span><span class="n">broker</span><span class="o">-</span><span class="n">b</span><span [...]
-<span class="n">How</span> <span class="n">to</span> <span class="n">verify</span>
-<span class="n">Execute</span> <span class="n">the</span> <span class="n">following</span> <span class="n">command</span> <span class="n">to</span> <span class="n">verify</span> <span class="n">according</span> <span class="n">to</span> <span class="n">the</span> <span class="n">CLI</span> <span class="nl">section:</span>
+<span class="nc">How</span> <span class="n">to</span> <span class="n">verify</span>
+<span class="nc">Execute</span> <span class="n">the</span> <span class="n">following</span> <span class="n">command</span> <span class="n">to</span> <span class="n">verify</span> <span class="n">according</span> <span class="n">to</span> <span class="n">the</span> <span class="no">CLI</span> <span class="nl">section:</span>
<span class="o">></span> <span class="n">bash</span> <span class="n">mqadmin</span> <span class="n">clusterlist</span>
</code></pre></div></div>
@@ -706,7 +706,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>
diff --git a/content/docs/roadmap/index.html b/content/docs/roadmap/index.html
index 9470eef..72f6387 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="2019-08-05T10:42:32+08:00">
+ <meta property="article:published_time" content="2019-08-13T20:57:29+08:00">
@@ -459,7 +459,7 @@
<meta itemprop="headline" content="The RoadMap of Apache RocketMQ">
<meta itemprop="description" content="4.1.0~4.3.0-incubating RoadMap:">
- <meta itemprop="dateModified" content="March 08, 2017">
+ <meta itemprop="dateModified" content="March 07, 2017">
<div class="page__inner-wrap">
@@ -581,7 +581,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>
diff --git a/content/docs/schedule-example/index.html b/content/docs/schedule-example/index.html
index b7a13d6..6b56b25 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="2019-08-05T10:42:32+08:00">
+ <meta property="article:published_time" content="2019-08-13T20:57:29+08:00">
@@ -459,7 +459,7 @@
<meta itemprop="headline" content="Schedule example">
<meta itemprop="description" content="How to use schedule component to reduce pull in RocketMQ.">
- <meta itemprop="dateModified" content="April 25, 2017">
+ <meta itemprop="dateModified" content="April 24, 2017">
<div class="page__inner-wrap">
@@ -501,21 +501,21 @@
<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="kd">public</span> <span class="kd">static</span> <span class="kt">void</span> <span class="nf">main</span><span class="o">(</span><span class="nc">String</span><span class="o">[]</span> <span class="n">args</span><span class="o">)</span> <span class="kd">throws</span> <span class="nc">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="nc">DefaultMQPushConsumer</span> <span class="n">consumer</span> <span class="o">=</span> <span class="k">new</span> <span class="nc">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="n">consumer</span><span class="o">.</span><span class="na">registerMessageListener</span><span class="o">(</span><span class="k">new</span> <span class="nc">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="kd">public</span> <span class="nc">ConsumeConcurrentlyStatus</span> <span class="nf">consumeMessage</span><span class="o">(</span><span class="nc">List</span><span class="o"><</span><span class="nc">MessageExt</span><span class="o">></span> <span class="n">messages</span><span class="o">,</span> <span class="nc">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="nc">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="nc">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="nc">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="k">return</span> <span class="nc">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>
@@ -532,14 +532,14 @@
<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="kd">public</span> <span class="kd">static</span> <span class="kt">void</span> <span class="nf">main</span><span class="o">(</span><span class="nc">String</span><span class="o">[]</span> <span class="n">args</span><span class="o">)</span> <span class="kd">throws</span> <span class="nc">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="nc">DefaultMQProducer</span> <span class="n">producer</span> <span class="o">=</span> <span class="k">new</span> <span class="nc">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="nc">Message</span> <span class="n">message</span> <span class="o">=</span> <span class="k">new</span> <span class="nc">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>
@@ -569,7 +569,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>
diff --git a/content/docs/simple-example/index.html b/content/docs/simple-example/index.html
index 5c2ef0e..4452e51 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="2019-08-05T10:42:32+08:00">
+ <meta property="article:published_time" content="2019-08-13T20:57:29+08:00">
@@ -459,7 +459,7 @@
<meta itemprop="headline" content="Simple Message Example">
<meta itemprop="description" content="How to send simple message to reduce pull in RocketMQ.">
- <meta itemprop="dateModified" content="April 25, 2017">
+ <meta itemprop="dateModified" content="April 24, 2017">
<div class="page__inner-wrap">
@@ -513,24 +513,24 @@ asynchronous, and one-way transmission.</li>
important notification messages, SMS notification, SMS marketing system, etc..</p>
<div class="language-java highlighter-rouge"><div class="highlight"><pre class="highlight"><code><span class="kd">public</span> <span class="kd">class</span> <span class="nc">SyncProducer</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="kd">public</span> <span class="kd">static</span> <span class="kt">void</span> <span class="nf">main</span><span class="o">(</span><span class="nc">String</span><span class="o">[]</span> <span class="n">args</span><span class="o">)</span> <span class="kd">throws</span> <span class="nc">Exception</span> <span class="o">{</span>
<span class="c1">//Instantiate with a producer group name.</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">"please_rename_unique_group_name"</span><span class="o">);</span>
+ <span class="nc">DefaultMQProducer</span> <span class="n">producer</span> <span class="o">=</span> <span class="k">new</span>
+ <span class="nc">DefaultMQProducer</span><span class="o">(</span><span class="s">"please_rename_unique_group_name"</span><span class="o">);</span>
<span class="c1">// Specify name server addresses.</span>
<span class="n">producer</span><span class="o">.</span><span class="na">setNamesrvAddr</span><span class="o">(</span><span class="s">"localhost:9876"</span><span class="o">);</span>
<span class="c1">//Launch the instance.</span>
<span class="n">producer</span><span class="o">.</span><span class="na">start</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="mi">100</span><span class="o">;</span> <span class="n">i</span><span class="o">++)</span> <span class="o">{</span>
<span class="c1">//Create a message instance, specifying topic, tag and message body.</span>
- <span class="n">Message</span> <span class="n">msg</span> <span class="o">=</span> <span class="k">new</span> <span class="n">Message</span><span class="o">(</span><span class="s">"TopicTest"</span> <span class="cm">/* Topic */</span><span class="o">,</span>
+ <span class="nc">Message</span> <span class="n">msg</span> <span class="o">=</span> <span class="k">new</span> <span class="nc">Message</span><span class="o">(</span><span class="s">"TopicTest"</span> <span class="cm">/* Topic */</span><span class="o">,</span>
<span class="s">"TagA"</span> <span class="cm">/* Tag */</span><span class="o">,</span>
<span class="o">(</span><span class="s">"Hello RocketMQ "</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="n">RemotingHelper</span><span class="o">.</span><span class="na">DEFAULT_CHARSET</span><span class="o">)</span> <span class="cm">/* Message body */</span>
+ <span class="n">i</span><span class="o">).</span><span class="na">getBytes</span><span class="o">(</span><span class="nc">RemotingHelper</span><span class="o">.</span><span class="na">DEFAULT_CHARSET</span><span class="o">)</span> <span class="cm">/* Message body */</span>
<span class="o">);</span>
<span class="c1">//Call send message to deliver message to one of brokers.</span>
- <span class="n">SendResult</span> <span class="n">sendResult</span> <span class="o">=</span> <span class="n">producer</span><span class="o">.</span><span class="na">send</span><span class="o">(</span><span class="n">msg</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">sendResult</span><span class="o">);</span>
+ <span class="nc">SendResult</span> <span class="n">sendResult</span> <span class="o">=</span> <span class="n">producer</span><span class="o">.</span><span class="na">send</span><span class="o">(</span><span class="n">msg</span><span class="o">);</span>
+ <span class="nc">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">sendResult</span><span class="o">);</span>
<span class="o">}</span>
<span class="c1">//Shut down once the producer instance is not longer in use.</span>
<span class="n">producer</span><span class="o">.</span><span class="na">shutdown</span><span class="o">();</span>
@@ -543,9 +543,9 @@ important notification messages, SMS notification, SMS marketing system, etc..</
<p>Asynchronous transmission is generally used in response time sensitive business scenarios.</p>
<div class="language-java highlighter-rouge"><div class="highlight"><pre class="highlight"><code><span class="kd">public</span> <span class="kd">class</span> <span class="nc">AsyncProducer</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="kd">public</span> <span class="kd">static</span> <span class="kt">void</span> <span class="nf">main</span><span class="o">(</span><span class="nc">String</span><span class="o">[]</span> <span class="n">args</span><span class="o">)</span> <span class="kd">throws</span> <span class="nc">Exception</span> <span class="o">{</span>
<span class="c1">//Instantiate with a producer group name.</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">"please_rename_unique_group_name"</span><span class="o">);</span>
+ <span class="nc">DefaultMQProducer</span> <span class="n">producer</span> <span class="o">=</span> <span class="k">new</span> <span class="nc">DefaultMQProducer</span><span class="o">(</span><span class="s">"please_rename_unique_group_name"</span><span class="o">);</span>
<span class="c1">// Specify name server addresses.</span>
<span class="n">producer</span><span class="o">.</span><span class="na">setNamesrvAddr</span><span class="o">(</span><span class="s">"localhost:9876"</span><span class="o">);</span>
<span class="c1">//Launch the instance.</span>
@@ -554,19 +554,19 @@ important notification messages, SMS notification, SMS marketing system, etc..</
<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="mi">100</span><span class="o">;</span> <span class="n">i</span><span class="o">++)</span> <span class="o">{</span>
<span class="kd">final</span> <span class="kt">int</span> <span class="n">index</span> <span class="o">=</span> <span class="n">i</span><span class="o">;</span>
<span class="c1">//Create a message instance, specifying topic, tag and message body.</span>
- <span class="n">Message</span> <span class="n">msg</span> <span class="o">=</span> <span class="k">new</span> <span class="n">Message</span><span class="o">(</span><span class="s">"TopicTest"</span><span class="o">,</span>
+ <span class="nc">Message</span> <span class="n">msg</span> <span class="o">=</span> <span class="k">new</span> <span class="nc">Message</span><span class="o">(</span><span class="s">"TopicTest"</span><span class="o">,</span>
<span class="s">"TagA"</span><span class="o">,</span>
<span class="s">"OrderID188"</span><span class="o">,</span>
- <span class="s">"Hello world"</span><span class="o">.</span><span class="na">getBytes</span><span class="o">(</span><span class="n">RemotingHelper</span><span class="o">.</span><span class="na">DEFAULT_CHARSET</span><span class="o">));</span>
- <span class="n">producer</span><span class="o">.</span><span class="na">send</span><span class="o">(</span><span class="n">msg</span><span class="o">,</span> <span class="k">new</span> <span class="n">SendCallback</span><span class="o">()</span> <span class="o">{</span>
+ <span class="s">"Hello world"</span><span class="o">.</span><span class="na">getBytes</span><span class="o">(</span><span class="nc">RemotingHelper</span><span class="o">.</span><span class="na">DEFAULT_CHARSET</span><span class="o">));</span>
+ <span class="n">producer</span><span class="o">.</span><span class="na">send</span><span class="o">(</span><span class="n">msg</span><span class="o">,</span> <span class="k">new</span> <span class="nc">SendCallback</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">onSuccess</span><span class="o">(</span><span class="n">SendResult</span> <span class="n">sendResult</span><span class="o">)</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">"%-10d OK %s %n"</span><span class="o">,</span> <span class="n">index</span><span class="o">,</span>
+ <span class="kd">public</span> <span class="kt">void</span> <span class="nf">onSuccess</span><span class="o">(</span><span class="nc">SendResult</span> <span class="n">sendResult</span><span class="o">)</span> <span class="o">{</span>
+ <span class="nc">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">"%-10d OK %s %n"</span><span class="o">,</span> <span class="n">index</span><span class="o">,</span>
<span class="n">sendResult</span><span class="o">.</span><span class="na">getMsgId</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">onException</span><span class="o">(</span><span class="n">Throwable</span> <span class="n">e</span><span class="o">)</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">"%-10d Exception %s %n"</span><span class="o">,</span> <span class="n">index</span><span class="o">,</span> <span class="n">e</span><span class="o">);</span>
+ <span class="kd">public</span> <span class="kt">void</span> <span class="nf">onException</span><span class="o">(</span><span class="nc">Throwable</span> <span class="n">e</span><span class="o">)</span> <span class="o">{</span>
+ <span class="nc">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">"%-10d Exception %s %n"</span><span class="o">,</span> <span class="n">index</span><span class="o">,</span> <span class="n">e</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>
@@ -583,19 +583,19 @@ important notification messages, SMS notification, SMS marketing system, etc..</
such as log collection.</p>
<div class="language-java highlighter-rouge"><div class="highlight"><pre class="highlight"><code><span class="kd">public</span> <span class="kd">class</span> <span class="nc">OnewayProducer</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="kd">public</span> <span class="kd">static</span> <span class="kt">void</span> <span class="nf">main</span><span class="o">(</span><span class="nc">String</span><span class="o">[]</span> <span class="n">args</span><span class="o">)</span> <span class="kd">throws</span> <span class="nc">Exception</span><span class="o">{</span>
<span class="c1">//Instantiate with a producer group name.</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">"please_rename_unique_group_name"</span><span class="o">);</span>
+ <span class="nc">DefaultMQProducer</span> <span class="n">producer</span> <span class="o">=</span> <span class="k">new</span> <span class="nc">DefaultMQProducer</span><span class="o">(</span><span class="s">"please_rename_unique_group_name"</span><span class="o">);</span>
<span class="c1">// Specify name server addresses.</span>
<span class="n">producer</span><span class="o">.</span><span class="na">setNamesrvAddr</span><span class="o">(</span><span class="s">"localhost:9876"</span><span class="o">);</span>
<span class="c1">//Launch the instance.</span>
<span class="n">producer</span><span class="o">.</span><span class="na">start</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="mi">100</span><span class="o">;</span> <span class="n">i</span><span class="o">++)</span> <span class="o">{</span>
<span class="c1">//Create a message instance, specifying topic, tag and message body.</span>
- <span class="n">Message</span> <span class="n">msg</span> <span class="o">=</span> <span class="k">new</span> <span class="n">Message</span><span class="o">(</span><span class="s">"TopicTest"</span> <span class="cm">/* Topic */</span><span class="o">,</span>
+ <span class="nc">Message</span> <span class="n">msg</span> <span class="o">=</span> <span class="k">new</span> <span class="nc">Message</span><span class="o">(</span><span class="s">"TopicTest"</span> <span class="cm">/* Topic */</span><span class="o">,</span>
<span class="s">"TagA"</span> <span class="cm">/* Tag */</span><span class="o">,</span>
<span class="o">(</span><span class="s">"Hello RocketMQ "</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="n">RemotingHelper</span><span class="o">.</span><span class="na">DEFAULT_CHARSET</span><span class="o">)</span> <span class="cm">/* Message body */</span>
+ <span class="n">i</span><span class="o">).</span><span class="na">getBytes</span><span class="o">(</span><span class="nc">RemotingHelper</span><span class="o">.</span><span class="na">DEFAULT_CHARSET</span><span class="o">)</span> <span class="cm">/* Message body */</span>
<span class="o">);</span>
<span class="c1">//Call send message to deliver message to one of brokers.</span>
<span class="n">producer</span><span class="o">.</span><span class="na">sendOneway</span><span class="o">(</span><span class="n">msg</span><span class="o">);</span>
@@ -612,10 +612,10 @@ such as log collection.</p>
<div class="language-java highlighter-rouge"><div class="highlight"><pre class="highlight"><code><span class="kd">public</span> <span class="kd">class</span> <span class="nc">Consumer</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">InterruptedException</span><span class="o">,</span> <span class="n">MQClientException</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="nc">String</span><span class="o">[]</span> <span class="n">args</span><span class="o">)</span> <span class="kd">throws</span> <span class="nc">InterruptedException</span><span class="o">,</span> <span class="nc">MQClientException</span> <span class="o">{</span>
<span class="c1">// Instantiate with specified consumer group name.</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">"please_rename_unique_group_name"</span><span class="o">);</span>
+ <span class="nc">DefaultMQPushConsumer</span> <span class="n">consumer</span> <span class="o">=</span> <span class="k">new</span> <span class="nc">DefaultMQPushConsumer</span><span class="o">(</span><span class="s">"please_rename_unique_group_name"</span><span class="o">);</span>
<span class="c1">// Specify name server addresses.</span>
<span class="n">consumer</span><span class="o">.</span><span class="na">setNamesrvAddr</span><span class="o">(</span><span class="s">"localhost:9876"</span><span class="o">);</span>
@@ -623,20 +623,20 @@ such as log collection.</p>
<span class="c1">// Subscribe one more more topics to consume.</span>
<span class="n">consumer</span><span class="o">.</span><span class="na">subscribe</span><span class="o">(</span><span class="s">"TopicTest"</span><span class="o">,</span> <span class="s">"*"</span><span class="o">);</span>
<span class="c1">// Register callback to execute on arrival of messages fetched from brokers.</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="n">consumer</span><span class="o">.</span><span class="na">registerMessageListener</span><span class="o">(</span><span class="k">new</span> <span class="nc">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">msgs</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="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 Receive New Messages: %s %n"</span><span class="o">,</span> <span class="n">Thread</span><span class="o">.</span><span class="na">currentThread</span><span class="o">().</span><span class="na">getName</span><span class="o">(),</span> <span class="n">msgs</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="kd">public</span> <span class="nc">ConsumeConcurrentlyStatus</span> <span class="nf">consumeMessage</span><span class="o">(</span><span class="nc">List</span><span class="o"><</span><span class="nc">MessageExt</span><span class="o">></span> <span class="n">msgs</span><span class="o">,</span>
+ <span class="nc">ConsumeConcurrentlyContext</span> <span class="n">context</span><span class="o">)</span> <span class="o">{</span>
+ <span class="nc">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 Receive New Messages: %s %n"</span><span class="o">,</span> <span class="nc">Thread</span><span class="o">.</span><span class="na">currentThread</span><span class="o">().</span><span class="na">getName</span><span class="o">(),</span> <span class="n">msgs</span><span class="o">);</span>
+ <span class="k">return</span> <span class="nc">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 the consumer instance.</span>
<span class="n">consumer</span><span class="o">.</span><span class="na">start</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">"Consumer Started.%n"</span><span class="o">);</span>
+ <span class="nc">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">"Consumer Started.%n"</span><span class="o">);</span>
<span class="o">}</span>
<span class="o">}</span>
</code></pre></div></div>
@@ -655,7 +655,7 @@ https://github.com/apache/rocketmq/tree/master/example</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>
diff --git a/content/docs/system-config/index.html b/content/docs/system-config/index.html
index 7608dfd..e81db3e 100644
--- a/content/docs/system-config/index.html
+++ b/content/docs/system-config/index.html
@@ -57,7 +57,7 @@
<meta property="og:type" content="article">
- <meta property="article:published_time" content="2019-08-05T10:42:32+08:00">
+ <meta property="article:published_time" content="2019-08-13T20:57:29+08:00">
@@ -459,7 +459,7 @@
<meta itemprop="headline" content="RocketMQ JVM/Linux Configuration">
<meta itemprop="description" content="This is an introduction for configuring RocketMQ broker JVM/OS parameters. It points out certain specified configurations that should be thinking about before deploying RocketMQ cluster.">
- <meta itemprop="dateModified" content="July 15, 2017">
+ <meta itemprop="dateModified" content="July 14, 2017">
<div class="page__inner-wrap">
@@ -554,7 +554,7 @@ may have. RocketMQ will use mmap to load CommitLog and ConsumeQueue, so set a bi
- <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2017-07-15">July 15, 2017</time></p>
+ <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2017-07-14">July 14, 2017</time></p>
</footer>
diff --git a/content/docs/transaction-example/index.html b/content/docs/transaction-example/index.html
index e1fcdda..642e131 100644
--- a/content/docs/transaction-example/index.html
+++ b/content/docs/transaction-example/index.html
@@ -57,7 +57,7 @@
<meta property="og:type" content="article">
- <meta property="article:published_time" content="2019-08-05T10:42:32+08:00">
+ <meta property="article:published_time" content="2019-08-13T20:57:29+08:00">
@@ -459,7 +459,7 @@
<meta itemprop="headline" content="Transaction example">
<meta itemprop="description" content="How to use transactional component to implement eventual consistency in RocketMQ.">
- <meta itemprop="dateModified" content="July 13, 2018">
+ <meta itemprop="dateModified" content="July 12, 2018">
<div class="page__inner-wrap">
@@ -606,7 +606,7 @@ public class TransactionProducer {
- <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2018-07-13">July 13, 2018</time></p>
+ <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2018-07-12">July 12, 2018</time></p>
</footer>
diff --git a/content/dowloading/releases/index.html b/content/dowloading/releases/index.html
index 09afb6b..5b46768 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="2019-08-05T10:42:32+08:00">
+ <meta property="article:published_time" content="2019-08-13T20:57:29+08:00">
@@ -459,7 +459,7 @@
<meta itemprop="headline" content="Downloading the Apache RocketMQ Releases">
<meta itemprop="description" content="Today, more than 100 companies are using the open source version of RocketMQ in their business. We also published a commercial distribution based on RocketMQ, a PaaS product called the Alibaba ONS.Compatibility GuideThe table below shows the supported jre environment for components of each release.">
- <meta itemprop="dateModified" content="May 15, 2019">
+ <meta itemprop="dateModified" content="May 14, 2019">
<div class="page__inner-wrap">
@@ -622,7 +622,7 @@ open source version of RocketMQ in their business. We also published a commercia
- <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2019-05-15">May 15, 2019</time></p>
+ <p class="page__date"><strong><i class="fa fa-fw fa-calendar" aria-hidden="true"></i> Updated:</strong> <time datetime="2019-05-14">May 14, 2019</time></p>
</footer>
diff --git a/content/feed.xml b/content/feed.xml
index da6b15a..68e0106 100644
--- a/content/feed.xml
+++ b/content/feed.xml
@@ -1,4 +1,4 @@
-<?xml version="1.0" encoding="utf-8"?><feed xmlns="http://www.w3.org/2005/Atom" ><generator uri="https://jekyllrb.com/" version="3.8.5">Jekyll</generator><link href="/feed.xml" rel="self" type="application/atom+xml" /><link href="/" rel="alternate" type="text/html" /><updated>2019-08-05T10:42:32+08:00</updated><id>/feed.xml</id><title type="html">Apache RocketMQ</title><subtitle>The homepage of RocketMQ.</subtitle><author><name>{"name"=>nil, "avatar"=>"/ass [...]
+<?xml version="1.0" encoding="utf-8"?><feed xmlns="http://www.w3.org/2005/Atom" ><generator uri="https://jekyllrb.com/" version="3.8.6">Jekyll</generator><link href="/feed.xml" rel="self" type="application/atom+xml" /><link href="/" rel="alternate" type="text/html" /><updated>2019-08-13T20:57:29+08:00</updated><id>/feed.xml</id><title type="html">Apache RocketMQ</title><subtitle>The homepage of RocketMQ.</subtitle><author><name>{"name"=>nil, "avatar"=>"/ass [...]
<h2> Download the 4.5.2 release</h2>
diff --git a/content/index.html b/content/index.html
index 18505c2..c2b612d 100644
--- a/content/index.html
+++ b/content/index.html
@@ -18,7 +18,7 @@
-<meta name="description" content="Apache RocketMQ™ is an open source distributed messaging and streaming data platform. Latest release v4.5.1 ">
+<meta name="description" content="Apache RocketMQ™ is an open source distributed messaging and streaming data platform. Latest release v4.5.2 ">
@@ -30,13 +30,13 @@
- <meta property="og:description" content="Apache RocketMQ™ is an open source distributed messaging and streaming data platform. Latest release v4.5.1 ">
+ <meta property="og:description" content="Apache RocketMQ™ is an open source distributed messaging and streaming data platform. Latest release v4.5.2 ">
<meta name="twitter:site" content="@ApacheRocketMQ">
<meta name="twitter:title" content="Apache RocketMQ">
- <meta name="twitter:description" content="Apache RocketMQ™ is an open source distributed messaging and streaming data platform. Latest release v4.5.1 ">
+ <meta name="twitter:description" content="Apache RocketMQ™ is an open source distributed messaging and streaming data platform. Latest release v4.5.2 ">
<meta name="twitter:url" content="">
@@ -166,7 +166,7 @@
</h1>
- <p class="page__lead">Apache RocketMQ™ is an open source distributed messaging and streaming data platform.<br /> <small><a href="/release_notes/release-notes-4.5.1/">Latest release v4.5.1</a></small><br /><br /> <iframe style="display: inline-block;" src="https://ghbtns.com/github-btn.html?user=apache&repo=rocketmq&type=star&count=true&size=large" frameborder="0" scrolling="0" width="160px" height="30px"></iframe> <iframe style="display: inline-block;" src="https://ghbtns.com/gi [...]
+ <p class="page__lead">Apache RocketMQ™ is an open source distributed messaging and streaming data platform.<br /> <small><a href="/release_notes/release-notes-4.5.2/">Latest release v4.5.2</a></small><br /><br /> <iframe style="display: inline-block;" src="https://ghbtns.com/github-btn.html?user=apache&repo=rocketmq&type=star&count=true&size=large" frameborder="0" scrolling="0" width="160px" height="30px"></iframe> <iframe style="display: inline-block;" src="https://ghbtns.com/gi [...]
</p>
@@ -182,7 +182,7 @@
<div id="main" role="main">
<article class="splash" itemscope itemtype="http://schema.org/CreativeWork">
- <meta itemprop="description" content="Apache RocketMQ™ is an open source distributed messaging and streaming data platform. Latest release v4.5.1 ">
+ <meta itemprop="description" content="Apache RocketMQ™ is an open source distributed messaging and streaming data platform. Latest release v4.5.2 ">
diff --git a/content/maven/mastering-component-compatible-dependency/index.html b/content/maven/mastering-component-compatible-dependency/index.html
index 2d5d38b..98a8154 100644
--- a/content/maven/mastering-component-compatible-dependency/index.html
+++ b/content/maven/mastering-component-compatible-dependency/index.html
@@ -350,9 +350,9 @@
<p>Another compatibility form,we call it <strong>source compatibility</strong>,meaning that recompilation is necessary.Java language does not support downward source compatibility. Such as if source files use new language features or Java SE platform APIs, they will not be usable with an earlier version of the Java platform. Usually it will throw similar error like this:</p>
<div class="language-java highlighter-rouge"><div class="highlight"><pre class="highlight"><code><span class="n">java</span><span class="o">.</span><span class="na">lang</span><span class="o">.</span><span class="na">UnsupportedClassVersionError</span><span class="o">:</span> <span class="n">com</span><span class="o">.</span><span class="na">alibaba</span><span class="o">.</span><span class="na">mq</span><span class="o">.</span><span class="na">core</span><span class="o">.</span><span cl [...]
- <span class="n">Unsupported</span> <span class="n">major</span><span class="o">.</span><span class="na">minor</span> <span class="n">version</span> <span class="mf">51.0</span>
- <span class="n">at</span> <span class="n">java</span><span class="o">.</span><span class="na">lang</span><span class="o">.</span><span class="na">ClassLoader</span><span class="o">.</span><span class="na">defineClass1</span><span class="o">(</span><span class="n">Native</span> <span class="n">Method</span><span class="o">)</span>
- <span class="n">at</span> <span class="n">java</span><span class="o">.</span><span class="na">lang</span><span class="o">.</span><span class="na">ClassLoader</span><span class="o">.</span><span class="na">defineClassCond</span><span class="o">(</span><span class="n">Unknown</span> <span class="n">Source</span><span class="o">)</span>
+ <span class="nc">Unsupported</span> <span class="n">major</span><span class="o">.</span><span class="na">minor</span> <span class="n">version</span> <span class="mf">51.0</span>
+ <span class="n">at</span> <span class="n">java</span><span class="o">.</span><span class="na">lang</span><span class="o">.</span><span class="na">ClassLoader</span><span class="o">.</span><span class="na">defineClass1</span><span class="o">(</span><span class="nc">Native</span> <span class="nc">Method</span><span class="o">)</span>
+ <span class="n">at</span> <span class="n">java</span><span class="o">.</span><span class="na">lang</span><span class="o">.</span><span class="na">ClassLoader</span><span class="o">.</span><span class="na">defineClassCond</span><span class="o">(</span><span class="nc">Unknown</span> <span class="nc">Source</span><span class="o">)</span>
</code></pre></div></div>
<p>Java language source compatibility policy is as follows,except for any incompatibilities listed further below:</p>
@@ -405,39 +405,39 @@ have a class named StaticLoggerBinder and implementing SLF4J spi LoggerFactoryBi
<div class="language-java highlighter-rouge"><div class="highlight"><pre class="highlight"><code><span class="c1">// We need to use the name of the StaticLoggerBinder class, but we can't reference</span>
<span class="c1">// the class itself.</span>
-<span class="kd">private</span> <span class="kd">static</span> <span class="n">String</span> <span class="n">STATIC_LOGGER_BINDER_PATH</span> <span class="o">=</span> <span class="s">"org/slf4j/impl/StaticLoggerBinder.class"</span><span class="o">;</span>
+<span class="kd">private</span> <span class="kd">static</span> <span class="nc">String</span> <span class="no">STATIC_LOGGER_BINDER_PATH</span> <span class="o">=</span> <span class="s">"org/slf4j/impl/StaticLoggerBinder.class"</span><span class="o">;</span>
<span class="cm">/**
* It is LoggerFactory's responsibility to track version changes and manage
* the compatibility list.
* It is assumed that all versions in the 1.6 are mutually compatible.
*/</span>
-<span class="kd">static</span> <span class="kd">private</span> <span class="kd">final</span> <span class="n">String</span><span class="o">[]</span> <span class="n">API_COMPATIBILITY_LIST</span> <span class="o">=</span> <span class="k">new</span> <span class="n">String</span><span class="o">[]{</span><span class="s">"1.6"</span><span class="o">,</span> <span class="s">"1.7"</span><span class="o">};</span>
+<span class="kd">static</span> <span class="kd">private</span> <span class="kd">final</span> <span class="nc">String</span><span class="o">[]</span> <span class="no">API_COMPATIBILITY_LIST</span> <span class="o">=</span> <span class="k">new</span> <span class="nc">String</span><span class="o">[]{</span><span class="s">"1.6"</span><span class="o">,</span> <span class="s">"1.7"</span><span class="o">};</span>
<span class="c1">// private constructor prevents instantiation</span>
<span class="kd">private</span> <span class="nf">LoggerFactory</span><span class="o">()</span> <span class="o">{}</span>
<span class="kd">private</span> <span class="kd">final</span> <span class="kd">static</span> <span class="kt">void</span> <span class="nf">versionSanityCheck</span><span class="o">()</span> <span class="o">{</span>
<span class="k">try</span> <span class="o">{</span>
- <span class="n">String</span> <span class="n">requested</span> <span class="o">=</span> <span class="n">StaticLoggerBinder</span><span class="o">.</span><span class="na">REQUESTED_API_VERSION</span><span class="o">;</span>
+ <span class="nc">String</span> <span class="n">requested</span> <span class="o">=</span> <span class="nc">StaticLoggerBinder</span><span class="o">.</span><span class="na">REQUESTED_API_VERSION</span><span class="o">;</span>
<span class="kt">boolean</span> <span class="n">match</span> <span class="o">=</span> <span class="kc">false</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">API_COMPATIBILITY_LIST</span><span class="o">.</span><span class="na">length</span><span class="o">;</span> <span class="n">i</span><span class="o">++)</span> <span class="o">{</span>
- <span class="k">if</span> <span class="o">(</span><span class="n">requested</span><span class="o">.</span><span class="na">startsWith</span><span class="o">(</span><span class="n">API_COMPATIBILITY_LIST</span><span class="o">[</span><span class="n">i</span><span class="o">]))</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="no">API_COMPATIBILITY_LIST</span><span class="o">.</span><span class="na">length</span><span class="o">;</span> <span class="n">i</span><span class="o">++)</span> <span class="o">{</span>
+ <span class="k">if</span> <span class="o">(</span><span class="n">requested</span><span class="o">.</span><span class="na">startsWith</span><span class="o">(</span><span class="no">API_COMPATIBILITY_LIST</span><span class="o">[</span><span class="n">i</span><span class="o">]))</span> <span class="o">{</span>
<span class="n">match</span> <span class="o">=</span> <span class="kc">true</span><span class="o">;</span>
<span class="o">}</span>
<span class="o">}</span>
<span class="k">if</span> <span class="o">(!</span><span class="n">match</span><span class="o">)</span> <span class="o">{</span>
- <span class="n">Util</span><span class="o">.</span><span class="na">report</span><span class="o">(</span><span class="s">"The requested version "</span> <span class="o">+</span> <span class="n">requested</span>
+ <span class="nc">Util</span><span class="o">.</span><span class="na">report</span><span class="o">(</span><span class="s">"The requested version "</span> <span class="o">+</span> <span class="n">requested</span>
<span class="o">+</span> <span class="s">" by your slf4j binding is not compatible with "</span>
- <span class="o">+</span> <span class="n">Arrays</span><span class="o">.</span><span class="na">asList</span><span class="o">(</span><span class="n">API_COMPATIBILITY_LIST</span><span class="o">).</span><span class="na">toString</span><span class="o">());</span>
- <span class="n">Util</span><span class="o">.</span><span class="na">report</span><span class="o">(</span><span class="s">"See "</span> <span class="o">+</span> <span class="n">VERSION_MISMATCH</span> <span class="o">+</span> <span class="s">" for further details."</span><span class="o">);</span>
+ <span class="o">+</span> <span class="nc">Arrays</span><span class="o">.</span><span class="na">asList</span><span class="o">(</span><span class="no">API_COMPATIBILITY_LIST</span><span class="o">).</span><span class="na">toString</span><span class="o">());</span>
+ <span class="nc">Util</span><span class="o">.</span><span class="na">report</span><span class="o">(</span><span class="s">"See "</span> <span class="o">+</span> <span class="no">VERSION_MISMATCH</span> <span class="o">+</span> <span class="s">" for further details."</span><span class="o">);</span>
<span class="o">}</span>
<span class="o">}</span> <span class="k">catch</span> <span class="o">(</span><span class="n">java</span><span class="o">.</span><span class="na">lang</span><span class="o">.</span><span class="na">NoSuchFieldError</span> <span class="n">nsfe</span><span class="o">)</span> <span class="o">{</span>
<span class="c1">// given our large user base and SLF4J's commitment to backward</span>
<span class="c1">// compatibility, we cannot cry here. Only for implementations</span>
<span class="c1">// which willingly declare a REQUESTED_API_VERSION field do we</span>
<span class="c1">// emit compatibility warnings.</span>
-<span class="o">}</span> <span class="k">catch</span> <span class="o">(</span><span class="n">Throwable</span> <span class="n">e</span><span class="o">)</span> <span class="o">{</span>
+<span class="o">}</span> <span class="k">catch</span> <span class="o">(</span><span class="nc">Throwable</span> <span class="n">e</span><span class="o">)</span> <span class="o">{</span>
<span class="c1">// we should never reach here</span>
- <span class="n">Util</span><span class="o">.</span><span class="na">report</span><span class="o">(</span><span class="s">"Unexpected problem occured during version sanity check"</span><span class="o">,</span> <span class="n">e</span><span class="o">);</span>
+ <span class="nc">Util</span><span class="o">.</span><span class="na">report</span><span class="o">(</span><span class="s">"Unexpected problem occured during version sanity check"</span><span class="o">,</span> <span class="n">e</span><span class="o">);</span>
<span class="o">}</span>
<span class="o">}</span>
</code></pre></div></div>
@@ -446,7 +446,7 @@ have a class named StaticLoggerBinder and implementing SLF4J spi LoggerFactoryBi
<p>If you have developed an old version library,naming it as 2.x.x.next version,you hope to refactor some implementations,how to process multi-version compatibility?here is a skill from maven dependency plugin:</p>
-<div class="language-java highlighter-rouge"><div class="highlight"><pre class="highlight"><code><span class="n">String</span> <span class="n">hint</span> <span class="o">=</span> <span class="n">isMaven31</span><span class="o">()</span> <span class="o">?</span> <span class="s">"maven31"</span> <span class="o">:</span> <span class="n">isMaven2x</span><span class="o">()</span> <span class="o">?</span> <span class="s">"maven2"</span> <span class="o">:</span> <span class="s">"maven3"</span> [...]
+<div class="language-java highlighter-rouge"><div class="highlight"><pre class="highlight"><code><span class="nc">String</span> <span class="n">hint</span> <span class="o">=</span> <span class="n">isMaven31</span><span class="o">()</span> <span class="o">?</span> <span class="s">"maven31"</span> <span class="o">:</span> <span class="n">isMaven2x</span><span class="o">()</span> <span class="o">?</span> <span class="s">"maven2"</span> <span class="o">:</span> <span class="s">"maven3"</span [...]
<span class="cm">/**
* Check the current Maven version to see if it's Maven 2.x.
@@ -493,9 +493,9 @@ have a class named StaticLoggerBinder and implementing SLF4J spi LoggerFactoryBi
<p>So from now on, when you performing a mvn test or mvn install operation. If there is an incompatibility in one of the projects, you would find some output like this:</p>
-<div class="language-java highlighter-rouge"><div class="highlight"><pre class="highlight"><code><span class="o">[</span><span class="n">INFO</span><span class="o">]</span> <span class="o">[</span><span class="n">animal</span><span class="o">-</span><span class="nl">sniffer:</span><span class="n">check</span> <span class="o">{</span><span class="nl">execution:</span> <span class="n">check</span><span class="o">-</span><span class="n">java</span><span class="o">-</span><span class="n">api [...]
-<span class="o">[</span><span class="n">INFO</span><span class="o">]</span> <span class="n">Checking</span> <span class="n">unresolved</span> <span class="n">references</span> <span class="n">to</span> <span class="n">org</span><span class="o">.</span><span class="na">codehaus</span><span class="o">.</span><span class="na">mojo</span><span class="o">.</span><span class="na">signature</span><span class="o">:</span><span class="n">java16</span><span class="o">-</span><span class="nl">sun:< [...]
-<span class="o">[</span><span class="n">ERROR</span><span class="o">]</span> <span class="n">Undefined</span> <span class="nl">reference:</span> <span class="n">java</span><span class="o">/</span><span class="n">lang</span><span class="o">/</span><span class="n">String</span><span class="o">.</span><span class="na">contains</span><span class="o">(</span><span class="n">Ljava</span><span class="o">/</span><span class="n">lang</span><span class="o">/</span><span class="n">CharSequence</spa [...]
+<div class="language-java highlighter-rouge"><div class="highlight"><pre class="highlight"><code><span class="o">[</span><span class="no">INFO</span><span class="o">]</span> <span class="o">[</span><span class="n">animal</span><span class="o">-</span><span class="nl">sniffer:</span><span class="n">check</span> <span class="o">{</span><span class="nl">execution:</span> <span class="n">check</span><span class="o">-</span><span class="n">java</span><span class="o">-</span><span class="n">ap [...]
+<span class="o">[</span><span class="no">INFO</span><span class="o">]</span> <span class="nc">Checking</span> <span class="n">unresolved</span> <span class="n">references</span> <span class="n">to</span> <span class="n">org</span><span class="o">.</span><span class="na">codehaus</span><span class="o">.</span><span class="na">mojo</span><span class="o">.</span><span class="na">signature</span><span class="o">:</span><span class="n">java16</span><span class="o">-</span><span class="nl">sun [...]
+<span class="o">[</span><span class="no">ERROR</span><span class="o">]</span> <span class="nc">Undefined</span> <span class="nl">reference:</span> <span class="n">java</span><span class="o">/</span><span class="n">lang</span><span class="o">/</span><span class="nc">String</span><span class="o">.</span><span class="na">contains</span><span class="o">(</span><span class="nc">Ljava</span><span class="o">/</span><span class="n">lang</span><span class="o">/</span><span class="nc">CharSequence [...]
</code></pre></div></div>
<p>More details please see <a href="http://blog.gvsig.org/2011/07/25/hunting-api-incompatibilities-with-the-animal-sniffer-project/">here</a>.</p>
@@ -515,13 +515,13 @@ have a class named StaticLoggerBinder and implementing SLF4J spi LoggerFactoryBi
<p>then,run <code class="highlighter-rouge">mvn clirr:check</code>,output may be like this:</p>
-<div class="language-java highlighter-rouge"><div class="highlight"><pre class="highlight"><code><span class="o">[</span><span class="n">INFO</span><span class="o">]</span> <span class="o">---</span> <span class="n">clirr</span><span class="o">-</span><span class="n">maven</span><span class="o">-</span><span class="nl">plugin:</span><span class="mf">2.6</span><span class="o">.</span><span class="mi">1</span><span class="o">:</span><span class="n">check</span> <span class="o">(</span><spa [...]
-<span class="o">[</span><span class="n">INFO</span><span class="o">]</span> <span class="n">artifact</span> <span class="n">com</span><span class="o">.</span><span class="na">alibaba</span><span class="o">.</span><span class="na">intl</span><span class="o">.</span><span class="na">base</span><span class="o">.</span><span class="na">cmq</span><span class="o">:</span><span class="n">cmq</span><span class="o">.</span><span class="na">common</span><span class="o">:</span> <span class="n">che [...]
-<span class="o">[</span><span class="n">INFO</span><span class="o">]</span> <span class="n">Comparing</span> <span class="n">to</span> <span class="nl">version:</span> <span class="mf">2.0</span><span class="o">.</span><span class="mi">1</span>
-<span class="o">[</span><span class="n">ERROR</span><span class="o">]</span> <span class="mi">7005</span><span class="o">:</span> <span class="n">com</span><span class="o">.</span><span class="na">alibaba</span><span class="o">.</span><span class="na">mq</span><span class="o">.</span><span class="na">client</span><span class="o">.</span><span class="na">CompletionListener</span><span class="o">:</span> <span class="n">Parameter</span> <span class="mi">1</span> <span class="n">of</span> < [...]
-<span class="o">[</span><span class="n">ERROR</span><span class="o">]</span> <span class="mi">7005</span><span class="o">:</span> <span class="n">com</span><span class="o">.</span><span class="na">alibaba</span><span class="o">.</span><span class="na">mq</span><span class="o">.</span><span class="na">client</span><span class="o">.</span><span class="na">CompletionListener</span><span class="o">:</span> <span class="n">Parameter</span> <span class="mi">1</span> <span class="n">of</span> < [...]
-<span class="o">[</span><span class="n">ERROR</span><span class="o">]</span> <span class="mi">7005</span><span class="o">:</span> <span class="n">com</span><span class="o">.</span><span class="na">alibaba</span><span class="o">.</span><span class="na">mq</span><span class="o">.</span><span class="na">client</span><span class="o">.</span><span class="na">MessageProducer</span><span class="o">:</span> <span class="n">Parameter</span> <span class="mi">1</span> <span class="n">of</span> <spa [...]
-<span class="o">[</span><span class="n">ERROR</span><span class="o">]</span> <span class="mi">7005</span><span class="o">:</span> <span class="n">com</span><span class="o">.</span><span class="na">alibaba</span><span class="o">.</span><span class="na">mq</span><span class="o">.</span><span class="na">client</span><span class="o">.</span><span class="na">MessageProducer</span><span class="o">:</span> <span class="n">Parameter</span> <span class="mi">1</span> <span class="n">of</span> <spa [...]
+<div class="language-java highlighter-rouge"><div class="highlight"><pre class="highlight"><code><span class="o">[</span><span class="no">INFO</span><span class="o">]</span> <span class="o">---</span> <span class="n">clirr</span><span class="o">-</span><span class="n">maven</span><span class="o">-</span><span class="nl">plugin:</span><span class="mf">2.6</span><span class="o">.</span><span class="mi">1</span><span class="o">:</span><span class="n">check</span> <span class="o">(</span><sp [...]
+<span class="o">[</span><span class="no">INFO</span><span class="o">]</span> <span class="n">artifact</span> <span class="n">com</span><span class="o">.</span><span class="na">alibaba</span><span class="o">.</span><span class="na">intl</span><span class="o">.</span><span class="na">base</span><span class="o">.</span><span class="na">cmq</span><span class="o">:</span><span class="n">cmq</span><span class="o">.</span><span class="na">common</span><span class="o">:</span> <span class="n">ch [...]
+<span class="o">[</span><span class="no">INFO</span><span class="o">]</span> <span class="nc">Comparing</span> <span class="n">to</span> <span class="nl">version:</span> <span class="mf">2.0</span><span class="o">.</span><span class="mi">1</span>
+<span class="o">[</span><span class="no">ERROR</span><span class="o">]</span> <span class="mi">7005</span><span class="o">:</span> <span class="n">com</span><span class="o">.</span><span class="na">alibaba</span><span class="o">.</span><span class="na">mq</span><span class="o">.</span><span class="na">client</span><span class="o">.</span><span class="na">CompletionListener</span><span class="o">:</span> <span class="nc">Parameter</span> <span class="mi">1</span> <span class="n">of</span> [...]
+<span class="o">[</span><span class="no">ERROR</span><span class="o">]</span> <span class="mi">7005</span><span class="o">:</span> <span class="n">com</span><span class="o">.</span><span class="na">alibaba</span><span class="o">.</span><span class="na">mq</span><span class="o">.</span><span class="na">client</span><span class="o">.</span><span class="na">CompletionListener</span><span class="o">:</span> <span class="nc">Parameter</span> <span class="mi">1</span> <span class="n">of</span> [...]
+<span class="o">[</span><span class="no">ERROR</span><span class="o">]</span> <span class="mi">7005</span><span class="o">:</span> <span class="n">com</span><span class="o">.</span><span class="na">alibaba</span><span class="o">.</span><span class="na">mq</span><span class="o">.</span><span class="na">client</span><span class="o">.</span><span class="na">MessageProducer</span><span class="o">:</span> <span class="nc">Parameter</span> <span class="mi">1</span> <span class="n">of</span> <s [...]
+<span class="o">[</span><span class="no">ERROR</span><span class="o">]</span> <span class="mi">7005</span><span class="o">:</span> <span class="n">com</span><span class="o">.</span><span class="na">alibaba</span><span class="o">.</span><span class="na">mq</span><span class="o">.</span><span class="na">client</span><span class="o">.</span><span class="na">MessageProducer</span><span class="o">:</span> <span class="nc">Parameter</span> <span class="mi">1</span> <span class="n">of</span> <s [...]
</code></pre></div></div>
<p>Some inspiration in <strong>Dependency Mediator</strong> project just come from here.more topics about compatible,you can reference from series article <a href="http://wiki.eclipse.org/index.php/Evolving_Java-based_APIs">Evolving Java-based APIs</a></p>
@@ -534,23 +534,23 @@ have a class named StaticLoggerBinder and implementing SLF4J spi LoggerFactoryBi
<p>What is the principle of <strong>Dependency Mediator</strong>？<strong>Dependency Mediator</strong> try to mediate various component conflicting problems.It uses jar or class as the smallest component unit,that is ComponentEntry:</p>
-<div class="language-java highlighter-rouge"><div class="highlight"><pre class="highlight"><code><span class="kd">public</span> <span class="kd">class</span> <span class="nc">ComponentEntry</span> <span class="kd">implements</span> <span class="n">Comparable</span><span class="o"><</span><span class="n">ComponentEntry</span><span class="o">></span> <span class="o">{</span>
+<div class="language-java highlighter-rouge"><div class="highlight"><pre class="highlight"><code><span class="kd">public</span> <span class="kd">class</span> <span class="nc">ComponentEntry</span> <span class="kd">implements</span> <span class="nc">Comparable</span><span class="o"><</span><span class="nc">ComponentEntry</span><span class="o">></span> <span class="o">{</span>
<span class="cm">/**
* Similar file name
*/</span>
- <span class="kd">private</span> <span class="n">String</span> <span class="n">pathName</span><span class="o">;</span>
+ <span class="kd">private</span> <span class="nc">String</span> <span class="n">pathName</span><span class="o">;</span>
<span class="cm">/**
* Component name ,such as fully-qualified class name or jar name
*/</span>
- <span class="kd">private</span> <span class="n">String</span> <span class="n">name</span><span class="o">;</span>
+ <span class="kd">private</span> <span class="nc">String</span> <span class="n">name</span><span class="o">;</span>
<span class="cm">/**
* Name of the jar which contains this entry,this field may be null
*/</span>
- <span class="kd">private</span> <span class="n">String</span> <span class="n">jarName</span><span class="o">;</span>
+ <span class="kd">private</span> <span class="nc">String</span> <span class="n">jarName</span><span class="o">;</span>
<span class="cm">/**
* Jar entry meta info,if it is a jar file,this field may be null
*/</span>
- <span class="kd">private</span> <span class="n">JarEntry</span> <span class="n">entry</span><span class="o">;</span>
+ <span class="kd">private</span> <span class="nc">JarEntry</span> <span class="n">entry</span><span class="o">;</span>
<span class="o">....</span>
</code></pre></div></div>
@@ -564,7 +564,7 @@ setting checkJars to true or nothing to do with this property,it will further an
<p>If you consider the dependency hierarchy as a binary tree structure,Undoubtedly,<strong>nearest definition</strong> means the <strong>minimum depth</strong>. so if you put some higher version dependency library after lower version one(may be transitive dependency),you will face incompatible conflicting problems.Such as :</p>
-<div class="language-java highlighter-rouge"><div class="highlight"><pre class="highlight"><code><span class="o">[</span><span class="n">WARNING</span><span class="o">]</span> <span class="n">Founded</span> <span class="n">conflicting</span> <span class="n">dependency</span> <span class="nl">component:</span><span class="n">org</span><span class="o">.</span><span class="na">apache</span><span class="o">.</span><span class="na">thrift</span><span class="o">:</span><span class="nl">libthri [...]
+<div class="language-java highlighter-rouge"><div class="highlight"><pre class="highlight"><code><span class="o">[</span><span class="no">WARNING</span><span class="o">]</span> <span class="nc">Founded</span> <span class="n">conflicting</span> <span class="n">dependency</span> <span class="nl">component:</span><span class="n">org</span><span class="o">.</span><span class="na">apache</span><span class="o">.</span><span class="na">thrift</span><span class="o">:</span><span class="nl">libth [...]
</code></pre></div></div>
<p>In this case,you could fix this problem through place libthrift 0.9.1 before the library imported through transitive dependency.</p>
diff --git a/content/sitemap.xml b/content/sitemap.xml
index 61535e8..56980bc 100644
--- a/content/sitemap.xml
+++ b/content/sitemap.xml
@@ -2,135 +2,135 @@
<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>/about/team/</loc>
-<lastmod>2019-08-05T10:42:32+08:00</lastmod>
+<lastmod>2019-08-13T20:57:29+08:00</lastmod>
</url>
<url>
<loc>/about/contact/</loc>
-<lastmod>2019-08-05T10:42:32+08:00</lastmod>
+<lastmod>2019-08-13T20:57:29+08:00</lastmod>
</url>
<url>
<loc>/about/rewards/</loc>
-<lastmod>2019-08-05T10:42:32+08:00</lastmod>
+<lastmod>2019-08-13T20:57:29+08:00</lastmod>
</url>
<url>
<loc>/docs/quick-start/</loc>
-<lastmod>2019-08-05T10:42:32+08:00</lastmod>
+<lastmod>2019-08-13T20:57:29+08:00</lastmod>
</url>
<url>
<loc>/docs/motivation/</loc>
-<lastmod>2019-08-05T10:42:32+08:00</lastmod>
+<lastmod>2019-08-13T20:57:29+08:00</lastmod>
</url>
<url>
<loc>/docs/core-concept/</loc>
-<lastmod>2019-08-05T10:42:32+08:00</lastmod>
+<lastmod>2019-08-13T20:57:29+08:00</lastmod>
</url>
<url>
<loc>/docs/cli-admin-tool/</loc>
-<lastmod>2019-08-05T10:42:32+08:00</lastmod>
+<lastmod>2019-08-13T20:57:29+08:00</lastmod>
</url>
<url>
<loc>/docs/cluster-deployment/</loc>
-<lastmod>2019-08-05T10:42:32+08:00</lastmod>
+<lastmod>2019-08-13T20:57:29+08:00</lastmod>
</url>
<url>
<loc>/docs/pull-request/</loc>
-<lastmod>2019-08-05T10:42:32+08:00</lastmod>
+<lastmod>2019-08-13T20:57:29+08:00</lastmod>
</url>
<url>
<loc>/docs/code-guidelines/</loc>
-<lastmod>2019-08-05T10:42:32+08:00</lastmod>
+<lastmod>2019-08-13T20:57:29+08:00</lastmod>
</url>
<url>
<loc>/docs/documentation/</loc>
-<lastmod>2019-08-05T10:42:32+08:00</lastmod>
+<lastmod>2019-08-13T20:57:29+08:00</lastmod>
</url>
<url>
<loc>/docs/faq/</loc>
-<lastmod>2019-08-05T10:42:32+08:00</lastmod>
+<lastmod>2019-08-13T20:57:29+08:00</lastmod>
</url>
<url>
<loc>/docs/release-manual</loc>
-<lastmod>2019-08-05T10:42:32+08:00</lastmod>
+<lastmod>2019-08-13T20:57:29+08:00</lastmod>
</url>
<url>
<loc>/dowloading/releases/</loc>
-<lastmod>2019-08-05T10:42:32+08:00</lastmod>
+<lastmod>2019-08-13T20:57:29+08:00</lastmod>
</url>
<url>
<loc>/docs/roadmap/</loc>
-<lastmod>2019-08-05T10:42:32+08:00</lastmod>
+<lastmod>2019-08-13T20:57:29+08:00</lastmod>
</url>
<url>
<loc>/docs/batch-example/</loc>
-<lastmod>2019-08-05T10:42:32+08:00</lastmod>
+<lastmod>2019-08-13T20:57:29+08:00</lastmod>
</url>
<url>
<loc>/docs/broadcast-example/</loc>
-<lastmod>2019-08-05T10:42:32+08:00</lastmod>
+<lastmod>2019-08-13T20:57:29+08:00</lastmod>
</url>
<url>
<loc>/docs/rmq-deployment/</loc>
-<lastmod>2019-08-05T10:42:32+08:00</lastmod>
+<lastmod>2019-08-13T20:57:29+08:00</lastmod>
</url>
<url>
<loc>/docs/order-example/</loc>
-<lastmod>2019-08-05T10:42:32+08:00</lastmod>
+<lastmod>2019-08-13T20:57:29+08:00</lastmod>
</url>
<url>
<loc>/docs/rmq-arc/</loc>
-<lastmod>2019-08-05T10:42:32+08:00</lastmod>
+<lastmod>2019-08-13T20:57:29+08:00</lastmod>
</url>
<url>
<loc>/docs/schedule-example/</loc>
-<lastmod>2019-08-05T10:42:32+08:00</lastmod>
+<lastmod>2019-08-13T20:57:29+08:00</lastmod>
</url>
<url>
<loc>/docs/simple-example/</loc>
-<lastmod>2019-08-05T10:42:32+08:00</lastmod>
+<lastmod>2019-08-13T20:57:29+08:00</lastmod>
</url>
<url>
<loc>/docs/filter-by-sql92-example/</loc>
-<lastmod>2019-08-05T10:42:32+08:00</lastmod>
+<lastmod>2019-08-13T20:57:29+08:00</lastmod>
</url>
<url>
<loc>/docs/logappender-example/</loc>
-<lastmod>2019-08-05T10:42:32+08:00</lastmod>
+<lastmod>2019-08-13T20:57:29+08:00</lastmod>
</url>
<url>
<loc>/docs/openmessaging-example/</loc>
-<lastmod>2019-08-05T10:42:32+08:00</lastmod>
+<lastmod>2019-08-13T20:57:29+08:00</lastmod>
</url>
<url>
<loc>/docs/system-config/</loc>
-<lastmod>2019-08-05T10:42:32+08:00</lastmod>
+<lastmod>2019-08-13T20:57:29+08:00</lastmod>
</url>
<url>
<loc>/docs/how-to-contribute/</loc>
-<lastmod>2019-08-05T10:42:32+08:00</lastmod>
+<lastmod>2019-08-13T20:57:29+08:00</lastmod>
</url>
<url>
<loc>/docs/transaction-example/</loc>
-<lastmod>2019-08-05T10:42:32+08:00</lastmod>
+<lastmod>2019-08-13T20:57:29+08:00</lastmod>
</url>
<url>
<loc>/docs/best-practice-broker/</loc>
-<lastmod>2019-08-05T10:42:32+08:00</lastmod>
+<lastmod>2019-08-13T20:57:29+08:00</lastmod>
</url>
<url>
<loc>/docs/best-practice-consumer/</loc>
-<lastmod>2019-08-05T10:42:32+08:00</lastmod>
+<lastmod>2019-08-13T20:57:29+08:00</lastmod>
</url>
<url>
<loc>/docs/create-pull-request/</loc>
-<lastmod>2019-08-05T10:42:32+08:00</lastmod>
+<lastmod>2019-08-13T20:57:29+08:00</lastmod>
</url>
<url>
<loc>/docs/best-practice-namesvr/</loc>
-<lastmod>2019-08-05T10:42:32+08:00</lastmod>
+<lastmod>2019-08-13T20:57:29+08:00</lastmod>
</url>
<url>
<loc>/docs/best-practice-producer/</loc>
-<lastmod>2019-08-05T10:42:32+08:00</lastmod>
+<lastmod>2019-08-13T20:57:29+08:00</lastmod>
</url>
<url>
<loc>/rocketmq/how-to-support-more-queues-in-rocketmq/</loc>
@@ -340,10 +340,10 @@
</url>
<url>
<loc>/assets/attachment/launch-rocketmq-code-marathon.pdf</loc>
-<lastmod>2019-08-02T19:48:38+08:00</lastmod>
+<lastmod>2019-08-13T20:11:10+08:00</lastmod>
</url>
<url>
<loc>/assets/attachment/launch-second-rocketmq-code-marathon.pdf</loc>
-<lastmod>2019-08-02T19:48:38+08:00</lastmod>
+<lastmod>2019-08-13T20:11:10+08:00</lastmod>
</url>
</urlset>
[rocketmq-site] 01/02: Merge remote-tracking branch 'origin/master'
into asf-site
Posted by hu...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
huzongtang pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/rocketmq-site.git
commit 47eb23cf19517083c89aafa88345f6ef54126865
Merge: 625b664 e901ec9
Author: zongtanghu <zo...@gmail.com>
AuthorDate: Tue Aug 13 20:57:14 2019 +0800
Merge remote-tracking branch 'origin/master' into asf-site
home.md | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)