✨: feat SQS Producer에서 SQS로 알림 발송 retry 실패 시, recover 처리를 통한 error 로깅…

… 및 Slack 알림
Team-LionHeart · Sep 21, 2024 · c939fc9 · c939fc9
1 parent 8af22fa
commit c939fc9
Showing 1 changed file with 7 additions and 0 deletions.
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
@@ -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()