|
2 | 2 | <!-- NewPage -->
|
3 | 3 | <html lang="en">
|
4 | 4 | <head>
|
5 |
| -<!-- Generated by javadoc (1.8.0_302) on Tue Oct 26 08:18:24 GMT 2021 --> |
| 5 | +<!-- Generated by javadoc (1.8.0_302) on Tue Nov 02 14:49:48 GMT 2021 --> |
6 | 6 | <meta http-equiv="Content-Type" content="text/html; charset=UTF-8">
|
7 | 7 | <title>ConsumerBuilder (RabbitMQ Stream Java Client 0.5.0-SNAPSHOT API)</title>
|
8 |
| -<meta name="date" content="2021-10-26"> |
| 8 | +<meta name="date" content="2021-11-02"> |
9 | 9 | <link rel="stylesheet" type="text/css" href="../../../stylesheet.css" title="Style">
|
10 | 10 | <script type="text/javascript" src="../../../script.js"></script>
|
11 | 11 | </head>
|
|
19 | 19 | catch(err) {
|
20 | 20 | }
|
21 | 21 | //-->
|
22 |
| -var methods = {"i0":6,"i1":6,"i2":6,"i3":6,"i4":6,"i5":6,"i6":6,"i7":6}; |
| 22 | +var methods = {"i0":6,"i1":6,"i2":6,"i3":6,"i4":6,"i5":6,"i6":6,"i7":6,"i8":6}; |
23 | 23 | var tabs = {65535:["t0","All Methods"],2:["t2","Instance Methods"],4:["t3","Abstract Methods"]};
|
24 | 24 | var altColor = "altColor";
|
25 | 25 | var rowColor = "rowColor";
|
@@ -193,6 +193,12 @@ <h3>Method Summary</h3>
|
193 | 193 | </tr>
|
194 | 194 | <tr id="i7" class="rowColor">
|
195 | 195 | <td class="colFirst"><code><a href="../../../com/rabbitmq/stream/ConsumerBuilder.html" title="interface in com.rabbitmq.stream">ConsumerBuilder</a></code></td>
|
| 196 | +<td class="colLast"><code><span class="memberNameLink"><a href="../../../com/rabbitmq/stream/ConsumerBuilder.html#subscriptionListener-com.rabbitmq.stream.SubscriptionListener-">subscriptionListener</a></span>(<a href="../../../com/rabbitmq/stream/SubscriptionListener.html" title="interface in com.rabbitmq.stream">SubscriptionListener</a> subscriptionListener)</code> |
| 197 | +<div class="block">Callback on subscription.</div> |
| 198 | +</td> |
| 199 | +</tr> |
| 200 | +<tr id="i8" class="altColor"> |
| 201 | +<td class="colFirst"><code><a href="../../../com/rabbitmq/stream/ConsumerBuilder.html" title="interface in com.rabbitmq.stream">ConsumerBuilder</a></code></td> |
196 | 202 | <td class="colLast"><code><span class="memberNameLink"><a href="../../../com/rabbitmq/stream/ConsumerBuilder.html#superStream-java.lang.String-">superStream</a></span>(<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> superStream)</code>
|
197 | 203 | <div class="block">Set the consumer to consume from a super stream (partitioned stream).</div>
|
198 | 204 | </td>
|
@@ -298,6 +304,26 @@ <h4>name</h4>
|
298 | 304 | </dl>
|
299 | 305 | </li>
|
300 | 306 | </ul>
|
| 307 | +<a name="subscriptionListener-com.rabbitmq.stream.SubscriptionListener-"> |
| 308 | +<!-- --> |
| 309 | +</a> |
| 310 | +<ul class="blockList"> |
| 311 | +<li class="blockList"> |
| 312 | +<h4>subscriptionListener</h4> |
| 313 | +<pre><a href="../../../com/rabbitmq/stream/ConsumerBuilder.html" title="interface in com.rabbitmq.stream">ConsumerBuilder</a> subscriptionListener(<a href="../../../com/rabbitmq/stream/SubscriptionListener.html" title="interface in com.rabbitmq.stream">SubscriptionListener</a> subscriptionListener)</pre> |
| 314 | +<div class="block">Callback on subscription. |
| 315 | + |
| 316 | + <p>Can be used to set the offset specification before subscribing to the stream.</div> |
| 317 | +<dl> |
| 318 | +<dt><span class="paramLabel">Parameters:</span></dt> |
| 319 | +<dd><code>subscriptionListener</code> - the listener</dd> |
| 320 | +<dt><span class="returnLabel">Returns:</span></dt> |
| 321 | +<dd>this builder instance</dd> |
| 322 | +<dt><span class="seeLabel">See Also:</span></dt> |
| 323 | +<dd><a href="../../../com/rabbitmq/stream/SubscriptionListener.html" title="interface in com.rabbitmq.stream"><code>SubscriptionListener</code></a></dd> |
| 324 | +</dl> |
| 325 | +</li> |
| 326 | +</ul> |
301 | 327 | <a name="manualTrackingStrategy--">
|
302 | 328 | <!-- -->
|
303 | 329 | </a>
|
|
0 commit comments