Revert "revert(chat): Revert WebSocket/RabbitMQ changes"

This reverts commit a2bdeb8.

Author: JIWONKIMS

src/main/kotlin/com/back/koreaTravelGuide/domain/userChat/chatmessage/usecase/RabbitChatMessagePublisher.kt

@@ -1,23 +1,20 @@
 package com.back.koreaTravelGuide.domain.userChat.chatmessage.usecase
 
-import org.springframework.amqp.rabbit.core.RabbitTemplate
 import org.springframework.context.annotation.Profile
+import org.springframework.messaging.simp.SimpMessagingTemplate
 import org.springframework.stereotype.Component
 
 @Profile("prod")
 @Component
 class RabbitChatMessagePublisher(
-//    private val messagingTemplate: SimpMessagingTemplate,
-    private val rabbitTemplate: RabbitTemplate,
+    private val messagingTemplate: SimpMessagingTemplate,
 ) : ChatMessagePublisher {
     override fun publishUserChat(
         roomId: Long,
         payload: Any,
     ) {
-        val routingKey = "userchat.$roomId"
-        rabbitTemplate.convertAndSend("amq.topic", routingKey, payload)
         // STOMP Broker Relay를 통해 RabbitMQ로 메시지 발행
         // enableStompBrokerRelay("/topic") 설정에 의해 자동으로 RabbitMQ STOMP Broker로 라우팅됨
-//        messagingTemplate.convertAndSend("/topic/userchat/$roomId", payload)
+        messagingTemplate.convertAndSend("/topic/userchat/$roomId", payload)
     }
 }

src/main/kotlin/com/back/koreaTravelGuide/domain/userChat/stomp/UserChatRabbitWebSocketConfig.kt

@@ -27,7 +27,7 @@ class UserChatRabbitWebSocketConfig(
     override fun registerStompEndpoints(registry: StompEndpointRegistry) {
         registry.addEndpoint("/ws/userchat")
             .setAllowedOriginPatterns("*")
-//            .setAllowedOrigins("https://www.team11.giwon11292.com", "http://localhost:3000")
+            .setAllowedOrigins("https://www.team11.giwon11292.com", "http://localhost:3000")
             .withSockJS()
     }
 

src/main/kotlin/com/back/koreaTravelGuide/domain/userChat/stomp/UserChatSimpleWebSocketConfig.kt

@@ -17,7 +17,7 @@ class UserChatSimpleWebSocketConfig(
     override fun registerStompEndpoints(registry: StompEndpointRegistry) {
         registry.addEndpoint("/ws/userchat")
             .setAllowedOriginPatterns("*")
-//            .setAllowedOrigins("https://www.team11.giwon11292.com", "http://localhost:3000")
+            .setAllowedOrigins("https://www.team11.giwon11292.com", "http://localhost:3000")
             .withSockJS()
     }
 

src/main/kotlin/com/back/koreaTravelGuide/domain/userChat/stomp/UserChatStompAuthChannelInterceptor.kt

@@ -1,5 +1,6 @@
 package com.back.koreaTravelGuide.domain.userChat.stomp
 
+import com.back.koreaTravelGuide.common.logging.log
 import com.back.koreaTravelGuide.common.security.JwtTokenProvider
 import org.springframework.messaging.Message
 import org.springframework.messaging.MessageChannel
@@ -20,7 +21,7 @@ class UserChatStompAuthChannelInterceptor(
     ): Message<*>? {
         val accessor = MessageHeaderAccessor.getAccessor(message, StompHeaderAccessor::class.java) ?: return message
 
-//        log.info("📨 [STOMP] Command: ${accessor.command}, User: ${accessor.user}, SessionId: ${accessor.sessionId}")
+        log.info("📨 [STOMP] Command: ${accessor.command}, User: ${accessor.user}, SessionId: ${accessor.sessionId}")
 
         if (accessor.command == StompCommand.CONNECT) {
             val rawHeader =
@@ -31,9 +32,9 @@ class UserChatStompAuthChannelInterceptor(
                 throw AuthenticationCredentialsNotFoundException("Invalid JWT token")
             }
             accessor.user = jwtTokenProvider.getAuthentication(token)
-//            log.info("✅ [STOMP] CONNECT authenticated: userId=${accessor.user?.name}")
+            log.info("✅ [STOMP] CONNECT authenticated: userId=${accessor.user?.name}")
         } else if (accessor.user == null) {
-//            log.error("❌ [STOMP] Unauthenticated ${accessor.command} request - SessionId: ${accessor.sessionId}")
+            log.error("❌ [STOMP] Unauthenticated ${accessor.command} request - SessionId: ${accessor.sessionId}")
             throw AuthenticationCredentialsNotFoundException("Unauthenticated STOMP request")
         }