34 lines
1.1 KiB
Java
34 lines
1.1 KiB
Java
package com.baeldung.reactive.websocket;
|
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.context.annotation.Bean;
|
|
import org.springframework.context.annotation.Configuration;
|
|
import org.springframework.web.reactive.HandlerMapping;
|
|
import org.springframework.web.reactive.handler.SimpleUrlHandlerMapping;
|
|
import org.springframework.web.reactive.socket.WebSocketHandler;
|
|
import org.springframework.web.reactive.socket.server.support.WebSocketHandlerAdapter;
|
|
import java.util.HashMap;
|
|
import java.util.Map;
|
|
|
|
@Configuration
|
|
public class ReactiveWebSocketConfiguration {
|
|
|
|
@Autowired
|
|
private WebSocketHandler webSocketHandler;
|
|
|
|
@Bean
|
|
public HandlerMapping webSocketHandlerMapping() {
|
|
Map<String, WebSocketHandler> map = new HashMap<>();
|
|
map.put("/event-emitter", webSocketHandler);
|
|
|
|
SimpleUrlHandlerMapping handlerMapping = new SimpleUrlHandlerMapping();
|
|
handlerMapping.setOrder(1);
|
|
handlerMapping.setUrlMap(map);
|
|
return handlerMapping;
|
|
}
|
|
|
|
@Bean
|
|
public WebSocketHandlerAdapter handlerAdapter() {
|
|
return new WebSocketHandlerAdapter();
|
|
}
|
|
} |