From c939fc9523e9092d55bc2c3f64cf52fd5b8b059f Mon Sep 17 00:00:00 2001
From: PgmJun <84304802+PgmJun@users.noreply.github.com>
Date: Sat, 21 Sep 2024 14:51:22 +0900
Subject: [PATCH] =?UTF-8?q?=E2=9C=A8:=20feat=20SQS=20Producer=EC=97=90?=
 =?UTF-8?q?=EC=84=9C=20SQS=EB=A1=9C=20=EC=95=8C=EB=A6=BC=20=EB=B0=9C?=
 =?UTF-8?q?=EC=86=A1=20retry=20=EC=8B=A4=ED=8C=A8=20=EC=8B=9C,=20recover?=
 =?UTF-8?q?=20=EC=B2=98=EB=A6=AC=EB=A5=BC=20=ED=86=B5=ED=95=9C=20error=20?=
 =?UTF-8?q?=EB=A1=9C=EA=B9=85=20=EB=B0=8F=20Slack=20=EC=95=8C=EB=A6=BC?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../lionheart/api/config/sqs/producer/SqsProducer.java     | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git a/lionheart-api/src/main/java/com/chiwawa/lionheart/api/config/sqs/producer/SqsProducer.java b/lionheart-api/src/main/java/com/chiwawa/lionheart/api/config/sqs/producer/SqsProducer.java
index 93c8559..89941a1 100644
--- a/lionheart-api/src/main/java/com/chiwawa/lionheart/api/config/sqs/producer/SqsProducer.java
+++ b/lionheart-api/src/main/java/com/chiwawa/lionheart/api/config/sqs/producer/SqsProducer.java
@@ -57,6 +57,13 @@ public void produce(MessageDto dto) {
         }
     }
 
+    @Recover
+    private void recoverListener(AmazonSQSException exception, MessageDto dto) {
+        throw new InternalServerException(
+                String.format("SQS로 메시지를 Produce 하는 과정에서 에러가 발생하며 메시지 발행에 실패하였습니다. :: Message -> %s", dto.toString())
+                , SQS_EXCEPTION);
+    }
+
     private Map<String, MessageAttributeValue> createMessageAttributes(String type) {
         final String dataType = "String";
         return Map.of(MessageType.MESSAGE_TYPE_HEADER, new MessageAttributeValue()