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 <bui...@apache.org> 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 mme...@apache.org.