Skip to content

Commit 256aba7

Browse files
committed
Fix rsocket test
Request route that exists; add additional error message verification Fixes gh-8154
1 parent 86e25ff commit 256aba7

File tree

1 file changed

+13
-7
lines changed

1 file changed

+13
-7
lines changed

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

+13-7
Original file line numberDiff line numberDiff line change
@@ -103,7 +103,9 @@ public void retrieveMonoWhenSecureThenDenied() throws Exception {
103103
.data(data)
104104
.retrieveMono(String.class)
105105
.block()
106-
).isInstanceOf(ApplicationErrorException.class);
106+
).isInstanceOf(ApplicationErrorException.class)
107+
.hasMessageContaining("Access Denied");
108+
107109
assertThat(this.controller.payloads).isEmpty();
108110
}
109111

@@ -116,7 +118,9 @@ public void retrieveMonoWhenAuthenticationFailedThenException() throws Exception
116118
.data(data)
117119
.retrieveMono(String.class)
118120
.block()
119-
).isInstanceOf(ApplicationErrorException.class);
121+
).isInstanceOf(ApplicationErrorException.class)
122+
.hasMessageContaining("Invalid Credentials");
123+
120124
assertThat(this.controller.payloads).isEmpty();
121125
}
122126

@@ -149,12 +153,13 @@ public void retrieveMonoWhenPublicThenGranted() throws Exception {
149153
@Test
150154
public void retrieveFluxWhenDataFluxAndSecureThenDenied() throws Exception {
151155
Flux<String> data = Flux.just("a", "b", "c");
152-
assertThatCode(() -> this.requester.route("secure.secure.retrieve-flux")
156+
assertThatCode(() -> this.requester.route("secure.retrieve-flux")
153157
.data(data, String.class)
154158
.retrieveFlux(String.class)
155159
.collectList()
156-
.block()).isInstanceOf(
157-
ApplicationErrorException.class);
160+
.block()
161+
).isInstanceOf(ApplicationErrorException.class)
162+
.hasMessageContaining("Access Denied");
158163

159164
assertThat(this.controller.payloads).isEmpty();
160165
}
@@ -179,8 +184,9 @@ public void retrieveFluxWhenDataStringAndSecureThenDenied() throws Exception {
179184
.data(data)
180185
.retrieveFlux(String.class)
181186
.collectList()
182-
.block()).isInstanceOf(
183-
ApplicationErrorException.class);
187+
.block()
188+
).isInstanceOf(ApplicationErrorException.class)
189+
.hasMessageContaining("Access Denied");
184190

185191
assertThat(this.controller.payloads).isEmpty();
186192
}

0 commit comments

Comments
 (0)