Skip to content

Commit 7ad641d

Browse files
committed
RSocket Tests use Available Port
Issue gh-7360
1 parent c46b224 commit 7ad641d

File tree

3 files changed

+4
-4
lines changed

3 files changed

+4
-4
lines changed

config/src/test/java/org/springframework/security/config/annotation/rsocket/JwtITests.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -82,7 +82,7 @@ public void setup() {
8282
.frameDecoder(PayloadDecoder.ZERO_COPY)
8383
.addSocketAcceptorPlugin(this.interceptor)
8484
.acceptor(this.handler.responder())
85-
.transport(TcpServerTransport.create("localhost", 7000))
85+
.transport(TcpServerTransport.create("localhost", 0))
8686
.start()
8787
.block();
8888
}

config/src/test/java/org/springframework/security/config/annotation/rsocket/RSocketMessageHandlerConnectionITests.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -75,7 +75,7 @@ public void setup() {
7575
.frameDecoder(PayloadDecoder.ZERO_COPY)
7676
.addSocketAcceptorPlugin(this.interceptor)
7777
.acceptor(this.handler.responder())
78-
.transport(TcpServerTransport.create("localhost", 7000))
78+
.transport(TcpServerTransport.create("localhost", 0))
7979
.start()
8080
.block();
8181
}

config/src/test/java/org/springframework/security/config/annotation/rsocket/RSocketMessageHandlerITests.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -78,14 +78,14 @@ public void setup() {
7878
.frameDecoder(PayloadDecoder.ZERO_COPY)
7979
.addSocketAcceptorPlugin(this.interceptor)
8080
.acceptor(this.handler.responder())
81-
.transport(TcpServerTransport.create("localhost", 7000))
81+
.transport(TcpServerTransport.create("localhost", 0))
8282
.start()
8383
.block();
8484

8585
this.requester = RSocketRequester.builder()
8686
// .rsocketFactory(factory -> factory.addRequesterPlugin(payloadInterceptor))
8787
.rsocketStrategies(this.handler.getRSocketStrategies())
88-
.connectTcp("localhost", 7000)
88+
.connectTcp("localhost", this.server.address().getPort())
8989
.block();
9090
}
9191

0 commit comments

Comments
 (0)