Skip to content

Commit 6aaaa2e

Browse files
rabbitmq-cirabbitmq-ci
committed
Merge pull request #374 from rabbitmq/flow-control
Consumer flow strategy (take two)
1 parent e885538 commit 6aaaa2e

File tree

534 files changed

+5182
-1034
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

534 files changed

+5182
-1034
lines changed

‎0.12.0-SNAPSHOT/api/allclasses-index.html

Lines changed: 82 additions & 59 deletions
Large diffs are not rendered by default.

‎0.12.0-SNAPSHOT/api/allpackages-index.html

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang="en">
33
<head>
4-
<!-- Generated by javadoc (17) on Mon Jul 17 06:56:08 UTC 2023 -->
4+
<!-- Generated by javadoc (17) on Mon Jul 17 08:53:14 UTC 2023 -->
55
<title>All Packages (RabbitMQ Stream Java Client 0.12.0-SNAPSHOT API)</title>
66
<meta name="viewport" content="width=device-width, initial-scale=1">
77
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">

‎0.12.0-SNAPSHOT/api/com/rabbitmq/stream/Address.html

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang="en">
33
<head>
4-
<!-- Generated by javadoc (17) on Mon Jul 17 06:56:08 UTC 2023 -->
4+
<!-- Generated by javadoc (17) on Mon Jul 17 08:53:14 UTC 2023 -->
55
<title>Address (RabbitMQ Stream Java Client 0.12.0-SNAPSHOT API)</title>
66
<meta name="viewport" content="width=device-width, initial-scale=1">
77
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">

‎0.12.0-SNAPSHOT/api/com/rabbitmq/stream/AddressResolver.html

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang="en">
33
<head>
4-
<!-- Generated by javadoc (17) on Mon Jul 17 06:56:08 UTC 2023 -->
4+
<!-- Generated by javadoc (17) on Mon Jul 17 08:53:14 UTC 2023 -->
55
<title>AddressResolver (RabbitMQ Stream Java Client 0.12.0-SNAPSHOT API)</title>
66
<meta name="viewport" content="width=device-width, initial-scale=1">
77
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">

‎0.12.0-SNAPSHOT/api/com/rabbitmq/stream/AuthenticationFailureException.html

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang="en">
33
<head>
4-
<!-- Generated by javadoc (17) on Mon Jul 17 06:56:08 UTC 2023 -->
4+
<!-- Generated by javadoc (17) on Mon Jul 17 08:53:14 UTC 2023 -->
55
<title>AuthenticationFailureException (RabbitMQ Stream Java Client 0.12.0-SNAPSHOT API)</title>
66
<meta name="viewport" content="width=device-width, initial-scale=1">
77
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">

‎0.12.0-SNAPSHOT/api/com/rabbitmq/stream/BackOffDelayPolicy.FixedWithInitialDelayAndTimeoutBackOffPolicy.html

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang="en">
33
<head>
4-
<!-- Generated by javadoc (17) on Mon Jul 17 06:56:08 UTC 2023 -->
4+
<!-- Generated by javadoc (17) on Mon Jul 17 08:53:14 UTC 2023 -->
55
<title>BackOffDelayPolicy.FixedWithInitialDelayAndTimeoutBackOffPolicy (RabbitMQ Stream Java Client 0.12.0-SNAPSHOT API)</title>
66
<meta name="viewport" content="width=device-width, initial-scale=1">
77
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">

‎0.12.0-SNAPSHOT/api/com/rabbitmq/stream/BackOffDelayPolicy.FixedWithInitialDelayBackOffPolicy.html

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang="en">
33
<head>
4-
<!-- Generated by javadoc (17) on Mon Jul 17 06:56:08 UTC 2023 -->
4+
<!-- Generated by javadoc (17) on Mon Jul 17 08:53:14 UTC 2023 -->
55
<title>BackOffDelayPolicy.FixedWithInitialDelayBackOffPolicy (RabbitMQ Stream Java Client 0.12.0-SNAPSHOT API)</title>
66
<meta name="viewport" content="width=device-width, initial-scale=1">
77
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">

