Skip to content

Commit 9d5ef57

Browse files
rabbitmq-cirabbitmq-ci
committed
Merge pull request #671 from rabbitmq/dynamic-batch-is-the-new-default
Use dynamic batch publishing by default
1 parent 941f235 commit 9d5ef57

File tree

578 files changed

+656
-610
lines changed

Some content is hidden

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

578 files changed

+656
-610
lines changed

Diff for: ‎0.21.0-SNAPSHOT/api/allclasses-index.html

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang>
33
<head>
4-
<!-- Generated by javadoc (21) on Wed Dec 11 14:48:30 UTC 2024 -->
4+
<!-- Generated by javadoc (21) on Wed Dec 11 15:30:49 UTC 2024 -->
55
<title>All Classes and Interfaces (RabbitMQ Stream Java Client 0.21.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">

Diff for: ‎0.21.0-SNAPSHOT/api/allpackages-index.html

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang>
33
<head>
4-
<!-- Generated by javadoc (21) on Wed Dec 11 14:48:30 UTC 2024 -->
4+
<!-- Generated by javadoc (21) on Wed Dec 11 15:30:49 UTC 2024 -->
55
<title>All Packages (RabbitMQ Stream Java Client 0.21.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">

Diff for: ‎0.21.0-SNAPSHOT/api/com/rabbitmq/stream/Address.html

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang>
33
<head>
4-
<!-- Generated by javadoc (21) on Wed Dec 11 14:48:30 UTC 2024 -->
4+
<!-- Generated by javadoc (21) on Wed Dec 11 15:30:49 UTC 2024 -->
55
<title>Address (RabbitMQ Stream Java Client 0.21.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">

Diff for: ‎0.21.0-SNAPSHOT/api/com/rabbitmq/stream/AddressResolver.html

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang>
33
<head>
4-
<!-- Generated by javadoc (21) on Wed Dec 11 14:48:30 UTC 2024 -->
4+
<!-- Generated by javadoc (21) on Wed Dec 11 15:30:49 UTC 2024 -->
55
<title>AddressResolver (RabbitMQ Stream Java Client 0.21.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">

Diff for: ‎0.21.0-SNAPSHOT/api/com/rabbitmq/stream/AuthenticationFailureException.html

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang>
33
<head>
4-
<!-- Generated by javadoc (21) on Wed Dec 11 14:48:30 UTC 2024 -->
4+
<!-- Generated by javadoc (21) on Wed Dec 11 15:30:49 UTC 2024 -->
55
<title>AuthenticationFailureException (RabbitMQ Stream Java Client 0.21.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">

Diff for: ‎0.21.0-SNAPSHOT/api/com/rabbitmq/stream/BackOffDelayPolicy.FixedWithInitialDelayAndTimeoutBackOffPolicy.html

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang>
33
<head>
4-
<!-- Generated by javadoc (21) on Wed Dec 11 14:48:30 UTC 2024 -->
4+
<!-- Generated by javadoc (21) on Wed Dec 11 15:30:49 UTC 2024 -->
55
<title>BackOffDelayPolicy.FixedWithInitialDelayAndTimeoutBackOffPolicy (RabbitMQ Stream Java Client 0.21.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">

Diff for: ‎0.21.0-SNAPSHOT/api/com/rabbitmq/stream/BackOffDelayPolicy.FixedWithInitialDelayBackOffPolicy.html

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang>
33
<head>
4-
<!-- Generated by javadoc (21) on Wed Dec 11 14:48:30 UTC 2024 -->
4+
<!-- Generated by javadoc (21) on Wed Dec 11 15:30:49 UTC 2024 -->
55
<title>BackOffDelayPolicy.FixedWithInitialDelayBackOffPolicy (RabbitMQ Stream Java Client 0.21.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">

Diff for: ‎0.21.0-SNAPSHOT/api/com/rabbitmq/stream/BackOffDelayPolicy.html

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang>
33
<head>
4-
<!-- Generated by javadoc (21) on Wed Dec 11 14:48:30 UTC 2024 -->
4+
<!-- Generated by javadoc (21) on Wed Dec 11 15:30:49 UTC 2024 -->
55
<title>BackOffDelayPolicy (RabbitMQ Stream Java Client 0.21.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">

Diff for: ‎0.21.0-SNAPSHOT/api/com/rabbitmq/stream/ByteCapacity.html

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang>
33
<head>
4-
<!-- Generated by javadoc (21) on Wed Dec 11 14:48:30 UTC 2024 -->
4+
<!-- Generated by javadoc (21) on Wed Dec 11 15:30:49 UTC 2024 -->
55
<title>ByteCapacity (RabbitMQ Stream Java Client 0.21.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">

Diff for: ‎0.21.0-SNAPSHOT/api/com/rabbitmq/stream/ChunkChecksum.html

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang>
33
<head>
4-
<!-- Generated by javadoc (21) on Wed Dec 11 14:48:30 UTC 2024 -->
4+
<!-- Generated by javadoc (21) on Wed Dec 11 15:30:49 UTC 2024 -->
55
<title>ChunkChecksum (RabbitMQ Stream Java Client 0.21.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">

Diff for: ‎0.21.0-SNAPSHOT/api/com/rabbitmq/stream/ChunkChecksumValidationException.html

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang>
33
<head>
4-
<!-- Generated by javadoc (21) on Wed Dec 11 14:48:30 UTC 2024 -->
4+
<!-- Generated by javadoc (21) on Wed Dec 11 15:30:49 UTC 2024 -->
55
<title>ChunkChecksumValidationException (RabbitMQ Stream Java Client 0.21.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">

Diff for: ‎0.21.0-SNAPSHOT/api/com/rabbitmq/stream/Codec.EncodedMessage.html

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang>
33
<head>
4-
<!-- Generated by javadoc (21) on Wed Dec 11 14:48:30 UTC 2024 -->
4+
<!-- Generated by javadoc (21) on Wed Dec 11 15:30:49 UTC 2024 -->
55
<title>Codec.EncodedMessage (RabbitMQ Stream Java Client 0.21.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">

Diff for: ‎0.21.0-SNAPSHOT/api/com/rabbitmq/stream/Codec.html

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang>
33
<head>
4-
<!-- Generated by javadoc (21) on Wed Dec 11 14:48:30 UTC 2024 -->
4+
<!-- Generated by javadoc (21) on Wed Dec 11 15:30:49 UTC 2024 -->
55
<title>Codec (RabbitMQ Stream Java Client 0.21.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">

Diff for: ‎0.21.0-SNAPSHOT/api/com/rabbitmq/stream/ConfirmationHandler.html

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang>
33
<head>
4-
<!-- Generated by javadoc (21) on Wed Dec 11 14:48:30 UTC 2024 -->
4+
<!-- Generated by javadoc (21) on Wed Dec 11 15:30:49 UTC 2024 -->
55
<title>ConfirmationHandler (RabbitMQ Stream Java Client 0.21.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">

Diff for: ‎0.21.0-SNAPSHOT/api/com/rabbitmq/stream/ConfirmationStatus.html

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang>
33
<head>
4-
<!-- Generated by javadoc (21) on Wed Dec 11 14:48:30 UTC 2024 -->
4+
<!-- Generated by javadoc (21) on Wed Dec 11 15:30:49 UTC 2024 -->
55
<title>ConfirmationStatus (RabbitMQ Stream Java Client 0.21.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">

Diff for: ‎0.21.0-SNAPSHOT/api/com/rabbitmq/stream/Constants.html

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang>
33
<head>
4-
<!-- Generated by javadoc (21) on Wed Dec 11 14:48:30 UTC 2024 -->
4+
<!-- Generated by javadoc (21) on Wed Dec 11 15:30:49 UTC 2024 -->
55
<title>Constants (RabbitMQ Stream Java Client 0.21.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">

Diff for: ‎0.21.0-SNAPSHOT/api/com/rabbitmq/stream/Consumer.html

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang>
33
<head>
4-
<!-- Generated by javadoc (21) on Wed Dec 11 14:48:30 UTC 2024 -->
4+
<!-- Generated by javadoc (21) on Wed Dec 11 15:30:49 UTC 2024 -->
55
<title>Consumer (RabbitMQ Stream Java Client 0.21.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">

Diff for: ‎0.21.0-SNAPSHOT/api/com/rabbitmq/stream/ConsumerBuilder.AutoTrackingStrategy.html

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang>
33
<head>
4-
<!-- Generated by javadoc (21) on Wed Dec 11 14:48:30 UTC 2024 -->
4+
<!-- Generated by javadoc (21) on Wed Dec 11 15:30:49 UTC 2024 -->
55
<title>ConsumerBuilder.AutoTrackingStrategy (RabbitMQ Stream Java Client 0.21.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">

Diff for: ‎0.21.0-SNAPSHOT/api/com/rabbitmq/stream/ConsumerBuilder.FilterConfiguration.html

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang>
33
<head>
4-
<!-- Generated by javadoc (21) on Wed Dec 11 14:48:30 UTC 2024 -->
4+
<!-- Generated by javadoc (21) on Wed Dec 11 15:30:49 UTC 2024 -->
55
<title>ConsumerBuilder.FilterConfiguration (RabbitMQ Stream Java Client 0.21.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">

Diff for: ‎0.21.0-SNAPSHOT/api/com/rabbitmq/stream/ConsumerBuilder.FlowConfiguration.html

+7-3
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang>
33
<head>
4-
<!-- Generated by javadoc (21) on Wed Dec 11 14:48:30 UTC 2024 -->
4+
<!-- Generated by javadoc (21) on Wed Dec 11 15:30:49 UTC 2024 -->
55
<title>ConsumerBuilder.FlowConfiguration (RabbitMQ Stream Java Client 0.21.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">
@@ -156,9 +156,13 @@ <h3>initialCredits</h3>
156156
<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>
157157
<div class="block">The number of initial credits for the subscription.
158158

159-
<p>Default is 1.
159+
<p>Default is 10.
160160

161-
<p>This calls uses <a href="ConsumerFlowStrategy.html#creditOnChunkArrival(int)"><code>ConsumerFlowStrategy.creditOnChunkArrival(int)</code></a>.</div>
161+
<p>This calls uses <a href="ConsumerFlowStrategy.html#creditOnChunkArrival(int)"><code>ConsumerFlowStrategy.creditOnChunkArrival(int)</code></a>.
162+
163+
<p>Use a small value like 1 for streams with large chunks (several hundreds of messages per
164+
chunk) and higher values (5 or more) for streams with small chunks (1 or a few messages per
165+
chunk).</div>
162166
<dl class="notes">
163167
<dt>Parameters:</dt>
164168
<dd><code>initialCredits</code> - the number of initial credits</dd>

Diff for: ‎0.21.0-SNAPSHOT/api/com/rabbitmq/stream/ConsumerBuilder.ManualTrackingStrategy.html

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang>
33
<head>
4-
<!-- Generated by javadoc (21) on Wed Dec 11 14:48:30 UTC 2024 -->
4+
<!-- Generated by javadoc (21) on Wed Dec 11 15:30:49 UTC 2024 -->
55
<title>ConsumerBuilder.ManualTrackingStrategy (RabbitMQ Stream Java Client 0.21.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">

Diff for: ‎0.21.0-SNAPSHOT/api/com/rabbitmq/stream/ConsumerBuilder.html

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang>
33
<head>
4-
<!-- Generated by javadoc (21) on Wed Dec 11 14:48:30 UTC 2024 -->
4+
<!-- Generated by javadoc (21) on Wed Dec 11 15:30:49 UTC 2024 -->
55
<title>ConsumerBuilder (RabbitMQ Stream Java Client 0.21.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">

Diff for: ‎0.21.0-SNAPSHOT/api/com/rabbitmq/stream/ConsumerFlowStrategy.Context.html

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang>
33
<head>
4-
<!-- Generated by javadoc (21) on Wed Dec 11 14:48:30 UTC 2024 -->
4+
<!-- Generated by javadoc (21) on Wed Dec 11 15:30:49 UTC 2024 -->
55
<title>ConsumerFlowStrategy.Context (RabbitMQ Stream Java Client 0.21.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">

Diff for: ‎0.21.0-SNAPSHOT/api/com/rabbitmq/stream/ConsumerFlowStrategy.CreditOnChunkArrivalConsumerFlowStrategy.html

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang>
33
<head>
4-
<!-- Generated by javadoc (21) on Wed Dec 11 14:48:30 UTC 2024 -->
4+
<!-- Generated by javadoc (21) on Wed Dec 11 15:30:49 UTC 2024 -->
55
<title>ConsumerFlowStrategy.CreditOnChunkArrivalConsumerFlowStrategy (RabbitMQ Stream Java Client 0.21.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">

Diff for: ‎0.21.0-SNAPSHOT/api/com/rabbitmq/stream/ConsumerFlowStrategy.MessageCountConsumerFlowStrategy.html

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang>
33
<head>
4-
<!-- Generated by javadoc (21) on Wed Dec 11 14:48:30 UTC 2024 -->
4+
<!-- Generated by javadoc (21) on Wed Dec 11 15:30:49 UTC 2024 -->
55
<title>ConsumerFlowStrategy.MessageCountConsumerFlowStrategy (RabbitMQ Stream Java Client 0.21.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">

Diff for: ‎0.21.0-SNAPSHOT/api/com/rabbitmq/stream/ConsumerFlowStrategy.MessageProcessedCallback.html

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang>
33
<head>
4-
<!-- Generated by javadoc (21) on Wed Dec 11 14:48:30 UTC 2024 -->
4+
<!-- Generated by javadoc (21) on Wed Dec 11 15:30:49 UTC 2024 -->
55
<title>ConsumerFlowStrategy.MessageProcessedCallback (RabbitMQ Stream Java Client 0.21.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">

Diff for: ‎0.21.0-SNAPSHOT/api/com/rabbitmq/stream/ConsumerFlowStrategy.html

+15-3
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang>
33
<head>
4-
<!-- Generated by javadoc (21) on Wed Dec 11 14:48:30 UTC 2024 -->
4+
<!-- Generated by javadoc (21) on Wed Dec 11 15:30:49 UTC 2024 -->
55
<title>ConsumerFlowStrategy (RabbitMQ Stream Java Client 0.21.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">
@@ -186,7 +186,7 @@ <h2>Method Summary</h2>
186186
<div class="col-first odd-row-color method-summary-table method-summary-table-tab1"><code>static <a href="ConsumerFlowStrategy.html" title="interface in com.rabbitmq.stream">ConsumerFlowStrategy</a></code></div>
187187
<div class="col-second odd-row-color method-summary-table method-summary-table-tab1"><code><a href="#creditWhenHalfMessagesProcessed()" class="member-name-link">creditWhenHalfMessagesProcessed</a>()</code></div>
188188
<div class="col-last odd-row-color method-summary-table method-summary-table-tab1">
189-
<div class="block">Strategy that provides 1 initial credit and a credit when half of the chunk messages are
189+
<div class="block">Strategy that provides 10 initial credits and a credit when half of the chunk messages are
190190
processed.</div>
191191
</div>
192192
<div class="col-first even-row-color method-summary-table method-summary-table-tab1"><code>static <a href="ConsumerFlowStrategy.html" title="interface in com.rabbitmq.stream">ConsumerFlowStrategy</a></code></div>
@@ -274,14 +274,20 @@ <h3>creditOnChunkArrival</h3>
274274
<dd><code>initialCredits</code> - number of initial credits</dd>
275275
<dt>Returns:</dt>
276276
<dd>flow strategy</dd>
277+
<dt>See Also:</dt>
278+
<dd>
279+
<ul class="tag-list-long">
280+
<li><a href="ConsumerBuilder.FlowConfiguration.html#initialCredits(int)"><code>ConsumerBuilder.FlowConfiguration.initialCredits(int)</code></a></li>
281+
</ul>
282+
</dd>
277283
</dl>
278284
</section>
279285
</li>
280286
<li>
281287
<section class="detail" id="creditWhenHalfMessagesProcessed()">
282288
<h3>creditWhenHalfMessagesProcessed</h3>
283289
<div class="member-signature"><span class="modifiers">static</span>&nbsp;<span class="return-type"><a href="ConsumerFlowStrategy.html" title="interface in com.rabbitmq.stream">ConsumerFlowStrategy</a></span>&nbsp;<span class="element-name">creditWhenHalfMessagesProcessed</span>()</div>
284-
<div class="block">Strategy that provides 1 initial credit and a credit when half of the chunk messages are
290+
<div class="block">Strategy that provides 10 initial credits and a credit when half of the chunk messages are
285291
processed.
286292

287293
<p>Make sure to call <a href="MessageHandler.Context.html#processed()"><code>MessageHandler.Context.processed()</code></a> on every message when using
@@ -306,6 +312,12 @@ <h3>creditWhenHalfMessagesProcessed</h3>
306312
<dd><code>initialCredits</code> - number of initial credits</dd>
307313
<dt>Returns:</dt>
308314
<dd>flow strategy</dd>
315+
<dt>See Also:</dt>
316+
<dd>
317+
<ul class="tag-list-long">
318+
<li><a href="ConsumerBuilder.FlowConfiguration.html#initialCredits(int)"><code>ConsumerBuilder.FlowConfiguration.initialCredits(int)</code></a></li>
319+
</ul>
320+
</dd>
309321
</dl>
310322
</section>
311323
</li>

Diff for: ‎0.21.0-SNAPSHOT/api/com/rabbitmq/stream/ConsumerUpdateListener.Context.html

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang>
33
<head>
4-
<!-- Generated by javadoc (21) on Wed Dec 11 14:48:30 UTC 2024 -->
4+
<!-- Generated by javadoc (21) on Wed Dec 11 15:30:49 UTC 2024 -->
55
<title>ConsumerUpdateListener.Context (RabbitMQ Stream Java Client 0.21.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">

Diff for: ‎0.21.0-SNAPSHOT/api/com/rabbitmq/stream/ConsumerUpdateListener.html

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang>
33
<head>
4-
<!-- Generated by javadoc (21) on Wed Dec 11 14:48:30 UTC 2024 -->
4+
<!-- Generated by javadoc (21) on Wed Dec 11 15:30:49 UTC 2024 -->
55
<title>ConsumerUpdateListener (RabbitMQ Stream Java Client 0.21.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">

Diff for: ‎0.21.0-SNAPSHOT/api/com/rabbitmq/stream/Environment.html

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang>
33
<head>
4-
<!-- Generated by javadoc (21) on Wed Dec 11 14:48:30 UTC 2024 -->
4+
<!-- Generated by javadoc (21) on Wed Dec 11 15:30:49 UTC 2024 -->
55
<title>Environment (RabbitMQ Stream Java Client 0.21.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">

Diff for: ‎0.21.0-SNAPSHOT/api/com/rabbitmq/stream/EnvironmentBuilder.NettyConfiguration.html

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang>
33
<head>
4-
<!-- Generated by javadoc (21) on Wed Dec 11 14:48:30 UTC 2024 -->
4+
<!-- Generated by javadoc (21) on Wed Dec 11 15:30:49 UTC 2024 -->
55
<title>EnvironmentBuilder.NettyConfiguration (RabbitMQ Stream Java Client 0.21.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">

Diff for: ‎0.21.0-SNAPSHOT/api/com/rabbitmq/stream/EnvironmentBuilder.TlsConfiguration.html

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang>
33
<head>
4-
<!-- Generated by javadoc (21) on Wed Dec 11 14:48:30 UTC 2024 -->
4+
<!-- Generated by javadoc (21) on Wed Dec 11 15:30:49 UTC 2024 -->
55
<title>EnvironmentBuilder.TlsConfiguration (RabbitMQ Stream Java Client 0.21.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">

Diff for: ‎0.21.0-SNAPSHOT/api/com/rabbitmq/stream/EnvironmentBuilder.html

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang>
33
<head>
4-
<!-- Generated by javadoc (21) on Wed Dec 11 14:48:30 UTC 2024 -->
4+
<!-- Generated by javadoc (21) on Wed Dec 11 15:30:49 UTC 2024 -->
55
<title>EnvironmentBuilder (RabbitMQ Stream Java Client 0.21.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">

Diff for: ‎0.21.0-SNAPSHOT/api/com/rabbitmq/stream/Message.html

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang>
33
<head>
4-
<!-- Generated by javadoc (21) on Wed Dec 11 14:48:30 UTC 2024 -->
4+
<!-- Generated by javadoc (21) on Wed Dec 11 15:30:49 UTC 2024 -->
55
<title>Message (RabbitMQ Stream Java Client 0.21.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">

Diff for: ‎0.21.0-SNAPSHOT/api/com/rabbitmq/stream/MessageBuilder.ApplicationPropertiesBuilder.html

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang>
33
<head>
4-
<!-- Generated by javadoc (21) on Wed Dec 11 14:48:30 UTC 2024 -->
4+
<!-- Generated by javadoc (21) on Wed Dec 11 15:30:49 UTC 2024 -->
55
<title>MessageBuilder.ApplicationPropertiesBuilder (RabbitMQ Stream Java Client 0.21.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">

Diff for: ‎0.21.0-SNAPSHOT/api/com/rabbitmq/stream/MessageBuilder.MessageAnnotationsBuilder.html

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang>
33
<head>
4-
<!-- Generated by javadoc (21) on Wed Dec 11 14:48:30 UTC 2024 -->
4+
<!-- Generated by javadoc (21) on Wed Dec 11 15:30:49 UTC 2024 -->
55
<title>MessageBuilder.MessageAnnotationsBuilder (RabbitMQ Stream Java Client 0.21.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">

Diff for: ‎0.21.0-SNAPSHOT/api/com/rabbitmq/stream/MessageBuilder.PropertiesBuilder.html

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
<!DOCTYPE HTML>
22
<html lang>
33
<head>
4-
<!-- Generated by javadoc (21) on Wed Dec 11 14:48:30 UTC 2024 -->
4+
<!-- Generated by javadoc (21) on Wed Dec 11 15:30:49 UTC 2024 -->
55
<title>MessageBuilder.PropertiesBuilder (RabbitMQ Stream Java Client 0.21.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 commit comments

Comments
 (0)