Skip to content

Commit 73b46dc

Browse files
committed
Merge pull request #881 from rabbitmq/chunk-id-in-flow-strategy-context
Add chunk ID to flow strategy context
1 parent 6a0f496 commit 73b46dc

File tree

688 files changed

+31210
-25316
lines changed

Some content is hidden

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

688 files changed

+31210
-25316
lines changed

1.4.0-SNAPSHOT/api/allclasses-index.html

Lines changed: 24 additions & 26 deletions
Original file line numberDiff line numberDiff line change
@@ -1,52 +1,51 @@
11
<!DOCTYPE HTML>
22
<html lang>
33
<head>
4-
<!-- Generated by javadoc (21) on Thu Oct 16 08:16:01 UTC 2025 -->
4+
<!-- Generated by javadoc (25) on Tue Nov 25 15:40:27 UTC 2025 -->
55
<title>All Classes and Interfaces (RabbitMQ Stream Java Client 1.4.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">
8-
<meta name="dc.created" content="2025-10-16">
8+
<meta name="dc.created" content="2025-11-25">
99
<meta name="description" content="class index">
1010
<meta name="generator" content="javadoc/AllClassesIndexWriter">
11-
<link rel="stylesheet" type="text/css" href="stylesheet.css" title="Style">
12-
<link rel="stylesheet" type="text/css" href="script-dir/jquery-ui.min.css" title="Style">
13-
<script type="text/javascript" src="script.js"></script>
14-
<script type="text/javascript" src="script-dir/jquery-3.7.1.min.js"></script>
15-
<script type="text/javascript" src="script-dir/jquery-ui.min.js"></script>
11+
<link rel="stylesheet" type="text/css" href="resource-files/jquery-ui.min.css">
12+
<link rel="stylesheet" type="text/css" href="resource-files/stylesheet.css">
13+
<script type="text/javascript" src="script-files/script.js"></script>
14+
<script type="text/javascript" src="script-files/jquery-3.7.1.min.js"></script>
15+
<script type="text/javascript" src="script-files/jquery-ui.min.js"></script>
1616
</head>
1717
<body class="all-classes-index-page">
18-
<script type="text/javascript">var pathtoroot = "./";
18+
<script type="text/javascript">const pathtoroot = "./";
1919
loadScripts(document, 'script');</script>
2020
<noscript>
2121
<div>JavaScript is disabled on your browser.</div>
2222
</noscript>
23-
<div class="flex-box">
24-
<header role="banner" class="flex-header">
23+
<header role="banner">
2524
<nav role="navigation">
2625
<!-- ========= START OF TOP NAVBAR ======= -->
27-
<div class="top-nav" id="navbar-top"><button id="navbar-toggle-button" aria-controls="navbar-top" aria-expanded="false" aria-label="Toggle navigation links"><span class="nav-bar-toggle-icon">&nbsp;</span><span class="nav-bar-toggle-icon">&nbsp;</span><span class="nav-bar-toggle-icon">&nbsp;</span></button>
26+
<div class="top-nav" id="navbar-top">
27+
<div class="nav-content">
28+
<div class="nav-menu-button"><button id="navbar-toggle-button" aria-controls="navbar-top" aria-expanded="false" aria-label="Toggle navigation links"><span class="nav-bar-toggle-icon">&nbsp;</span><span class="nav-bar-toggle-icon">&nbsp;</span><span class="nav-bar-toggle-icon">&nbsp;</span></button></div>
2829
<div class="skip-nav"><a href="#skip-navbar-top" title="Skip navigation links">Skip navigation links</a></div>
2930
<ul id="navbar-top-firstrow" class="nav-list" title="Navigation">
3031
<li><a href="index.html">Overview</a></li>
31-
<li>Package</li>
32-
<li>Class</li>
33-
<li>Use</li>
3432
<li><a href="overview-tree.html">Tree</a></li>
3533
<li><a href="index-all.html">Index</a></li>
34+
<li><a href="search.html">Search</a></li>
3635
<li><a href="help-doc.html#all-classes">Help</a></li>
3736
</ul>
3837
</div>
38+
</div>
3939
<div class="sub-nav">
40-
<div id="navbar-sub-list"></div>
41-
<div class="nav-list-search"><a href="search.html">SEARCH</a>
42-
<input type="text" id="search-input" disabled placeholder="Search">
43-
<input type="reset" id="reset-button" disabled value="reset">
40+
<div class="nav-content">
41+
<ol class="sub-nav-list"></ol>
42+
<div class="nav-list-search"><input type="text" id="search-input" disabled placeholder="Search documentation (type /)" aria-label="Search in documentation" autocomplete="off" spellcheck="false"><input type="reset" id="reset-search" disabled value="Reset"></div>
4443
</div>
4544
</div>
4645
<!-- ========= END OF TOP NAVBAR ========= -->
4746
<span class="skip-nav" id="skip-navbar-top"></span></nav>
4847
</header>
49-
<div class="flex-content">
48+
<div class="main-grid">
5049
<main role="main">
5150
<div class="header">
5251
<h1 title="All Classes and Interfaces" class="title">All Classes and Interfaces</h1>
@@ -144,7 +143,7 @@ <h1 title="All Classes and Interfaces" class="title">All Classes and Interfaces<
144143
<div class="col-first even-row-color all-classes-table all-classes-table-tab2"><a href="com/rabbitmq/stream/compression/CommonsCompressCompressionCodecFactory.html" title="class in com.rabbitmq.stream.compression">CommonsCompressCompressionCodecFactory</a></div>
145144
<div class="col-last even-row-color all-classes-table all-classes-table-tab2">
146145
<div class="block"><a href="com/rabbitmq/stream/compression/CompressionCodecFactory.html" title="interface in com.rabbitmq.stream.compression"><code>CompressionCodecFactory</code></a> creating codecs using <a href="https://commons.apache.org/proper/commons-compress/">Apache Commons Compress</a>
147-
implementations.</div>
146+
implementations.</div>
148147
</div>
149148
<div class="col-first odd-row-color all-classes-table all-classes-table-tab3"><a href="com/rabbitmq/stream/compression/Compression.html" title="enum in com.rabbitmq.stream.compression">Compression</a></div>
150149
<div class="col-last odd-row-color all-classes-table all-classes-table-tab3">
@@ -229,7 +228,7 @@ <h1 title="All Classes and Interfaces" class="title">All Classes and Interfaces<
229228
<div class="col-first odd-row-color all-classes-table all-classes-table-tab2"><a href="com/rabbitmq/stream/ConsumerFlowStrategy.CreditEveryNthChunkConsumerFlowStrategy.html" title="class in com.rabbitmq.stream">ConsumerFlowStrategy.CreditEveryNthChunkConsumerFlowStrategy</a></div>
230229
<div class="col-last odd-row-color all-classes-table all-classes-table-tab2">
231230
<div class="block">Strategy that provides the specified number of initial credits and <code>n</code> credits every
232-
<code>n</code> chunks.</div>
231+
<code>n</code> chunks.</div>
233232
</div>
234233
<div class="col-first even-row-color all-classes-table all-classes-table-tab2"><a href="com/rabbitmq/stream/ConsumerFlowStrategy.CreditOnChunkArrivalConsumerFlowStrategy.html" title="class in com.rabbitmq.stream">ConsumerFlowStrategy.CreditOnChunkArrivalConsumerFlowStrategy</a></div>
235234
<div class="col-last even-row-color all-classes-table all-classes-table-tab2">
@@ -238,7 +237,7 @@ <h1 title="All Classes and Interfaces" class="title">All Classes and Interfaces<
238237
<div class="col-first odd-row-color all-classes-table all-classes-table-tab2"><a href="com/rabbitmq/stream/ConsumerFlowStrategy.MessageCountConsumerFlowStrategy.html" title="class in com.rabbitmq.stream">ConsumerFlowStrategy.MessageCountConsumerFlowStrategy</a></div>
239238
<div class="col-last odd-row-color all-classes-table all-classes-table-tab2">
240239
<div class="block">Strategy that provides the specified number of initial credits and a credit when the specified
241-
ratio of the chunk messages are processed.</div>
240+
ratio of the chunk messages are processed.</div>
242241
</div>
243242
<div class="col-first even-row-color all-classes-table all-classes-table-tab1"><a href="com/rabbitmq/stream/ConsumerFlowStrategy.MessageProcessedCallback.html" title="interface in com.rabbitmq.stream">ConsumerFlowStrategy.MessageProcessedCallback</a></div>
244243
<div class="col-last even-row-color all-classes-table all-classes-table-tab1">
@@ -321,7 +320,7 @@ <h1 title="All Classes and Interfaces" class="title">All Classes and Interfaces<
321320
<div class="col-first odd-row-color all-classes-table all-classes-table-tab2"><a href="com/rabbitmq/stream/oauth2/GsonTokenParser.html" title="class in com.rabbitmq.stream.oauth2">GsonTokenParser</a></div>
322321
<div class="col-last odd-row-color all-classes-table all-classes-table-tab2">
323322
<div class="block">Token parser for <a href="https://www.rfc-editor.org/rfc/rfc6749#section-5.1">JSON OAuth 2 Access
324-
tokens</a>.</div>
323+
tokens</a>.</div>
325324
</div>
326325
<div class="col-first even-row-color all-classes-table all-classes-table-tab2"><a href="com/rabbitmq/stream/oauth2/HttpTokenRequester.html" title="class in com.rabbitmq.stream.oauth2">HttpTokenRequester</a></div>
327326
<div class="col-last even-row-color all-classes-table all-classes-table-tab2">
@@ -372,7 +371,7 @@ <h1 title="All Classes and Interfaces" class="title">All Classes and Interfaces<
372371
<div class="col-first odd-row-color all-classes-table all-classes-table-tab2"><a href="com/rabbitmq/stream/observation/micrometer/MicrometerObservationCollectorBuilder.html" title="class in com.rabbitmq.stream.observation.micrometer">MicrometerObservationCollectorBuilder</a></div>
373372
<div class="col-last odd-row-color all-classes-table all-classes-table-tab2">
374373
<div class="block">Builder to configure and create <a href="https://micrometer.io/docs/observation">Micrometer
375-
Observation</a> implementation of <a href="com/rabbitmq/stream/ObservationCollector.html" title="interface in com.rabbitmq.stream"><code>ObservationCollector</code></a>.</div>
374+
Observation</a> implementation of <a href="com/rabbitmq/stream/ObservationCollector.html" title="interface in com.rabbitmq.stream"><code>ObservationCollector</code></a>.</div>
376375
</div>
377376
<div class="col-first even-row-color all-classes-table all-classes-table-tab5"><a href="com/rabbitmq/stream/NoOffsetException.html" title="class in com.rabbitmq.stream">NoOffsetException</a></div>
378377
<div class="col-last even-row-color all-classes-table all-classes-table-tab5">&nbsp;</div>
@@ -563,12 +562,11 @@ <h1 title="All Classes and Interfaces" class="title">All Classes and Interfaces<
563562
</div>
564563
</div>
565564
</div>
566-
</main>
567565
<footer role="contentinfo">
568566
<hr>
569567
<p class="legal-copy"><small>Copyright &#169; 2025 <a href="https://www.rabbitmq.com">Broadcom Inc. and/or its subsidiaries</a>. All rights reserved.</small></p>
570568
</footer>
571-
</div>
569+
</main>
572570
</div>
573571
</body>
574572
</html>

1.4.0-SNAPSHOT/api/allpackages-index.html

Lines changed: 19 additions & 21 deletions
Original file line numberDiff line numberDiff line change
@@ -1,52 +1,51 @@
11
<!DOCTYPE HTML>
22
<html lang>
33
<head>
4-
<!-- Generated by javadoc (21) on Thu Oct 16 08:16:01 UTC 2025 -->
4+
<!-- Generated by javadoc (25) on Tue Nov 25 15:40:27 UTC 2025 -->
55
<title>All Packages (RabbitMQ Stream Java Client 1.4.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">
8-
<meta name="dc.created" content="2025-10-16">
8+
<meta name="dc.created" content="2025-11-25">
99
<meta name="description" content="package index">
1010
<meta name="generator" content="javadoc/AllPackagesIndexWriter">
11-
<link rel="stylesheet" type="text/css" href="stylesheet.css" title="Style">
12-
<link rel="stylesheet" type="text/css" href="script-dir/jquery-ui.min.css" title="Style">
13-
<script type="text/javascript" src="script.js"></script>
14-
<script type="text/javascript" src="script-dir/jquery-3.7.1.min.js"></script>
15-
<script type="text/javascript" src="script-dir/jquery-ui.min.js"></script>
11+
<link rel="stylesheet" type="text/css" href="resource-files/jquery-ui.min.css">
12+
<link rel="stylesheet" type="text/css" href="resource-files/stylesheet.css">
13+
<script type="text/javascript" src="script-files/script.js"></script>
14+
<script type="text/javascript" src="script-files/jquery-3.7.1.min.js"></script>
15+
<script type="text/javascript" src="script-files/jquery-ui.min.js"></script>
1616
</head>
1717
<body class="all-packages-index-page">
18-
<script type="text/javascript">var pathtoroot = "./";
18+
<script type="text/javascript">const pathtoroot = "./";
1919
loadScripts(document, 'script');</script>
2020
<noscript>
2121
<div>JavaScript is disabled on your browser.</div>
2222
</noscript>
23-
<div class="flex-box">
24-
<header role="banner" class="flex-header">
23+
<header role="banner">
2524
<nav role="navigation">
2625
<!-- ========= START OF TOP NAVBAR ======= -->
27-
<div class="top-nav" id="navbar-top"><button id="navbar-toggle-button" aria-controls="navbar-top" aria-expanded="false" aria-label="Toggle navigation links"><span class="nav-bar-toggle-icon">&nbsp;</span><span class="nav-bar-toggle-icon">&nbsp;</span><span class="nav-bar-toggle-icon">&nbsp;</span></button>
26+
<div class="top-nav" id="navbar-top">
27+
<div class="nav-content">
28+
<div class="nav-menu-button"><button id="navbar-toggle-button" aria-controls="navbar-top" aria-expanded="false" aria-label="Toggle navigation links"><span class="nav-bar-toggle-icon">&nbsp;</span><span class="nav-bar-toggle-icon">&nbsp;</span><span class="nav-bar-toggle-icon">&nbsp;</span></button></div>
2829
<div class="skip-nav"><a href="#skip-navbar-top" title="Skip navigation links">Skip navigation links</a></div>
2930
<ul id="navbar-top-firstrow" class="nav-list" title="Navigation">
3031
<li><a href="index.html">Overview</a></li>
31-
<li>Package</li>
32-
<li>Class</li>
33-
<li>Use</li>
3432
<li><a href="overview-tree.html">Tree</a></li>
3533
<li><a href="index-all.html">Index</a></li>
34+
<li><a href="search.html">Search</a></li>
3635
<li><a href="help-doc.html#all-packages">Help</a></li>
3736
</ul>
3837
</div>
38+
</div>
3939
<div class="sub-nav">
40-
<div id="navbar-sub-list"></div>
41-
<div class="nav-list-search"><a href="search.html">SEARCH</a>
42-
<input type="text" id="search-input" disabled placeholder="Search">
43-
<input type="reset" id="reset-button" disabled value="reset">
40+
<div class="nav-content">
41+
<ol class="sub-nav-list"></ol>
42+
<div class="nav-list-search"><input type="text" id="search-input" disabled placeholder="Search documentation (type /)" aria-label="Search in documentation" autocomplete="off" spellcheck="false"><input type="reset" id="reset-search" disabled value="Reset"></div>
4443
</div>
4544
</div>
4645
<!-- ========= END OF TOP NAVBAR ========= -->
4746
<span class="skip-nav" id="skip-navbar-top"></span></nav>
4847
</header>
49-
<div class="flex-content">
48+
<div class="main-grid">
5049
<main role="main">
5150
<div class="header">
5251
<h1 title="All&amp;nbsp;Packages" class="title">All&nbsp;Packages</h1>
@@ -88,12 +87,11 @@ <h1 title="All&amp;nbsp;Packages" class="title">All&nbsp;Packages</h1>
8887
<div class="block">SASL API for the RabbitMQ Stream Java Client.</div>
8988
</div>
9089
</div>
91-
</main>
9290
<footer role="contentinfo">
9391
<hr>
9492
<p class="legal-copy"><small>Copyright &#169; 2025 <a href="https://www.rabbitmq.com">Broadcom Inc. and/or its subsidiaries</a>. All rights reserved.</small></p>
9593
</footer>
96-
</div>
94+
</main>
9795
</div>
9896
</body>
9997
</html>

0 commit comments

Comments
 (0)