‎0.12.0-SNAPSHOT/api/com/rabbitmq/stream/BackOffDelayPolicy.html

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang="en">
33
<head>
4-
<!-- Generated by javadoc (17) on Mon Jul 17 06:56:08 UTC 2023 -->
4+
<!-- Generated by javadoc (17) on Mon Jul 17 08:53:14 UTC 2023 -->
55
<title>BackOffDelayPolicy (RabbitMQ Stream Java Client 0.12.0-SNAPSHOT API)</title>
66
<meta name="viewport" content="width=device-width, initial-scale=1">
77
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">

‎0.12.0-SNAPSHOT/api/com/rabbitmq/stream/ByteCapacity.html

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang="en">
33
<head>
4-
<!-- Generated by javadoc (17) on Mon Jul 17 06:56:08 UTC 2023 -->
4+
<!-- Generated by javadoc (17) on Mon Jul 17 08:53:14 UTC 2023 -->
55
<title>ByteCapacity (RabbitMQ Stream Java Client 0.12.0-SNAPSHOT API)</title>
66
<meta name="viewport" content="width=device-width, initial-scale=1">
77
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">

‎0.12.0-SNAPSHOT/api/com/rabbitmq/stream/ChunkChecksum.html

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang="en">
33
<head>
4-
<!-- Generated by javadoc (17) on Mon Jul 17 06:56:08 UTC 2023 -->
4+
<!-- Generated by javadoc (17) on Mon Jul 17 08:53:14 UTC 2023 -->
55
<title>ChunkChecksum (RabbitMQ Stream Java Client 0.12.0-SNAPSHOT API)</title>
66
<meta name="viewport" content="width=device-width, initial-scale=1">
77
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">

‎0.12.0-SNAPSHOT/api/com/rabbitmq/stream/ChunkChecksumValidationException.html

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang="en">
33
<head>
4-
<!-- Generated by javadoc (17) on Mon Jul 17 06:56:08 UTC 2023 -->
4+
<!-- Generated by javadoc (17) on Mon Jul 17 08:53:14 UTC 2023 -->
55
<title>ChunkChecksumValidationException (RabbitMQ Stream Java Client 0.12.0-SNAPSHOT API)</title>
66
<meta name="viewport" content="width=device-width, initial-scale=1">
77
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">

‎0.12.0-SNAPSHOT/api/com/rabbitmq/stream/Codec.EncodedMessage.html

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang="en">
33
<head>
4-
<!-- Generated by javadoc (17) on Mon Jul 17 06:56:08 UTC 2023 -->
4+
<!-- Generated by javadoc (17) on Mon Jul 17 08:53:14 UTC 2023 -->
55
<title>Codec.EncodedMessage (RabbitMQ Stream Java Client 0.12.0-SNAPSHOT API)</title>
66
<meta name="viewport" content="width=device-width, initial-scale=1">
77
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">

‎0.12.0-SNAPSHOT/api/com/rabbitmq/stream/Codec.html

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang="en">
33
<head>
4-
<!-- Generated by javadoc (17) on Mon Jul 17 06:56:08 UTC 2023 -->
4+
<!-- Generated by javadoc (17) on Mon Jul 17 08:53:14 UTC 2023 -->
55
<title>Codec (RabbitMQ Stream Java Client 0.12.0-SNAPSHOT API)</title>
66
<meta name="viewport" content="width=device-width, initial-scale=1">
77
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">

‎0.12.0-SNAPSHOT/api/com/rabbitmq/stream/ConfirmationHandler.html

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang="en">
33
<head>
4-
<!-- Generated by javadoc (17) on Mon Jul 17 06:56:08 UTC 2023 -->
4+
<!-- Generated by javadoc (17) on Mon Jul 17 08:53:14 UTC 2023 -->
55
<title>ConfirmationHandler (RabbitMQ Stream Java Client 0.12.0-SNAPSHOT API)</title>
66
<meta name="viewport" content="width=device-width, initial-scale=1">
77
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">

