File tree Expand file tree Collapse file tree 2 files changed +4
-10
lines changed
samples/boot/hellorsocket/src
integration-test/java/sample Expand file tree Collapse file tree 2 files changed +4
-10
lines changed Original file line number Diff line number Diff line change 15
15
*/
16
16
package sample ;
17
17
18
- import org .junit .Test ;
19
- import org .junit .runner .RunWith ;
20
18
import org .springframework .beans .factory .annotation .Autowired ;
21
19
import org .springframework .boot .rsocket .context .RSocketServerInitializedEvent ;
22
20
import org .springframework .boot .test .context .SpringBootTest ;
27
25
import org .springframework .security .rsocket .metadata .UsernamePasswordMetadata ;
28
26
import org .springframework .test .context .TestPropertySource ;
29
27
import org .springframework .test .context .junit4 .SpringRunner ;
28
+
29
+ import org .junit .Test ;
30
+ import org .junit .runner .RunWith ;
30
31
import reactor .core .publisher .Mono ;
31
32
32
33
import static org .assertj .core .api .Assertions .assertThat ;
@@ -91,7 +92,7 @@ static class Config implements ApplicationListener<RSocketServerInitializedEvent
91
92
92
93
@ Override
93
94
public void onApplicationEvent (RSocketServerInitializedEvent event ) {
94
- this .port = event .getrSocketServer ().address ().getPort ();
95
+ this .port = event .getServer ().address ().getPort ();
95
96
}
96
97
}
97
98
}
Original file line number Diff line number Diff line change 16
16
17
17
package sample ;
18
18
19
- import org .springframework .boot .rsocket .server .ServerRSocketFactoryCustomizer ;
20
19
import org .springframework .context .annotation .Bean ;
21
20
import org .springframework .context .annotation .Configuration ;
22
21
import org .springframework .security .config .annotation .rsocket .EnableRSocketSecurity ;
23
22
import org .springframework .security .core .userdetails .MapReactiveUserDetailsService ;
24
23
import org .springframework .security .core .userdetails .User ;
25
24
import org .springframework .security .core .userdetails .UserDetails ;
26
- import org .springframework .security .rsocket .core .SecuritySocketAcceptorInterceptor ;
27
25
28
26
/**
29
27
* @author Rob Winch
@@ -43,9 +41,4 @@ MapReactiveUserDetailsService userDetailsService() {
43
41
return new MapReactiveUserDetailsService (user );
44
42
}
45
43
46
- @ Bean
47
- ServerRSocketFactoryCustomizer springSecurityRSocketSecurity (
48
- SecuritySocketAcceptorInterceptor interceptor ) {
49
- return builder -> builder .addSocketAcceptorPlugin (interceptor );
50
- }
51
44
}
You can’t perform that action at this time.
0 commit comments