diff --git a/module/spring-boot-reactor-netty/src/main/java/org/springframework/boot/reactor/netty/NettyWebServer.java b/module/spring-boot-reactor-netty/src/main/java/org/springframework/boot/reactor/netty/NettyWebServer.java index fabed378078..1d0c48deac8 100644 --- a/module/spring-boot-reactor-netty/src/main/java/org/springframework/boot/reactor/netty/NettyWebServer.java +++ b/module/spring-boot-reactor-netty/src/main/java/org/springframework/boot/reactor/netty/NettyWebServer.java @@ -121,7 +121,7 @@ public class NettyWebServer implements WebServer { catch (Exception ex) { PortInUseException.ifCausedBy(ex, ChannelBindException.class, (bindException) -> { if (bindException.localPort() > 0 && !isPermissionDenied(bindException.getCause())) { - PortInUseException.throwIfPortBindingException(bindException, bindException::localPort); + throw new PortInUseException(bindException.localPort(), ex); } }); throw new WebServerException("Unable to start Netty", ex); diff --git a/module/spring-boot-reactor-netty/src/test/java/org/springframework/boot/reactor/netty/NettyReactiveWebServerFactoryTests.java b/module/spring-boot-reactor-netty/src/test/java/org/springframework/boot/reactor/netty/NettyReactiveWebServerFactoryTests.java index 35a820ffcbc..cc93043de27 100644 --- a/module/spring-boot-reactor-netty/src/test/java/org/springframework/boot/reactor/netty/NettyReactiveWebServerFactoryTests.java +++ b/module/spring-boot-reactor-netty/src/test/java/org/springframework/boot/reactor/netty/NettyReactiveWebServerFactoryTests.java @@ -17,9 +17,7 @@ package org.springframework.boot.reactor.netty; import java.net.ConnectException; -import java.net.InetAddress; import java.net.SocketAddress; -import java.net.UnknownHostException; import java.time.Duration; import java.util.Arrays; @@ -46,7 +44,6 @@ import org.springframework.boot.testsupport.classpath.resources.WithPackageResou import org.springframework.boot.web.server.PortInUseException; import org.springframework.boot.web.server.Shutdown; import org.springframework.boot.web.server.Ssl; -import org.springframework.boot.web.server.WebServerException; import org.springframework.boot.web.server.reactive.AbstractReactiveWebServerFactory; import org.springframework.boot.web.server.reactive.AbstractReactiveWebServerFactoryTests; import org.springframework.boot.web.server.reactive.ConfigurableReactiveWebServerFactory; @@ -75,7 +72,7 @@ import static org.mockito.Mockito.mock; class NettyReactiveWebServerFactoryTests extends AbstractReactiveWebServerFactoryTests { @Test - void portInUseExceptionIsThrownWhenPortIsAlreadyInUse() { + void exceptionIsThrownWhenPortIsAlreadyInUse() { AbstractReactiveWebServerFactory factory = getFactory(); factory.setPort(0); this.webServer = factory.getWebServer(new EchoHandler()); @@ -86,14 +83,6 @@ class NettyReactiveWebServerFactoryTests extends AbstractReactiveWebServerFactor .withCauseInstanceOf(Throwable.class); } - @Test - void webServerExceptionIsThrownWhenAddressCannotBeAssigned() throws UnknownHostException { - AbstractReactiveWebServerFactory factory = getFactory(); - factory.setPort(8080); - factory.setAddress(InetAddress.getByName("1.2.3.4")); - assertThatExceptionOfType(WebServerException.class).isThrownBy(factory.getWebServer(new EchoHandler())::start); - } - @Test void getPortWhenDisposableServerPortOperationIsUnsupportedReturnsMinusOne() { NettyReactiveWebServerFactory factory = new NoPortNettyReactiveWebServerFactory(0);