‎0.12.0-SNAPSHOT/api/com/rabbitmq/stream/ConfirmationStatus.html

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang="en">
33
<head>
4-
<!-- Generated by javadoc (17) on Mon Jul 17 06:56:08 UTC 2023 -->
4+
<!-- Generated by javadoc (17) on Mon Jul 17 08:53:14 UTC 2023 -->
55
<title>ConfirmationStatus (RabbitMQ Stream Java Client 0.12.0-SNAPSHOT API)</title>
66
<meta name="viewport" content="width=device-width, initial-scale=1">
77
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">

‎0.12.0-SNAPSHOT/api/com/rabbitmq/stream/Constants.html

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang="en">
33
<head>
4-
<!-- Generated by javadoc (17) on Mon Jul 17 06:56:08 UTC 2023 -->
4+
<!-- Generated by javadoc (17) on Mon Jul 17 08:53:14 UTC 2023 -->
55
<title>Constants (RabbitMQ Stream Java Client 0.12.0-SNAPSHOT API)</title>
66
<meta name="viewport" content="width=device-width, initial-scale=1">
77
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">

‎0.12.0-SNAPSHOT/api/com/rabbitmq/stream/Consumer.html

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang="en">
33
<head>
4-
<!-- Generated by javadoc (17) on Mon Jul 17 06:56:08 UTC 2023 -->
4+
<!-- Generated by javadoc (17) on Mon Jul 17 08:53:14 UTC 2023 -->
55
<title>Consumer (RabbitMQ Stream Java Client 0.12.0-SNAPSHOT API)</title>
66
<meta name="viewport" content="width=device-width, initial-scale=1">
77
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">

‎0.12.0-SNAPSHOT/api/com/rabbitmq/stream/ConsumerBuilder.AutoTrackingStrategy.html

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang="en">
33
<head>
4-
<!-- Generated by javadoc (17) on Mon Jul 17 06:56:08 UTC 2023 -->
4+
<!-- Generated by javadoc (17) on Mon Jul 17 08:53:14 UTC 2023 -->
55
<title>ConsumerBuilder.AutoTrackingStrategy (RabbitMQ Stream Java Client 0.12.0-SNAPSHOT API)</title>
66
<meta name="viewport" content="width=device-width, initial-scale=1">
77
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">

‎0.12.0-SNAPSHOT/api/com/rabbitmq/stream/ConsumerBuilder.FilterConfiguration.html

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang="en">
33
<head>
4-
<!-- Generated by javadoc (17) on Mon Jul 17 06:56:08 UTC 2023 -->
4+
<!-- Generated by javadoc (17) on Mon Jul 17 08:53:14 UTC 2023 -->
55
<title>ConsumerBuilder.FilterConfiguration (RabbitMQ Stream Java Client 0.12.0-SNAPSHOT API)</title>
66
<meta name="viewport" content="width=device-width, initial-scale=1">
77
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">

‎0.12.0-SNAPSHOT/api/com/rabbitmq/stream/ConsumerBuilder.FlowConfiguration.html

