[MS-196] Log: WebSocket log 명시 구체화

MODU-TAXI · Sep 3, 2024 · ed5f26c · ed5f26c
1 parent 0ddf586
commit ed5f26c
Show file tree

Hide file tree

Showing 3 changed files with 15 additions and 2 deletions.
diff --git a/src/main/java/com/modutaxi/api/common/config/websocket/StompHandler.java b/src/main/java/com/modutaxi/api/common/config/websocket/StompHandler.java
@@ -117,6 +117,7 @@ else if (StompCommand.SUBSCRIBE == accessor.getCommand()) {
             String sessionId = accessor.getSessionId();
             // 세션에 대한 정보 삭제
             redisChatRoomRepositoryImpl.removeUserBySessionIdEnterInfo(sessionId);
+            log.info("SESSION DELETE");
         }
 
         return message;

diff --git a/src/main/java/com/modutaxi/api/domain/chat/controller/ChatController.java b/src/main/java/com/modutaxi/api/domain/chat/controller/ChatController.java
@@ -11,6 +11,7 @@
 import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.tags.Tag;
 import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.http.ResponseEntity;
 import org.springframework.messaging.handler.annotation.MessageMapping;
 import org.springframework.web.bind.annotation.GetMapping;
@@ -21,6 +22,7 @@
 
 @RequiredArgsConstructor
 @RestController
+@Slf4j
 @Tag(name = "pub/sub 관련 API")
 public class ChatController {
 
@@ -39,7 +41,6 @@ public void sendMessage(ChatMessageRequestDto message) {
         message.setMemberId(memberId);
         message.setDateTime(LocalDateTime.now());
 
-
         // Websocket에 발행된 메시지를 redis로 발행(publish)
         chatService.sendChatMessage(message);
     }

diff --git a/src/main/java/com/modutaxi/api/domain/chat/service/RedisSubscriber.java b/src/main/java/com/modutaxi/api/domain/chat/service/RedisSubscriber.java
@@ -6,9 +6,11 @@
 import com.modutaxi.api.common.exception.errorcode.StompErrorCode;
 import com.modutaxi.api.domain.chatmessage.dto.ChatMessageResponseDto.ChatMessageResponse;
 import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.messaging.simp.SimpMessageSendingOperations;
 import org.springframework.stereotype.Service;
 
+@Slf4j
 @Service
 @RequiredArgsConstructor
 public class RedisSubscriber {
@@ -20,8 +22,17 @@ public void sendMessage(String publishMessage) {
         try {
             ChatMessageResponse chatMessageResponse;
             chatMessageResponse = objectMapper.readValue(publishMessage, ChatMessageResponse.class);
+
+            // Log each field of ChatMessageResponse
+            log.info("Room ID: {}", chatMessageResponse.getRoomId());
+            log.info("Message Type: {}", chatMessageResponse.getMessageType());
+            log.info("Content: {}", chatMessageResponse.getContent());
+            log.info("Sender: {}", chatMessageResponse.getSender());
+            log.info("Member ID: {}", chatMessageResponse.getMemberId());
+            log.info("Date and Time: {}", chatMessageResponse.getDateTime());
+
             messageSendingOperations.convertAndSend("/sub/chat/" + chatMessageResponse.getRoomId(),
-                    chatMessageResponse);
+                chatMessageResponse);
         } catch (JsonProcessingException e) {
             throw new BaseException(StompErrorCode.FAIL_SEND_MESSAGE);
         }