From ff68fac4151768d6c75671be7b0057dfef669800 Mon Sep 17 00:00:00 2001 From: JuHyeonPark Date: Wed, 24 Jan 2024 13:37:50 +0900 Subject: [PATCH] =?UTF-8?q?refactor:=20=ED=95=B8=EB=93=A4=EB=9F=AC=20?= =?UTF-8?q?=EC=9D=98=EC=A1=B4=EC=84=B1=20=EC=A3=BC=EC=9E=85?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit 핸들러 의존성 주입 --- .../yanabada/common/config/WebSockConfig.java | 11 +++++++++++ 1 file changed, 11 insertions(+) diff --git a/src/main/java/kr/co/fastcampus/yanabada/common/config/WebSockConfig.java b/src/main/java/kr/co/fastcampus/yanabada/common/config/WebSockConfig.java index 0f19a118..adc8f7b7 100644 --- a/src/main/java/kr/co/fastcampus/yanabada/common/config/WebSockConfig.java +++ b/src/main/java/kr/co/fastcampus/yanabada/common/config/WebSockConfig.java @@ -1,15 +1,21 @@ package kr.co.fastcampus.yanabada.common.config; +import kr.co.fastcampus.yanabada.common.handler.StompHandler; +import lombok.RequiredArgsConstructor; import org.springframework.context.annotation.Configuration; +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 +@RequiredArgsConstructor @EnableWebSocketMessageBroker public class WebSockConfig implements WebSocketMessageBrokerConfigurer { + private final StompHandler stompHandler; + @Override public void configureMessageBroker(MessageBrokerRegistry config) { config.enableSimpleBroker("/sub"); @@ -20,4 +26,9 @@ public void configureMessageBroker(MessageBrokerRegistry config) { public void registerStompEndpoints(StompEndpointRegistry registry) { registry.addEndpoint("/ws-stomp").setAllowedOriginPatterns("*"); } + + @Override + public void configureClientInboundChannel(ChannelRegistration registration) { + registration.interceptors(stompHandler); + } }