Lines changed: 51 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang="en">
33
<head>
4-
<!-- Generated by javadoc (17) on Mon Jul 17 06:56:08 UTC 2023 -->
4+
<!-- Generated by javadoc (17) on Mon Jul 17 08:53:14 UTC 2023 -->
55
<title>ConsumerBuilder.FlowConfiguration (RabbitMQ Stream Java Client 0.12.0-SNAPSHOT API)</title>
66
<meta name="viewport" content="width=device-width, initial-scale=1">
77
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">
@@ -79,10 +79,19 @@ <h1 title="Interface ConsumerBuilder.FlowConfiguration" class="title">Interface
7979
</dl>
8080
<hr>
8181
<div class="type-signature"><span class="modifiers">public static interface </span><span class="element-name type-name-label">ConsumerBuilder.FlowConfiguration</span></div>
82-
<div class="block">Message flow configuration.</div>
82+
<div class="block">Message flow configuration.
83+
84+
<p>The default configuration uses <a href="ConsumerFlowStrategy.html#creditOnChunkArrival()"><code>ConsumerFlowStrategy.creditOnChunkArrival()</code></a>.</div>
8385
<dl class="notes">
8486
<dt>Since:</dt>
8587
<dd>0.11.0</dd>
88+
<dt>See Also:</dt>
89+
<dd>
90+
<ul class="see-list-long">
91+
<li><a href="ConsumerFlowStrategy.html#creditOnChunkArrival()"><code>ConsumerFlowStrategy.creditOnChunkArrival()</code></a></li>
92+
<li><a href="MessageHandler.Context.html#processed()"><code>MessageHandler.Context.processed()</code></a></li>
93+
</ul>
94+
</dd>
8695
</dl>
8796
</section>
8897
<section class="summary">
@@ -108,6 +117,11 @@ <h2>Method Summary</h2>
108117
<div class="col-last odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab3">
109118
<div class="block">The number of initial credits for the subscription.</div>
110119
</div>
120+
<div class="col-first even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab3"><code><a href="ConsumerBuilder.FlowConfiguration.html" title="interface in com.rabbitmq.stream">ConsumerBuilder.FlowConfiguration</a></code></div>
121+
<div class="col-second even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab3"><code><a href="#strategy(com.rabbitmq.stream.ConsumerFlowStrategy)" class="member-name-link">strategy</a><wbr>(<a href="ConsumerFlowStrategy.html" title="interface in com.rabbitmq.stream">ConsumerFlowStrategy</a>&nbsp;strategy)</code></div>
122+
<div class="col-last even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab3">
123+
<div class="block">Flow strategy to use</div>
124+
</div>
111125
</div>
112126
</div>
113127
</div>
@@ -128,12 +142,46 @@ <h3>initialCredits</h3>
128142
<div class="member-signature"><span class="return-type"><a href="ConsumerBuilder.FlowConfiguration.html" title="interface in com.rabbitmq.stream">ConsumerBuilder.FlowConfiguration</a></span>&nbsp;<span class="element-name">initialCredits</span><wbr><span class="parameters">(int&nbsp;initialCredits)</span></div>
129143
<div class="block">The number of initial credits for the subscription.
130144

