Skip to content

Commit 31179d7

Browse files
committed
fixup! Upgrade to Jetty 12.0.24
1 parent c4f2922 commit 31179d7

File tree

4 files changed

+11
-11
lines changed

4 files changed

+11
-11
lines changed

spring-boot-project/spring-boot/src/main/java/org/springframework/boot/web/embedded/jetty/JettyReactiveWebServerFactory.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -31,10 +31,10 @@
3131
import org.eclipse.jetty.http2.server.HTTP2CServerConnectionFactory;
3232
import org.eclipse.jetty.server.AbstractConnector;
3333
import org.eclipse.jetty.server.ConnectionFactory;
34-
import org.eclipse.jetty.server.ConnectionLimit;
3534
import org.eclipse.jetty.server.Handler;
3635
import org.eclipse.jetty.server.HttpConfiguration;
3736
import org.eclipse.jetty.server.HttpConnectionFactory;
37+
import org.eclipse.jetty.server.NetworkConnectionLimit;
3838
import org.eclipse.jetty.server.Server;
3939
import org.eclipse.jetty.server.ServerConnector;
4040
import org.eclipse.jetty.server.handler.StatisticsHandler;
@@ -189,7 +189,7 @@ protected Server createJettyServer(JettyHttpHandlerAdapter servlet) {
189189
server.setHandler(addHandlerWrappers(contextHandler));
190190
JettyReactiveWebServerFactory.logger.info("Server initialized with port: " + port);
191191
if (this.maxConnections > -1) {
192-
server.addBean(new ConnectionLimit(this.maxConnections, server));
192+
server.addBean(new NetworkConnectionLimit(this.maxConnections, server));
193193
}
194194
if (Ssl.isEnabled(getSsl())) {
195195
customizeSsl(server, address);

spring-boot-project/spring-boot/src/main/java/org/springframework/boot/web/embedded/jetty/JettyServletWebServerFactory.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -55,12 +55,12 @@
5555
import org.eclipse.jetty.http2.server.HTTP2CServerConnectionFactory;
5656
import org.eclipse.jetty.server.AbstractConnector;
5757
import org.eclipse.jetty.server.ConnectionFactory;
58-
import org.eclipse.jetty.server.ConnectionLimit;
5958
import org.eclipse.jetty.server.Connector;
6059
import org.eclipse.jetty.server.Handler;
6160
import org.eclipse.jetty.server.HttpConfiguration;
6261
import org.eclipse.jetty.server.HttpConnectionFactory;
6362
import org.eclipse.jetty.server.HttpCookieUtils;
63+
import org.eclipse.jetty.server.NetworkConnectionLimit;
6464
import org.eclipse.jetty.server.Request;
6565
import org.eclipse.jetty.server.Response;
6666
import org.eclipse.jetty.server.Server;
@@ -175,7 +175,7 @@ public WebServer getWebServer(ServletContextInitializer... initializers) {
175175
server.setHandler(addHandlerWrappers(context));
176176
this.logger.info("Server initialized with port: " + port);
177177
if (this.maxConnections > -1) {
178-
server.addBean(new ConnectionLimit(this.maxConnections, server.getConnectors()));
178+
server.addBean(new NetworkConnectionLimit(this.maxConnections, server.getConnectors()));
179179
}
180180
if (Ssl.isEnabled(getSsl())) {
181181
customizeSsl(server, address);

spring-boot-project/spring-boot/src/test/java/org/springframework/boot/web/embedded/jetty/JettyReactiveWebServerFactoryTests.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -23,8 +23,8 @@
2323
import java.util.List;
2424

2525
import org.awaitility.Awaitility;
26-
import org.eclipse.jetty.server.ConnectionLimit;
2726
import org.eclipse.jetty.server.Connector;
27+
import org.eclipse.jetty.server.NetworkConnectionLimit;
2828
import org.eclipse.jetty.server.Server;
2929
import org.eclipse.jetty.server.ServerConnector;
3030
import org.junit.jupiter.api.Disabled;
@@ -145,9 +145,9 @@ void shouldApplyMaxConnections() {
145145
factory.setMaxConnections(1);
146146
this.webServer = factory.getWebServer(new EchoHandler());
147147
Server server = ((JettyWebServer) this.webServer).getServer();
148-
ConnectionLimit connectionLimit = server.getBean(ConnectionLimit.class);
148+
NetworkConnectionLimit connectionLimit = server.getBean(NetworkConnectionLimit.class);
149149
assertThat(connectionLimit).isNotNull();
150-
assertThat(connectionLimit.getMaxConnections()).isOne();
150+
assertThat(connectionLimit.getMaxNetworkConnectionCount()).isOne();
151151
}
152152

153153
@Test

spring-boot-project/spring-boot/src/test/java/org/springframework/boot/web/embedded/jetty/JettyServletWebServerFactoryTests.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -48,9 +48,9 @@
4848
import org.eclipse.jetty.ee10.webapp.Configuration;
4949
import org.eclipse.jetty.ee10.webapp.WebAppContext;
5050
import org.eclipse.jetty.server.AbstractConnector;
51-
import org.eclipse.jetty.server.ConnectionLimit;
5251
import org.eclipse.jetty.server.Connector;
5352
import org.eclipse.jetty.server.Handler;
53+
import org.eclipse.jetty.server.NetworkConnectionLimit;
5454
import org.eclipse.jetty.server.Server;
5555
import org.eclipse.jetty.server.ServerConnector;
5656
import org.eclipse.jetty.server.SslConnectionFactory;
@@ -562,9 +562,9 @@ void shouldApplyMaxConnections() {
562562
factory.setMaxConnections(1);
563563
this.webServer = factory.getWebServer();
564564
Server server = ((JettyWebServer) this.webServer).getServer();
565-
ConnectionLimit connectionLimit = server.getBean(ConnectionLimit.class);
565+
NetworkConnectionLimit connectionLimit = server.getBean(NetworkConnectionLimit.class);
566566
assertThat(connectionLimit).isNotNull();
567-
assertThat(connectionLimit.getMaxConnections()).isOne();
567+
assertThat(connectionLimit.getMaxNetworkConnectionCount()).isOne();
568568
}
569569

570570
@Test
@@ -574,7 +574,7 @@ void shouldApplyMaxConnectionsToConnectors() {
574574
this.webServer = factory.getWebServer();
575575
Server server = ((JettyWebServer) this.webServer).getServer();
576576
assertThat(server.getConnectors()).isEmpty();
577-
ConnectionLimit connectionLimit = server.getBean(ConnectionLimit.class);
577+
NetworkConnectionLimit connectionLimit = server.getBean(NetworkConnectionLimit.class);
578578
assertThat(connectionLimit).extracting("_connectors")
579579
.asInstanceOf(InstanceOfAssertFactories.list(AbstractConnector.class))
580580
.hasSize(1);

0 commit comments

Comments
 (0)