This is an automated email from the ASF dual-hosted git repository.
mmerli pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/incubator-pulsar.git
The following commit(s) were added to refs/heads/asf-site by this push:
new 2716be2 Updated site at revision 7404952
2716be2 is described below
commit 2716be27a9a9d3fd959055f19bda732a9e68879f
Author: jenkins <bui...@apache.org>
AuthorDate: Wed Feb 14 08:16:04 2018 +0000
Updated site at revision 7404952
---
content/api/client/index-all.html | 8 ++
.../org/apache/pulsar/client/api/Reader.html | 47 +++++-
.../docs/latest/project/BinaryProtocol/index.html | 157 ++++++++++++++++++++-
content/ja/project/BinaryProtocol/index.html | 157 ++++++++++++++++++++-
4 files changed, 358 insertions(+), 11 deletions(-)
diff --git a/content/api/client/index-all.html
b/content/api/client/index-all.html
index 7a9aa8a..296466e 100644
--- a/content/api/client/index-all.html
+++ b/content/api/client/index-all.html
@@ -557,6 +557,14 @@
<dd>
<div class="block">Check whether the message has a key</div>
</dd>
+<dt><span class="memberNameLink"><a
href="org/apache/pulsar/client/api/Reader.html#hasMessageAvailable--">hasMessageAvailable()</a></span>
- Method in interface org.apache.pulsar.client.api.<a
href="org/apache/pulsar/client/api/Reader.html" title="interface in
org.apache.pulsar.client.api">Reader</a></dt>
+<dd>
+<div class="block">Check if there is any message available to read from the
current position.</div>
+</dd>
+<dt><span class="memberNameLink"><a
href="org/apache/pulsar/client/api/Reader.html#hasMessageAvailableAsync--">hasMessageAvailableAsync()</a></span>
- Method in interface org.apache.pulsar.client.api.<a
href="org/apache/pulsar/client/api/Reader.html" title="interface in
org.apache.pulsar.client.api">Reader</a></dt>
+<dd>
+<div class="block">Asynchronously Check if there is message that has been
published successfully to the broker in the topic.</div>
+</dd>
<dt><span class="memberNameLink"><a
href="org/apache/pulsar/client/api/Message.html#hasProperty-java.lang.String-">hasProperty(String)</a></span>
- Method in interface org.apache.pulsar.client.api.<a
href="org/apache/pulsar/client/api/Message.html" title="interface in
org.apache.pulsar.client.api">Message</a></dt>
<dd>
<div class="block">Check whether the message has a specific property
attached.</div>
diff --git a/content/api/client/org/apache/pulsar/client/api/Reader.html
b/content/api/client/org/apache/pulsar/client/api/Reader.html
index 052fce9..c8ae116 100644
--- a/content/api/client/org/apache/pulsar/client/api/Reader.html
+++ b/content/api/client/org/apache/pulsar/client/api/Reader.html
@@ -17,7 +17,7 @@
catch(err) {
}
//-->
-var methods = {"i0":6,"i1":6,"i2":6,"i3":6,"i4":6,"i5":6};
+var methods = {"i0":6,"i1":6,"i2":6,"i3":6,"i4":6,"i5":6,"i6":6,"i7":6};
var tabs = {65535:["t0","All Methods"],2:["t2","Instance
Methods"],4:["t3","Abstract Methods"]};
var altColor = "altColor";
var rowColor = "rowColor";
@@ -136,24 +136,36 @@ extends Closeable</pre>
</tr>
<tr id="i2" class="altColor">
<td class="colFirst"><code>boolean</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../org/apache/pulsar/client/api/Reader.html#hasMessageAvailable--">hasMessageAvailable</a></span>()</code>
+<div class="block">Check if there is any message available to read from the
current position.</div>
+</td>
+</tr>
+<tr id="i3" class="rowColor">
+<td class="colFirst"><code>CompletableFuture<Boolean></code></td>
+<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../org/apache/pulsar/client/api/Reader.html#hasMessageAvailableAsync--">hasMessageAvailableAsync</a></span>()</code>
+<div class="block">Asynchronously Check if there is message that has been
published successfully to the broker in the topic.</div>
+</td>
+</tr>
+<tr id="i4" class="altColor">
+<td class="colFirst"><code>boolean</code></td>
<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../org/apache/pulsar/client/api/Reader.html#hasReachedEndOfTopic--">hasReachedEndOfTopic</a></span>()</code>
<div class="block">Return true if the topic was terminated and this reader has
reached the end of the topic</div>
</td>
</tr>
-<tr id="i3" class="rowColor">
+<tr id="i5" class="rowColor">
<td class="colFirst"><code><a
href="../../../../../org/apache/pulsar/client/api/Message.html"
title="interface in org.apache.pulsar.client.api">Message</a></code></td>
<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../org/apache/pulsar/client/api/Reader.html#readNext--">readNext</a></span>()</code>
<div class="block">Read the next message in the topic</div>
</td>
</tr>
-<tr id="i4" class="altColor">
+<tr id="i6" class="altColor">
<td class="colFirst"><code><a
href="../../../../../org/apache/pulsar/client/api/Message.html"
title="interface in org.apache.pulsar.client.api">Message</a></code></td>
<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../org/apache/pulsar/client/api/Reader.html#readNext-int-java.util.concurrent.TimeUnit-">readNext</a></span>(int timeout,
TimeUnit unit)</code>
<div class="block">Read the next message in the topic.</div>
</td>
</tr>
-<tr id="i5" class="rowColor">
+<tr id="i7" class="rowColor">
<td class="colFirst"><code>CompletableFuture<<a
href="../../../../../org/apache/pulsar/client/api/Message.html"
title="interface in org.apache.pulsar.client.api">Message</a>></code></td>
<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../org/apache/pulsar/client/api/Reader.html#readNextAsync--">readNextAsync</a></span>()</code> </td>
</tr>
@@ -253,13 +265,38 @@ extends Closeable</pre>
<a name="hasReachedEndOfTopic--">
<!-- -->
</a>
-<ul class="blockListLast">
+<ul class="blockList">
<li class="blockList">
<h4>hasReachedEndOfTopic</h4>
<pre>boolean hasReachedEndOfTopic()</pre>
<div class="block">Return true if the topic was terminated and this reader has
reached the end of the topic</div>
</li>
</ul>
+<a name="hasMessageAvailable--">
+<!-- -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>hasMessageAvailable</h4>
+<pre>boolean hasMessageAvailable()
+ throws <a
href="../../../../../org/apache/pulsar/client/api/PulsarClientException.html"
title="class in org.apache.pulsar.client.api">PulsarClientException</a></pre>
+<div class="block">Check if there is any message available to read from the
current position.</div>
+<dl>
+<dt><span class="throwsLabel">Throws:</span></dt>
+<dd><code><a
href="../../../../../org/apache/pulsar/client/api/PulsarClientException.html"
title="class in
org.apache.pulsar.client.api">PulsarClientException</a></code></dd>
+</dl>
+</li>
+</ul>
+<a name="hasMessageAvailableAsync--">
+<!-- -->
+</a>
+<ul class="blockListLast">
+<li class="blockList">
+<h4>hasMessageAvailableAsync</h4>
+<pre>CompletableFuture<Boolean> hasMessageAvailableAsync()</pre>
+<div class="block">Asynchronously Check if there is message that has been
published successfully to the broker in the topic.</div>
+</li>
+</ul>
</li>
</ul>
</li>
diff --git a/content/docs/latest/project/BinaryProtocol/index.html
b/content/docs/latest/project/BinaryProtocol/index.html
index 29b81ec..d67dda9 100644
--- a/content/docs/latest/project/BinaryProtocol/index.html
+++ b/content/docs/latest/project/BinaryProtocol/index.html
@@ -1985,6 +1985,18 @@ response will contain actual metadata.</p>
</li>
<li>
+ <a href="#pulsar.proto.CommandGetLastMessageId">
+ CommandGetLastMessageId
+ </a>
+ </li>
+
+ <li>
+ <a href="#pulsar.proto.CommandGetLastMessageIdResponse">
+ CommandGetLastMessageIdResponse
+ </a>
+ </li>
+
+ <li>
<a href="#pulsar.proto.CommandLookupTopic">
CommandLookupTopic
</a>
@@ -2505,6 +2517,26 @@ response will contain actual metadata.</p>
<td></td>
<td></td>
</tr>
+
+ <tr>
+ <td class="wrap">getLastMessageId</td>
+
+ <td class="wrap"><a
href="#pulsar.proto.CommandGetLastMessageId">CommandGetLastMessageId</a></td>
+
+ <td>optional</td>
+ <td></td>
+ <td></td>
+ </tr>
+
+ <tr>
+ <td class="wrap">getLastMessageIdResponse</td>
+
+ <td class="wrap"><a
href="#pulsar.proto.CommandGetLastMessageIdResponse">CommandGetLastMessageIdResponse</a></td>
+
+ <td>optional</td>
+ <td></td>
+ <td></td>
+ </tr>
<!-- for field in fields -->
</tbody>
</table>
@@ -2794,7 +2826,7 @@ will be the auth of the proxy itself</td>
<td></td>
<td>Original auth role and auth Method that was passed
to the proxy. In this case the auth info above
-will be the auth of the proxy itself </td>
+will be the auth of the proxy itself</td>
</tr>
<tr>
@@ -3202,6 +3234,104 @@ of any number previously specified</td>
<div class="card-block">
<div class="card-title">
+ <h5 class="message-name" id="pulsar.proto.CommandGetLastMessageId">
+ CommandGetLastMessageId
+ </h5>
+ <p class="message-name">pulsar.proto.CommandGetLastMessageId</p>
+ <p class="lead"></p>
+ </div>
+
+ <div class="card">
+ <h5>Fields</h5>
+ <table class="protobuf-table">
+ <thead>
+ <tr>
+ <th>Name</th>
+ <th>Type</th>
+ <th>Label</th>
+ <th>Default</th>
+ <th>Description</th>
+ </tr>
+ </thead>
+ <tbody>
+
+ <tr>
+ <td class="wrap">consumer_id</td>
+
+ <td class="wrap">uint64</td>
+
+ <td>required</td>
+ <td></td>
+ <td></td>
+ </tr>
+
+ <tr>
+ <td class="wrap">request_id</td>
+
+ <td class="wrap">uint64</td>
+
+ <td>required</td>
+ <td></td>
+ <td></td>
+ </tr>
+ <!-- for field in fields -->
+ </tbody>
+ </table>
+ </div>
+ <!-- if fields -->
+ </div>
+
+ <div class="card-block">
+ <div class="card-title">
+ <h5 class="message-name"
id="pulsar.proto.CommandGetLastMessageIdResponse">
+ CommandGetLastMessageIdResponse
+ </h5>
+ <p
class="message-name">pulsar.proto.CommandGetLastMessageIdResponse</p>
+ <p class="lead"></p>
+ </div>
+
+ <div class="card">
+ <h5>Fields</h5>
+ <table class="protobuf-table">
+ <thead>
+ <tr>
+ <th>Name</th>
+ <th>Type</th>
+ <th>Label</th>
+ <th>Default</th>
+ <th>Description</th>
+ </tr>
+ </thead>
+ <tbody>
+
+ <tr>
+ <td class="wrap">last_message_id</td>
+
+ <td class="wrap"><a
href="#pulsar.proto.MessageIdData">MessageIdData</a></td>
+
+ <td>required</td>
+ <td></td>
+ <td></td>
+ </tr>
+
+ <tr>
+ <td class="wrap">request_id</td>
+
+ <td class="wrap">uint64</td>
+
+ <td>required</td>
+ <td></td>
+ <td></td>
+ </tr>
+ <!-- for field in fields -->
+ </tbody>
+ </table>
+ </div>
+ <!-- if fields -->
+ </div>
+
+ <div class="card-block">
+ <div class="card-title">
<h5 class="message-name" id="pulsar.proto.CommandLookupTopic">
CommandLookupTopic
</h5>
@@ -3272,7 +3402,7 @@ a Pulsar proxy.</td>
<td>optional</td>
<td></td>
<td>Original auth role and auth Method that was passed
-to the proxy. </td>
+to the proxy.</td>
</tr>
<tr>
@@ -3513,7 +3643,7 @@ a Pulsar proxy.</td>
<td>optional</td>
<td></td>
<td>Original auth role and auth Method that was passed
-to the proxy. </td>
+to the proxy.</td>
</tr>
<tr>
@@ -5071,6 +5201,20 @@ if this field is omitted, `publish_time` can be used for
the purpose of `event_t
<td>
</td>
</tr>
+
+ <tr>
+ <td>GET_LAST_MESSAGE_ID</td>
+ <td>29</td>
+ <td>
+</td>
+ </tr>
+
+ <tr>
+ <td>GET_LAST_MESSAGE_ID_RESPONSE</td>
+ <td>30</td>
+ <td>
+</td>
+ </tr>
<!-- for value in values -->
</tbody>
</table>
@@ -5445,6 +5589,13 @@ incrementally added to the protocol</p>
<td><p>C++ consumers before this version are not correctly
handling the checksum field</p>
</td>
</tr>
+
+ <tr>
+ <td>v12</td>
+ <td>12</td>
+ <td><p>Added get topic’s last messageId from broker</p>
+</td>
+ </tr>
<!-- for value in values -->
</tbody>
</table>
diff --git a/content/ja/project/BinaryProtocol/index.html
b/content/ja/project/BinaryProtocol/index.html
index 70c5c9d..ef3fe68 100644
--- a/content/ja/project/BinaryProtocol/index.html
+++ b/content/ja/project/BinaryProtocol/index.html
@@ -1770,6 +1770,18 @@
</li>
<li>
+ <a href="#pulsar.proto.CommandGetLastMessageId">
+ CommandGetLastMessageId
+ </a>
+ </li>
+
+ <li>
+ <a href="#pulsar.proto.CommandGetLastMessageIdResponse">
+ CommandGetLastMessageIdResponse
+ </a>
+ </li>
+
+ <li>
<a href="#pulsar.proto.CommandLookupTopic">
CommandLookupTopic
</a>
@@ -2290,6 +2302,26 @@
<td></td>
<td></td>
</tr>
+
+ <tr>
+ <td class="wrap">getLastMessageId</td>
+
+ <td class="wrap"><a
href="#pulsar.proto.CommandGetLastMessageId">CommandGetLastMessageId</a></td>
+
+ <td>optional</td>
+ <td></td>
+ <td></td>
+ </tr>
+
+ <tr>
+ <td class="wrap">getLastMessageIdResponse</td>
+
+ <td class="wrap"><a
href="#pulsar.proto.CommandGetLastMessageIdResponse">CommandGetLastMessageIdResponse</a></td>
+
+ <td>optional</td>
+ <td></td>
+ <td></td>
+ </tr>
<!-- for field in fields -->
</tbody>
</table>
@@ -2579,7 +2611,7 @@ will be the auth of the proxy itself</td>
<td></td>
<td>Original auth role and auth Method that was passed
to the proxy. In this case the auth info above
-will be the auth of the proxy itself </td>
+will be the auth of the proxy itself</td>
</tr>
<tr>
@@ -2987,6 +3019,104 @@ of any number previously specified</td>
<div class="card-block">
<div class="card-title">
+ <h5 class="message-name" id="pulsar.proto.CommandGetLastMessageId">
+ CommandGetLastMessageId
+ </h5>
+ <p class="message-name">pulsar.proto.CommandGetLastMessageId</p>
+ <p class="lead"></p>
+ </div>
+
+ <div class="card">
+ <h5>Fields</h5>
+ <table class="protobuf-table">
+ <thead>
+ <tr>
+ <th>Name</th>
+ <th>Type</th>
+ <th>Label</th>
+ <th>Default</th>
+ <th>Description</th>
+ </tr>
+ </thead>
+ <tbody>
+
+ <tr>
+ <td class="wrap">consumer_id</td>
+
+ <td class="wrap">uint64</td>
+
+ <td>required</td>
+ <td></td>
+ <td></td>
+ </tr>
+
+ <tr>
+ <td class="wrap">request_id</td>
+
+ <td class="wrap">uint64</td>
+
+ <td>required</td>
+ <td></td>
+ <td></td>
+ </tr>
+ <!-- for field in fields -->
+ </tbody>
+ </table>
+ </div>
+ <!-- if fields -->
+ </div>
+
+ <div class="card-block">
+ <div class="card-title">
+ <h5 class="message-name"
id="pulsar.proto.CommandGetLastMessageIdResponse">
+ CommandGetLastMessageIdResponse
+ </h5>
+ <p
class="message-name">pulsar.proto.CommandGetLastMessageIdResponse</p>
+ <p class="lead"></p>
+ </div>
+
+ <div class="card">
+ <h5>Fields</h5>
+ <table class="protobuf-table">
+ <thead>
+ <tr>
+ <th>Name</th>
+ <th>Type</th>
+ <th>Label</th>
+ <th>Default</th>
+ <th>Description</th>
+ </tr>
+ </thead>
+ <tbody>
+
+ <tr>
+ <td class="wrap">last_message_id</td>
+
+ <td class="wrap"><a
href="#pulsar.proto.MessageIdData">MessageIdData</a></td>
+
+ <td>required</td>
+ <td></td>
+ <td></td>
+ </tr>
+
+ <tr>
+ <td class="wrap">request_id</td>
+
+ <td class="wrap">uint64</td>
+
+ <td>required</td>
+ <td></td>
+ <td></td>
+ </tr>
+ <!-- for field in fields -->
+ </tbody>
+ </table>
+ </div>
+ <!-- if fields -->
+ </div>
+
+ <div class="card-block">
+ <div class="card-title">
<h5 class="message-name" id="pulsar.proto.CommandLookupTopic">
CommandLookupTopic
</h5>
@@ -3057,7 +3187,7 @@ a Pulsar proxy.</td>
<td>optional</td>
<td></td>
<td>Original auth role and auth Method that was passed
-to the proxy. </td>
+to the proxy.</td>
</tr>
<tr>
@@ -3298,7 +3428,7 @@ a Pulsar proxy.</td>
<td>optional</td>
<td></td>
<td>Original auth role and auth Method that was passed
-to the proxy. </td>
+to the proxy.</td>
</tr>
<tr>
@@ -4856,6 +4986,20 @@ if this field is omitted, `publish_time` can be used for
the purpose of `event_t
<td>
</td>
</tr>
+
+ <tr>
+ <td>GET_LAST_MESSAGE_ID</td>
+ <td>29</td>
+ <td>
+</td>
+ </tr>
+
+ <tr>
+ <td>GET_LAST_MESSAGE_ID_RESPONSE</td>
+ <td>30</td>
+ <td>
+</td>
+ </tr>
<!-- for value in values -->
</tbody>
</table>
@@ -5230,6 +5374,13 @@ incrementally added to the protocol</p>
<td><p>C++ consumers before this version are not correctly
handling the checksum field</p>
</td>
</tr>
+
+ <tr>
+ <td>v12</td>
+ <td>12</td>
+ <td><p>Added get topic’s last messageId from broker</p>
+</td>
+ </tr>
<!-- for value in values -->
</tbody>
</table>
--
To stop receiving notification emails like this one, please contact
mme...@apache.org.
