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 43b465c Updated site at revision f3b47c0
43b465c is described below
commit 43b465c30c108939f1133477b4a3fa378c43b34e
Author: jenkins <[email protected]>
AuthorDate: Wed May 16 08:30:48 2018 +0000
Updated site at revision f3b47c0
---
content/api/client/index-all.html | 6 ++++
.../org/apache/pulsar/client/api/Consumer.html | 35 ++++++++++++++++------
.../org/apache/pulsar/client/api/Producer.html | 29 ++++++++++++++----
.../org/apache/pulsar/client/api/Reader.html | 25 +++++++++++++---
4 files changed, 76 insertions(+), 19 deletions(-)
diff --git a/content/api/client/index-all.html
b/content/api/client/index-all.html
index 118a493..0961ffc 100644
--- a/content/api/client/index-all.html
+++ b/content/api/client/index-all.html
@@ -988,6 +988,12 @@
<dd>
<div class="block">Set the number of threads to be used for handling
connections to brokers <i>(default: 1 thread)</i></div>
</dd>
+<dt><span class="memberNameLink"><a
href="org/apache/pulsar/client/api/Consumer.html#isConnected--">isConnected()</a></span>
- Method in interface org.apache.pulsar.client.api.<a
href="org/apache/pulsar/client/api/Consumer.html" title="interface in
org.apache.pulsar.client.api">Consumer</a></dt>
+<dd> </dd>
+<dt><span class="memberNameLink"><a
href="org/apache/pulsar/client/api/Producer.html#isConnected--">isConnected()</a></span>
- Method in interface org.apache.pulsar.client.api.<a
href="org/apache/pulsar/client/api/Producer.html" title="interface in
org.apache.pulsar.client.api">Producer</a></dt>
+<dd> </dd>
+<dt><span class="memberNameLink"><a
href="org/apache/pulsar/client/api/Reader.html#isConnected--">isConnected()</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> </dd>
<dt><span class="memberNameLink"><a
href="org/apache/pulsar/client/api/ProducerConfiguration.html#isEncryptionEnabled--">isEncryptionEnabled()</a></span>
- Method in class org.apache.pulsar.client.api.<a
href="org/apache/pulsar/client/api/ProducerConfiguration.html" title="class in
org.apache.pulsar.client.api">ProducerConfiguration</a></dt>
<dd>
<div class="block"><span class="deprecatedLabel">Deprecated.</span></div>
diff --git a/content/api/client/org/apache/pulsar/client/api/Consumer.html
b/content/api/client/org/apache/pulsar/client/api/Consumer.html
index 337185a..bfcd77e 100644
--- a/content/api/client/org/apache/pulsar/client/api/Consumer.html
+++ b/content/api/client/org/apache/pulsar/client/api/Consumer.html
@@ -17,7 +17,7 @@
catch(err) {
}
//-->
-var methods =
{"i0":6,"i1":6,"i2":6,"i3":6,"i4":6,"i5":6,"i6":6,"i7":6,"i8":6,"i9":6,"i10":6,"i11":6,"i12":6,"i13":6,"i14":6,"i15":6,"i16":6,"i17":6,"i18":6,"i19":6,"i20":6,"i21":6};
+var methods =
{"i0":6,"i1":6,"i2":6,"i3":6,"i4":6,"i5":6,"i6":6,"i7":6,"i8":6,"i9":6,"i10":6,"i11":6,"i12":6,"i13":6,"i14":6,"i15":6,"i16":6,"i17":6,"i18":6,"i19":6,"i20":6,"i21":6,"i22":6};
var tabs = {65535:["t0","All Methods"],2:["t2","Instance
Methods"],4:["t3","Abstract Methods"]};
var altColor = "altColor";
var rowColor = "rowColor";
@@ -211,49 +211,53 @@ extends Closeable</pre>
</td>
</tr>
<tr id="i14" class="altColor">
+<td class="colFirst"><code>boolean</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../org/apache/pulsar/client/api/Consumer.html#isConnected--">isConnected</a></span>()</code> </td>
+</tr>
+<tr id="i15" 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><<a
href="../../../../../org/apache/pulsar/client/api/Consumer.html" title="type
parameter in Consumer">T</a>></code></td>
<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../org/apache/pulsar/client/api/Consumer.html#receive--">receive</a></span>()</code>
<div class="block">Receives a single message.</div>
</td>
</tr>
-<tr id="i15" class="rowColor">
+<tr id="i16" 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><<a
href="../../../../../org/apache/pulsar/client/api/Consumer.html" title="type
parameter in Consumer">T</a>></code></td>
<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../org/apache/pulsar/client/api/Consumer.html#receive-int-java.util.concurrent.TimeUnit-">receive</a></span>(int timeout,
TimeUnit unit)</code>
<div class="block">Receive a single message</div>
</td>
</tr>
-<tr id="i16" class="altColor">
+<tr id="i17" 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><<a
href="../../../../../org/apache/pulsar/client/api/Consumer.html" title="type
parameter in Consumer">T</a>>></code></td>
<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../org/apache/pulsar/client/api/Consumer.html#receiveAsync--">receiveAsync</a></span>()</code>
<div class="block">Receive a single message</div>
</td>
</tr>
-<tr id="i17" class="rowColor">
+<tr id="i18" class="altColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../org/apache/pulsar/client/api/Consumer.html#redeliverUnacknowledgedMessages--">redeliverUnacknowledgedMessages</a></span>()</code>
<div class="block">Redelivers all the unacknowledged messages.</div>
</td>
</tr>
-<tr id="i18" class="altColor">
+<tr id="i19" class="rowColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../org/apache/pulsar/client/api/Consumer.html#seek-org.apache.pulsar.client.api.MessageId-">seek</a></span>(<a
href="../../../../../org/apache/pulsar/client/api/MessageId.html"
title="interface in
org.apache.pulsar.client.api">MessageId</a> messageId)</code>
<div class="block">Reset the subscription associated with this consumer to a
specific message id.</div>
</td>
</tr>
-<tr id="i19" class="rowColor">
+<tr id="i20" class="altColor">
<td class="colFirst"><code>CompletableFuture<Void></code></td>
<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../org/apache/pulsar/client/api/Consumer.html#seekAsync-org.apache.pulsar.client.api.MessageId-">seekAsync</a></span>(<a
href="../../../../../org/apache/pulsar/client/api/MessageId.html"
title="interface in
org.apache.pulsar.client.api">MessageId</a> messageId)</code>
<div class="block">Reset the subscription associated with this consumer to a
specific message id.</div>
</td>
</tr>
-<tr id="i20" class="altColor">
+<tr id="i21" class="rowColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../org/apache/pulsar/client/api/Consumer.html#unsubscribe--">unsubscribe</a></span>()</code>
<div class="block">Unsubscribe the consumer</div>
</td>
</tr>
-<tr id="i21" class="rowColor">
+<tr id="i22" class="altColor">
<td class="colFirst"><code>CompletableFuture<Void></code></td>
<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../org/apache/pulsar/client/api/Consumer.html#unsubscribeAsync--">unsubscribeAsync</a></span>()</code>
<div class="block">Asynchronously unsubscribe the consumer</div>
@@ -673,7 +677,7 @@ extends Closeable</pre>
<a name="seekAsync-org.apache.pulsar.client.api.MessageId-">
<!-- -->
</a>
-<ul class="blockListLast">
+<ul class="blockList">
<li class="blockList">
<h4>seekAsync</h4>
<pre>CompletableFuture<Void> seekAsync(<a
href="../../../../../org/apache/pulsar/client/api/MessageId.html"
title="interface in
org.apache.pulsar.client.api">MessageId</a> messageId)</pre>
@@ -697,6 +701,19 @@ extends Closeable</pre>
</dl>
</li>
</ul>
+<a name="isConnected--">
+<!-- -->
+</a>
+<ul class="blockListLast">
+<li class="blockList">
+<h4>isConnected</h4>
+<pre>boolean isConnected()</pre>
+<dl>
+<dt><span class="returnLabel">Returns:</span></dt>
+<dd>Whether the consumer is connected to the broker</dd>
+</dl>
+</li>
+</ul>
</li>
</ul>
</li>
diff --git a/content/api/client/org/apache/pulsar/client/api/Producer.html
b/content/api/client/org/apache/pulsar/client/api/Producer.html
index 1dd3c3d..74d143e 100644
--- a/content/api/client/org/apache/pulsar/client/api/Producer.html
+++ b/content/api/client/org/apache/pulsar/client/api/Producer.html
@@ -17,7 +17,7 @@
catch(err) {
}
//-->
-var methods =
{"i0":6,"i1":6,"i2":6,"i3":6,"i4":6,"i5":6,"i6":6,"i7":38,"i8":6,"i9":38,"i10":6};
+var methods =
{"i0":6,"i1":6,"i2":6,"i3":6,"i4":6,"i5":6,"i6":6,"i7":6,"i8":38,"i9":6,"i10":38,"i11":6};
var tabs = {65535:["t0","All Methods"],2:["t2","Instance
Methods"],4:["t3","Abstract Methods"],32:["t6","Deprecated Methods"]};
var altColor = "altColor";
var rowColor = "rowColor";
@@ -170,6 +170,10 @@ extends Closeable</pre>
<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../org/apache/pulsar/client/api/Producer.html#getTopic--">getTopic</a></span>()</code> </td>
</tr>
<tr id="i6" class="altColor">
+<td class="colFirst"><code>boolean</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../org/apache/pulsar/client/api/Producer.html#isConnected--">isConnected</a></span>()</code> </td>
+</tr>
+<tr id="i7" class="rowColor">
<td class="colFirst"><code><a
href="../../../../../org/apache/pulsar/client/api/TypedMessageBuilder.html"
title="interface in org.apache.pulsar.client.api">TypedMessageBuilder</a><<a
href="../../../../../org/apache/pulsar/client/api/Producer.html" title="type
parameter in Producer">T</a>></code></td>
<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../org/apache/pulsar/client/api/Producer.html#newMessage--">newMessage</a></span>()</code>
<div class="block">Create a new message builder
@@ -177,7 +181,7 @@ extends Closeable</pre>
This message builder allows to specify additional properties on the
message.</div>
</td>
</tr>
-<tr id="i7" class="rowColor">
+<tr id="i8" class="altColor">
<td class="colFirst"><code><a
href="../../../../../org/apache/pulsar/client/api/MessageId.html"
title="interface in org.apache.pulsar.client.api">MessageId</a></code></td>
<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../org/apache/pulsar/client/api/Producer.html#send-org.apache.pulsar.client.api.Message-">send</a></span>(<a
href="../../../../../org/apache/pulsar/client/api/Message.html"
title="interface in org.apache.pulsar.client.api">Message</a><<a
href="../../../../../org/apache/pulsar/client/api/Producer.html" title="type
parameter in Producer">T</a>> message)</code>
<div class="block"><span class="deprecatedLabel">Deprecated.</span>
@@ -186,13 +190,13 @@ extends Closeable</pre>
</div>
</td>
</tr>
-<tr id="i8" class="altColor">
+<tr id="i9" class="rowColor">
<td class="colFirst"><code><a
href="../../../../../org/apache/pulsar/client/api/MessageId.html"
title="interface in org.apache.pulsar.client.api">MessageId</a></code></td>
<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../org/apache/pulsar/client/api/Producer.html#send-T-">send</a></span>(<a
href="../../../../../org/apache/pulsar/client/api/Producer.html" title="type
parameter in Producer">T</a> message)</code>
<div class="block">Sends a message.</div>
</td>
</tr>
-<tr id="i9" class="rowColor">
+<tr id="i10" class="altColor">
<td class="colFirst"><code>CompletableFuture<<a
href="../../../../../org/apache/pulsar/client/api/MessageId.html"
title="interface in org.apache.pulsar.client.api">MessageId</a>></code></td>
<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../org/apache/pulsar/client/api/Producer.html#sendAsync-org.apache.pulsar.client.api.Message-">sendAsync</a></span>(<a
href="../../../../../org/apache/pulsar/client/api/Message.html"
title="interface in org.apache.pulsar.client.api">Message</a><<a
href="../../../../../org/apache/pulsar/client/api/Producer.html" title="type
parameter in Producer">T</a>> message)</code>
<div class="block"><span class="deprecatedLabel">Deprecated.</span>
@@ -201,7 +205,7 @@ extends Closeable</pre>
</div>
</td>
</tr>
-<tr id="i10" class="altColor">
+<tr id="i11" class="rowColor">
<td class="colFirst"><code>CompletableFuture<<a
href="../../../../../org/apache/pulsar/client/api/MessageId.html"
title="interface in org.apache.pulsar.client.api">MessageId</a>></code></td>
<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../org/apache/pulsar/client/api/Producer.html#sendAsync-T-">sendAsync</a></span>(<a
href="../../../../../org/apache/pulsar/client/api/Producer.html" title="type
parameter in Producer">T</a> message)</code>
<div class="block">Send a message asynchronously</div>
@@ -460,7 +464,7 @@ CompletableFuture<<a
href="../../../../../org/apache/pulsar/client/api/Messag
<a name="closeAsync--">
<!-- -->
</a>
-<ul class="blockListLast">
+<ul class="blockList">
<li class="blockList">
<h4>closeAsync</h4>
<pre>CompletableFuture<Void> closeAsync()</pre>
@@ -474,6 +478,19 @@ CompletableFuture<<a
href="../../../../../org/apache/pulsar/client/api/Messag
</dl>
</li>
</ul>
+<a name="isConnected--">
+<!-- -->
+</a>
+<ul class="blockListLast">
+<li class="blockList">
+<h4>isConnected</h4>
+<pre>boolean isConnected()</pre>
+<dl>
+<dt><span class="returnLabel">Returns:</span></dt>
+<dd>Whether the producer is connected to the broker</dd>
+</dl>
+</li>
+</ul>
</li>
</ul>
</li>
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 9b584a2..c15175a 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,"i6":6,"i7":6};
+var methods = {"i0":6,"i1":6,"i2":6,"i3":6,"i4":6,"i5":6,"i6":6,"i7":6,"i8":6};
var tabs = {65535:["t0","All Methods"],2:["t2","Instance
Methods"],4:["t3","Abstract Methods"]};
var altColor = "altColor";
var rowColor = "rowColor";
@@ -153,12 +153,16 @@ extends Closeable</pre>
</td>
</tr>
<tr id="i5" class="rowColor">
+<td class="colFirst"><code>boolean</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../org/apache/pulsar/client/api/Reader.html#isConnected--">isConnected</a></span>()</code> </td>
+</tr>
+<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><<a
href="../../../../../org/apache/pulsar/client/api/Reader.html" title="type
parameter in Reader">T</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="i6" class="altColor">
+<tr id="i7" 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><<a
href="../../../../../org/apache/pulsar/client/api/Reader.html" title="type
parameter in Reader">T</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>
@@ -166,7 +170,7 @@ extends Closeable</pre>
time units.</div>
</td>
</tr>
-<tr id="i7" class="rowColor">
+<tr id="i8" class="altColor">
<td class="colFirst"><code>CompletableFuture<<a
href="../../../../../org/apache/pulsar/client/api/Message.html"
title="interface in org.apache.pulsar.client.api">Message</a><<a
href="../../../../../org/apache/pulsar/client/api/Reader.html" title="type
parameter in Reader">T</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>
@@ -292,13 +296,26 @@ extends Closeable</pre>
<a name="hasMessageAvailableAsync--">
<!-- -->
</a>
-<ul class="blockListLast">
+<ul class="blockList">
<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>
+<a name="isConnected--">
+<!-- -->
+</a>
+<ul class="blockListLast">
+<li class="blockList">
+<h4>isConnected</h4>
+<pre>boolean isConnected()</pre>
+<dl>
+<dt><span class="returnLabel">Returns:</span></dt>
+<dd>Whether the reader is connected to the broker</dd>
+</dl>
+</li>
+</ul>
</li>
</ul>
</li>
--
To stop receiving notification emails like this one, please contact
[email protected].