fix: LocalDateTime 타입 직렬화/역직렬화 오류로 인한 코드 수정

kjungw1025 · Feb 1, 2024 · 267d1b3 · 267d1b3
1 parent 8f6088a
commit 267d1b3
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 2 deletions.
diff --git a/src/main/java/com/dku/council/domain/chat/service/MessageReceiver.java b/src/main/java/com/dku/council/domain/chat/service/MessageReceiver.java
@@ -1,9 +1,10 @@
 package com.dku.council.domain.chat.service;
 
 import com.dku.council.domain.chat.model.dto.Message;
-import com.dku.council.domain.chat.model.dto.response.ResponseChatDto;
 import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.databind.ObjectMapper;
+import com.fasterxml.jackson.databind.SerializationFeature;
+import com.fasterxml.jackson.datatype.jsr310.JavaTimeModule;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.kafka.annotation.KafkaListener;
@@ -20,6 +21,8 @@ public class MessageReceiver {
     public void receiveMessage(String stringChat) throws JsonProcessingException {
 
         ObjectMapper objectMapper = new ObjectMapper();
+        objectMapper.registerModule(new JavaTimeModule());
+        objectMapper.disable(SerializationFeature.WRITE_DATES_AS_TIMESTAMPS);
         Message message = objectMapper.readValue(stringChat, Message.class);
         log.info("Consumed Message : " + stringChat);
 

diff --git a/src/main/java/com/dku/council/domain/chat/service/MessageSender.java b/src/main/java/com/dku/council/domain/chat/service/MessageSender.java
@@ -1,9 +1,10 @@
 package com.dku.council.domain.chat.service;
 
 import com.dku.council.domain.chat.model.dto.Message;
-import com.dku.council.domain.chat.model.dto.response.ResponseChatDto;
 import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.databind.ObjectMapper;
+import com.fasterxml.jackson.databind.SerializationFeature;
+import com.fasterxml.jackson.datatype.jsr310.JavaTimeModule;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.kafka.core.KafkaTemplate;
@@ -20,6 +21,8 @@ public void send(String topic, Message data) {
 
         // 메시지를 KafkaTemplate 를 사용하여 지정된 토픽으로 전송
         ObjectMapper objectMapper = new ObjectMapper();
+        objectMapper.registerModule(new JavaTimeModule());
+        objectMapper.disable(SerializationFeature.WRITE_DATES_AS_TIMESTAMPS);
         try {
             String stringChat = objectMapper.writeValueAsString(data);
             log.info("MessageSender Message -> String형 : " + stringChat);