3
3
import org .springframework .beans .factory .annotation .Value ;
4
4
import org .springframework .context .annotation .Configuration ;
5
5
import org .springframework .messaging .simp .config .MessageBrokerRegistry ;
6
- import org .springframework .web .socket .WebSocketHandler ;
7
- import org .springframework .web .socket .WebSocketSession ;
8
6
import org .springframework .web .socket .config .annotation .EnableWebSocketMessageBroker ;
9
7
import org .springframework .web .socket .config .annotation .StompEndpointRegistry ;
10
8
import org .springframework .web .socket .config .annotation .WebSocketMessageBrokerConfigurer ;
11
- import org .springframework .web .socket .config .annotation .WebSocketTransportRegistration ;
12
- import org .springframework .web .socket .handler .WebSocketHandlerDecorator ;
13
- import org .springframework .web .socket .handler .WebSocketHandlerDecoratorFactory ;
14
9
15
10
@ Configuration
16
11
@ EnableWebSocketMessageBroker
@@ -20,42 +15,15 @@ public class WebSocketConfig implements WebSocketMessageBrokerConfigurer {
20
15
21
16
@ Override
22
17
public void registerStompEndpoints (StompEndpointRegistry registry ) {
23
- registry .addEndpoint ("/ws" ).setAllowedOriginPatterns (allowedOrigins ).withSockJS ();
18
+ registry .addEndpoint ("/ws" )
19
+ .setAllowedOriginPatterns (allowedOrigins )
20
+ .addInterceptors (new CustomHandshakeInterceptor ())
21
+ .withSockJS ();
24
22
}
25
23
26
24
@ Override
27
25
public void configureMessageBroker (MessageBrokerRegistry registry ) {
28
26
registry .setApplicationDestinationPrefixes ("/app" );
29
27
registry .enableSimpleBroker ("/topic" );
30
28
}
31
-
32
- // @Override
33
- // public void configureWebSocketTransport(WebSocketTransportRegistration registration) {
34
- // registration.addDecoratorFactory(new WebSocketHandlerDecoratorFactory() {
35
- // @Override
36
- // public WebSocketHandler decorate(WebSocketHandler handler) {
37
- // return new WebSocketHandlerDecorator(handler) {
38
- // @Override
39
- // public void afterConnectionEstablished(WebSocketSession session) throws Exception {
40
- // super.afterConnectionEstablished(session);
41
- // session.getHandshakeHeaders().add("Access-Control-Allow-Origin", "*");
42
- // }
43
- // };
44
- // }
45
- // });
46
- // }
47
-
48
- // @Override
49
- // public boolean configureMessageConverters(List<MessageConverter> messageConverters) {
50
- // DefaultContentTypeResolver resolver = new DefaultContentTypeResolver();
51
- // resolver.setDefaultMimeType(APPLICATION_JSON);
52
- // MappingJackson2MessageConverter converter = new MappingJackson2MessageConverter();
53
- // converter.setObjectMapper(new ObjectMapper());
54
- // converter.setContentTypeResolver(resolver);
55
- // messageConverters.add(new StringMessageConverter());
56
- // messageConverters.add(new ByteArrayMessageConverter());
57
- // messageConverters.add(converter);
58
- //
59
- // return false;
60
- // }
61
29
}
0 commit comments