|
@@ -1,24 +1,34 @@
|
|
|
+
|
|
|
package hello;
|
|
|
|
|
|
import org.springframework.context.annotation.Configuration;
|
|
|
-import org.springframework.messaging.simp.config.EnableWebSocketMessageBroker;
|
|
|
-import org.springframework.messaging.simp.config.MessageBrokerConfigurer;
|
|
|
-import org.springframework.messaging.simp.config.StompEndpointRegistry;
|
|
|
-import org.springframework.messaging.simp.config.WebSocketMessageBrokerConfigurer;
|
|
|
+import org.springframework.messaging.simp.config.ChannelRegistration;
|
|
|
+import org.springframework.messaging.simp.config.MessageBrokerRegistry;
|
|
|
+import org.springframework.web.socket.config.annotation.EnableWebSocketMessageBroker;
|
|
|
+import org.springframework.web.socket.config.annotation.StompEndpointRegistry;
|
|
|
+import org.springframework.web.socket.config.annotation.WebSocketMessageBrokerConfigurer;
|
|
|
|
|
|
@Configuration
|
|
|
@EnableWebSocketMessageBroker
|
|
|
public class WebSocketConfig implements WebSocketMessageBrokerConfigurer {
|
|
|
|
|
|
@Override
|
|
|
- public void configureMessageBroker(MessageBrokerConfigurer config) {
|
|
|
+ public void configureMessageBroker(MessageBrokerRegistry config) {
|
|
|
config.enableSimpleBroker("/queue/");
|
|
|
- config.setAnnotationMethodDestinationPrefixes("/app");
|
|
|
+ config.setApplicationDestinationPrefixes("/app");
|
|
|
}
|
|
|
-
|
|
|
+
|
|
|
@Override
|
|
|
public void registerStompEndpoints(StompEndpointRegistry registry) {
|
|
|
registry.addEndpoint("/hello").withSockJS();
|
|
|
}
|
|
|
|
|
|
+ @Override
|
|
|
+ public void configureClientInboundChannel(ChannelRegistration channelRegistration) {
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public void configureClientOutboundChannel(ChannelRegistration channelRegistration) {
|
|
|
+ }
|
|
|
+
|
|
|
}
|