131-
<p>Default is 1.</div>
145+
<p>Default is 1.
146+
147+
<p>This calls uses <a href="ConsumerFlowStrategy.html#creditOnChunkArrival(int)"><code>ConsumerFlowStrategy.creditOnChunkArrival(int)</code></a>.</div>
132148
<dl class="notes">
133149
<dt>Parameters:</dt>
134150
<dd><code>initialCredits</code> - the number of initial credits</dd>
135151
<dt>Returns:</dt>
136152
<dd>this configuration instance</dd>
153+
<dt>See Also:</dt>
154+
<dd>
155+
<ul class="see-list-long">
156+
<li><a href="ConsumerFlowStrategy.html#creditOnChunkArrival(int)"><code>ConsumerFlowStrategy.creditOnChunkArrival(int)</code></a></li>
157+
</ul>
158+
</dd>
159+
</dl>
160+
</section>
161+
</li>
162+
<li>
163+
<section class="detail" id="strategy(com.rabbitmq.stream.ConsumerFlowStrategy)">
164+
<h3>strategy</h3>
165+
<div class="member-signature"><span class="return-type"><a href="ConsumerBuilder.FlowConfiguration.html" title="interface in com.rabbitmq.stream">ConsumerBuilder.FlowConfiguration</a></span>&nbsp;<span class="element-name">strategy</span><wbr><span class="parameters">(<a href="ConsumerFlowStrategy.html" title="interface in com.rabbitmq.stream">ConsumerFlowStrategy</a>&nbsp;strategy)</span></div>
166+
<div class="block">Flow strategy to use</div>
167+
<dl class="notes">
168+
<dt>Parameters:</dt>
169+
<dd><code>strategy</code> - the strategy to use</dd>
170+
<dt>Returns:</dt>
171+
<dd>this configuration instance</dd>
172+
<dt>Since:</dt>
173+
<dd>0.12.0</dd>
174+
<dt>See Also:</dt>
175+
<dd>
176+
<ul class="see-list-long">
177+
<li><a href="ConsumerFlowStrategy.html" title="interface in com.rabbitmq.stream"><code>ConsumerFlowStrategy</code></a></li>
178+
<li><a href="ConsumerFlowStrategy.html#creditOnChunkArrival()"><code>ConsumerFlowStrategy.creditOnChunkArrival()</code></a></li>
179+
<li><a href="ConsumerFlowStrategy.html#creditOnChunkArrival(int)"><code>ConsumerFlowStrategy.creditOnChunkArrival(int)</code></a></li>
180+
<li><a href="ConsumerFlowStrategy.html#creditWhenHalfMessagesProcessed()"><code>ConsumerFlowStrategy.creditWhenHalfMessagesProcessed()</code></a></li>
181+
<li><a href="ConsumerFlowStrategy.html#creditWhenHalfMessagesProcessed(int)"><code>ConsumerFlowStrategy.creditWhenHalfMessagesProcessed(int)</code></a></li>
182+
<li><a href="ConsumerFlowStrategy.html#creditOnProcessedMessageCount(int,double)"><code>ConsumerFlowStrategy.creditOnProcessedMessageCount(int, double)</code></a></li>
183+
</ul>
184+
</dd>
137185
</dl>
138186
</section>
139187
</li>

‎0.12.0-SNAPSHOT/api/com/rabbitmq/stream/ConsumerBuilder.ManualTrackingStrategy.html

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang="en">
33
<head>
4-
<!-- Generated by javadoc (17) on Mon Jul 17 06:56:08 UTC 2023 -->
4+
<!-- Generated by javadoc (17) on Mon Jul 17 08:53:14 UTC 2023 -->
55
<title>ConsumerBuilder.ManualTrackingStrategy (RabbitMQ Stream Java Client 0.12.0-SNAPSHOT API)</title>
66
<meta name="viewport" content="width=device-width, initial-scale=1">
77
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">

‎0.12.0-SNAPSHOT/api/com/rabbitmq/stream/ConsumerBuilder.html

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang="en">
33
<head>
4-
<!-- Generated by javadoc (17) on Mon Jul 17 06:56:08 UTC 2023 -->
4+
<!-- Generated by javadoc (17) on Mon Jul 17 08:53:14 UTC 2023 -->
55
<title>ConsumerBuilder (RabbitMQ Stream Java Client 0.12.0-SNAPSHOT API)</title>
66
<meta name="viewport" content="width=device-width, initial-scale=1">
77
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">
@@ -437,6 +437,13 @@ <h3>flow</h3>
437437
<dd>the flow configuration</dd>
438438
<dt>Since:</dt>
439439
<dd>0.11.0</dd>
440+
<dt>See Also:</dt>
441+
<dd>
442+
<ul class="see-list-long">
443+
<li><a href="ConsumerFlowStrategy.html#creditOnChunkArrival()"><code>ConsumerFlowStrategy.creditOnChunkArrival()</code></a></li>
444+
<li><a href="MessageHandler.Context.html#processed()"><code>MessageHandler.Context.processed()</code></a></li>
445+
</ul>
446+
</dd>
440447
</dl>
441448
</section>
442449
</li>

0 commit comments

Comments
 (0)