Skip to content

Commit 0660a1e

Browse files
committed
Move event loop group setup to Netty configuration
References #269
1 parent 1d9f663 commit 0660a1e

File tree

506 files changed

+648
-552
lines changed

Some content is hidden

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

506 files changed

+648
-552
lines changed

0.10.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="en">
33
<head>
4-
<!-- Generated by javadoc (17) on Fri Jan 20 11:22:29 UTC 2023 -->
4+
<!-- Generated by javadoc (17) on Fri Jan 20 12:54:39 UTC 2023 -->
55
<title>All Classes and Interfaces (RabbitMQ Stream Java Client 0.10.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.10.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="en">
33
<head>
4-
<!-- Generated by javadoc (17) on Fri Jan 20 11:22:29 UTC 2023 -->
4+
<!-- Generated by javadoc (17) on Fri Jan 20 12:54:39 UTC 2023 -->
55
<title>All Packages (RabbitMQ Stream Java Client 0.10.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.10.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="en">
33
<head>
4-
<!-- Generated by javadoc (17) on Fri Jan 20 11:22:29 UTC 2023 -->
4+
<!-- Generated by javadoc (17) on Fri Jan 20 12:54:39 UTC 2023 -->
55
<title>Address (RabbitMQ Stream Java Client 0.10.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.10.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="en">
33
<head>
4-
<!-- Generated by javadoc (17) on Fri Jan 20 11:22:29 UTC 2023 -->
4+
<!-- Generated by javadoc (17) on Fri Jan 20 12:54:39 UTC 2023 -->
55
<title>AddressResolver (RabbitMQ Stream Java Client 0.10.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.10.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="en">
33
<head>
4-
<!-- Generated by javadoc (17) on Fri Jan 20 11:22:29 UTC 2023 -->
4+
<!-- Generated by javadoc (17) on Fri Jan 20 12:54:39 UTC 2023 -->
55
<title>AuthenticationFailureException (RabbitMQ Stream Java Client 0.10.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.10.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="en">
33
<head>
4-
<!-- Generated by javadoc (17) on Fri Jan 20 11:22:29 UTC 2023 -->
4+
<!-- Generated by javadoc (17) on Fri Jan 20 12:54:39 UTC 2023 -->
55
<title>BackOffDelayPolicy.FixedWithInitialDelayAndTimeoutBackOffPolicy (RabbitMQ Stream Java Client 0.10.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.10.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="en">
33
<head>
4-
<!-- Generated by javadoc (17) on Fri Jan 20 11:22:29 UTC 2023 -->
4+
<!-- Generated by javadoc (17) on Fri Jan 20 12:54:39 UTC 2023 -->
55
<title>BackOffDelayPolicy.FixedWithInitialDelayBackOffPolicy (RabbitMQ Stream Java Client 0.10.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.10.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="en">
33
<head>
4-
<!-- Generated by javadoc (17) on Fri Jan 20 11:22:29 UTC 2023 -->
4+
<!-- Generated by javadoc (17) on Fri Jan 20 12:54:39 UTC 2023 -->
55
<title>BackOffDelayPolicy (RabbitMQ Stream Java Client 0.10.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.10.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="en">
33
<head>
4-
<!-- Generated by javadoc (17) on Fri Jan 20 11:22:29 UTC 2023 -->
4+
<!-- Generated by javadoc (17) on Fri Jan 20 12:54:39 UTC 2023 -->
55
<title>ByteCapacity (RabbitMQ Stream Java Client 0.10.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.10.0-SNAPSHOT/api/com/rabbitmq/stream/ChannelCustomizer.html

+1-1
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 Fri Jan 20 11:22:29 UTC 2023 -->
4+
<!-- Generated by javadoc (17) on Fri Jan 20 12:54:39 UTC 2023 -->
55
<title>ChannelCustomizer (RabbitMQ Stream Java Client 0.10.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.10.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="en">
33
<head>
4-
<!-- Generated by javadoc (17) on Fri Jan 20 11:22:29 UTC 2023 -->
4+
<!-- Generated by javadoc (17) on Fri Jan 20 12:54:39 UTC 2023 -->
55
<title>ChunkChecksum (RabbitMQ Stream Java Client 0.10.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.10.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="en">
33
<head>
4-
<!-- Generated by javadoc (17) on Fri Jan 20 11:22:29 UTC 2023 -->
4+
<!-- Generated by javadoc (17) on Fri Jan 20 12:54:39 UTC 2023 -->
55
<title>ChunkChecksumValidationException (RabbitMQ Stream Java Client 0.10.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.10.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="en">
33
<head>
4-
<!-- Generated by javadoc (17) on Fri Jan 20 11:22:29 UTC 2023 -->
4+
<!-- Generated by javadoc (17) on Fri Jan 20 12:54:39 UTC 2023 -->
55
<title>Codec.EncodedMessage (RabbitMQ Stream Java Client 0.10.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.10.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="en">
33
<head>
4-
<!-- Generated by javadoc (17) on Fri Jan 20 11:22:29 UTC 2023 -->
4+
<!-- Generated by javadoc (17) on Fri Jan 20 12:54:39 UTC 2023 -->
55
<title>Codec (RabbitMQ Stream Java Client 0.10.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.10.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="en">
33
<head>
4-
<!-- Generated by javadoc (17) on Fri Jan 20 11:22:29 UTC 2023 -->
4+
<!-- Generated by javadoc (17) on Fri Jan 20 12:54:39 UTC 2023 -->
55
<title>ConfirmationHandler (RabbitMQ Stream Java Client 0.10.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.10.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="en">
33
<head>
4-
<!-- Generated by javadoc (17) on Fri Jan 20 11:22:29 UTC 2023 -->
4+
<!-- Generated by javadoc (17) on Fri Jan 20 12:54:39 UTC 2023 -->
55
<title>ConfirmationStatus (RabbitMQ Stream Java Client 0.10.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.10.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="en">
33
<head>
4-
<!-- Generated by javadoc (17) on Fri Jan 20 11:22:29 UTC 2023 -->
4+
<!-- Generated by javadoc (17) on Fri Jan 20 12:54:39 UTC 2023 -->
55
<title>Constants (RabbitMQ Stream Java Client 0.10.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.10.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="en">
33
<head>
4-
<!-- Generated by javadoc (17) on Fri Jan 20 11:22:29 UTC 2023 -->
4+
<!-- Generated by javadoc (17) on Fri Jan 20 12:54:39 UTC 2023 -->
55
<title>Consumer (RabbitMQ Stream Java Client 0.10.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.10.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="en">
33
<head>
4-
<!-- Generated by javadoc (17) on Fri Jan 20 11:22:29 UTC 2023 -->
4+
<!-- Generated by javadoc (17) on Fri Jan 20 12:54:39 UTC 2023 -->
55
<title>ConsumerBuilder.AutoTrackingStrategy (RabbitMQ Stream Java Client 0.10.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.10.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="en">
33
<head>
4-
<!-- Generated by javadoc (17) on Fri Jan 20 11:22:29 UTC 2023 -->
4+
<!-- Generated by javadoc (17) on Fri Jan 20 12:54:39 UTC 2023 -->
55
<title>ConsumerBuilder.ManualTrackingStrategy (RabbitMQ Stream Java Client 0.10.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.10.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="en">
33
<head>
4-
<!-- Generated by javadoc (17) on Fri Jan 20 11:22:29 UTC 2023 -->
4+
<!-- Generated by javadoc (17) on Fri Jan 20 12:54:39 UTC 2023 -->
55
<title>ConsumerBuilder (RabbitMQ Stream Java Client 0.10.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.10.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="en">
33
<head>
4-
<!-- Generated by javadoc (17) on Fri Jan 20 11:22:29 UTC 2023 -->
4+
<!-- Generated by javadoc (17) on Fri Jan 20 12:54:39 UTC 2023 -->
55
<title>ConsumerUpdateListener.Context (RabbitMQ Stream Java Client 0.10.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.10.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="en">
33
<head>
4-
<!-- Generated by javadoc (17) on Fri Jan 20 11:22:29 UTC 2023 -->
4+
<!-- Generated by javadoc (17) on Fri Jan 20 12:54:39 UTC 2023 -->
55
<title>ConsumerUpdateListener (RabbitMQ Stream Java Client 0.10.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.10.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="en">
33
<head>
4-
<!-- Generated by javadoc (17) on Fri Jan 20 11:22:29 UTC 2023 -->
4+
<!-- Generated by javadoc (17) on Fri Jan 20 12:54:39 UTC 2023 -->
55
<title>Environment (RabbitMQ Stream Java Client 0.10.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.10.0-SNAPSHOT/api/com/rabbitmq/stream/EnvironmentBuilder.NettyConfiguration.html

+22-1
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 Fri Jan 20 11:22:29 UTC 2023 -->
4+
<!-- Generated by javadoc (17) on Fri Jan 20 12:54:39 UTC 2023 -->
55
<title>EnvironmentBuilder.NettyConfiguration (RabbitMQ Stream Java Client 0.10.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">
@@ -116,6 +116,11 @@ <h2>Method Summary</h2>
116116
<div class="col-last odd-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab3">
117117
<div class="block">Go back to the environment builder</div>
118118
</div>
119+
<div class="col-first even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab3"><code><a href="EnvironmentBuilder.NettyConfiguration.html" title="interface in com.rabbitmq.stream">EnvironmentBuilder.NettyConfiguration</a></code></div>
120+
<div class="col-second even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab3"><code><a href="#eventLoopGroup(io.netty.channel.EventLoopGroup)" class="member-name-link">eventLoopGroup</a><wbr>(<a href="https://netty.io/4.1/api/io/netty/channel/EventLoopGroup.html" title="class or interface in io.netty.channel" class="external-link">EventLoopGroup</a>&nbsp;eventLoopGroup)</code></div>
121+
<div class="col-last even-row-color method-summary-table method-summary-table-tab2 method-summary-table-tab3">
122+
<div class="block">The <a href="https://netty.io/4.1/api/io/netty/channel/EventLoopGroup.html" title="class or interface in io.netty.channel" class="external-link"><code>EventLoopGroup</code></a> instance to use.</div>
123+
</div>
119124
</div>
120125
</div>
121126
</div>
@@ -131,6 +136,22 @@ <h2>Method Summary</h2>
131136
<h2>Method Details</h2>
132137
<ul class="member-list">
133138
<li>
139+
<section class="detail" id="eventLoopGroup(io.netty.channel.EventLoopGroup)">
140+
<h3>eventLoopGroup</h3>
141+
<div class="member-signature"><span class="return-type"><a href="EnvironmentBuilder.NettyConfiguration.html" title="interface in com.rabbitmq.stream">EnvironmentBuilder.NettyConfiguration</a></span>&nbsp;<span class="element-name">eventLoopGroup</span><wbr><span class="parameters">(<a href="https://netty.io/4.1/api/io/netty/channel/EventLoopGroup.html" title="class or interface in io.netty.channel" class="external-link">EventLoopGroup</a>&nbsp;eventLoopGroup)</span></div>
142+
<div class="block">The <a href="https://netty.io/4.1/api/io/netty/channel/EventLoopGroup.html" title="class or interface in io.netty.channel" class="external-link"><code>EventLoopGroup</code></a> instance to use.
143+
144+
<p>The environment uses its own instance by default. It is the developer's responsibility to
145+
close the <a href="https://netty.io/4.1/api/io/netty/channel/EventLoopGroup.html" title="class or interface in io.netty.channel" class="external-link"><code>EventLoopGroup</code></a> they provide.</div>
146+
<dl class="notes">
147+
<dt>Parameters:</dt>
148+
<dd><code>eventLoopGroup</code> - </dd>
149+
<dt>Returns:</dt>
150+
<dd>the Netty configuration helper</dd>
151+
</dl>
152+
</section>
153+
</li>
154+
<li>
134155
<section class="detail" id="byteBufAllocator(io.netty.buffer.ByteBufAllocator)">
135156
<h3>byteBufAllocator</h3>
136157
<div class="member-signature"><span class="return-type"><a href="EnvironmentBuilder.NettyConfiguration.html" title="interface in com.rabbitmq.stream">EnvironmentBuilder.NettyConfiguration</a></span>&nbsp;<span class="element-name">byteBufAllocator</span><wbr><span class="parameters">(<a href="https://netty.io/4.1/api/io/netty/buffer/ByteBufAllocator.html" title="class or interface in io.netty.buffer" class="external-link">ByteBufAllocator</a>&nbsp;byteBufAllocator)</span></div>

0.10.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="en">
33
<head>
4-
<!-- Generated by javadoc (17) on Fri Jan 20 11:22:29 UTC 2023 -->
4+
<!-- Generated by javadoc (17) on Fri Jan 20 12:54:39 UTC 2023 -->
55
<title>EnvironmentBuilder.TlsConfiguration (RabbitMQ Stream Java Client 0.10.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)