From 3bac1d525838e24e8c67e11389dfc2b23104950f Mon Sep 17 00:00:00 2001 From: hyunw9 Date: Fri, 6 Sep 2024 17:32:20 +0900 Subject: [PATCH] =?UTF-8?q?Fix=20:=20=EC=B2=98=EB=A6=AC=20=EC=8B=A4?= =?UTF-8?q?=ED=8C=A8=EC=8B=9C=20=EC=98=88=EC=99=B8=20=EB=B0=9C=EC=83=9D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../processors/RodyMessageProcessor.java | 19 ++++++++++++++----- 1 file changed, 14 insertions(+), 5 deletions(-) diff --git a/clody-domain/src/main/java/com/clody/domain/reply/service/processors/RodyMessageProcessor.java b/clody-domain/src/main/java/com/clody/domain/reply/service/processors/RodyMessageProcessor.java index 4c46aec..31fba97 100644 --- a/clody-domain/src/main/java/com/clody/domain/reply/service/processors/RodyMessageProcessor.java +++ b/clody-domain/src/main/java/com/clody/domain/reply/service/processors/RodyMessageProcessor.java @@ -4,6 +4,7 @@ import com.clody.domain.reply.dto.DequeuedMessage; import com.clody.domain.reply.repository.ReplyRepository; import com.clody.domain.reply.service.RodyProcessor; +import com.clody.support.exception.NotFoundException; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.springframework.context.event.EventListener; @@ -19,12 +20,20 @@ public class RodyMessageProcessor { @EventListener public void sendDequeuedMessageToRody(DequeuedMessage message){ - Reply reply = replyRepository.findById(message.replyId()); - if(reply.checkReplyDeleted()){ - log.info("Deleted reply: {}", reply.getId()); - return; + try { + Reply reply = replyRepository.findById(message.replyId()); + + if (reply.checkReplyDeleted()) { + log.info("Deleted reply: {}", reply.getId()); + return; + } + + rodyProcessor.createReply(message); + } catch (NotFoundException e) { + log.info("Reply 발견 실패 : {}. 프로세스 스킵.", message.replyId()); + } catch (Exception e) { + log.error("처리 중 오류가 발생했습니다. Reply Id: {}. Error: {}", message.replyId(), e.getMessage()); } - rodyProcessor.createReply(message); } }