feat: ContentProducer & SummarizedContentConsumer 구현

ContentProducer, SummarizedContentConsumer, ContentMessageDto

backend/src/main/java/com/rollthedice/backend/domain/news/contentqueue/ContentProducer.java

@@ -0,0 +1,26 @@
+package com.rollthedice.backend.domain.news.contentqueue;
+
+import com.rollthedice.backend.domain.news.dto.ContentMessageDto;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.amqp.rabbit.core.RabbitTemplate;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Component;
+
+@Slf4j
+@RequiredArgsConstructor
+@Component
+public class ContentProducer {
+    @Value("${rabbitmq.summary.exchange.name}")
+    private String exchangeName;
+
+    @Value("${rabbitmq.summary.routing.key}")
+    private String routingKey;
+
+    private final RabbitTemplate rabbitTemplate;
+
+    public void sendMessage(ContentMessageDto messageDto) {
+        log.info("publish news content message : {}", messageDto.getId());
+        rabbitTemplate.convertAndSend(exchangeName, routingKey, messageDto);
+    }
+}

backend/src/main/java/com/rollthedice/backend/domain/news/contentqueue/SummarizedContentConsumer.java

@@ -0,0 +1,21 @@
+package com.rollthedice.backend.domain.news.contentqueue;
+
+import com.rollthedice.backend.domain.news.dto.ContentMessageDto;
+import com.rollthedice.backend.domain.news.service.NewsService;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.amqp.rabbit.annotation.RabbitListener;
+import org.springframework.stereotype.Component;
+
+@Slf4j
+@RequiredArgsConstructor
+@Component
+public class SummarizedContentConsumer {
+    private final NewsService newsService;
+
+    @RabbitListener(queues = "${rabbitmq.store.queue.name}")
+    public void receiveMessage(ContentMessageDto messageDto) {
+        log.info("Received summarized news message id: {}", messageDto.getId());
+        newsService.updateSummarizedNews(messageDto);
+    }
+}

backend/src/main/java/com/rollthedice/backend/domain/news/dto/ContentMessageDto.java

@@ -0,0 +1,12 @@
+package com.rollthedice.backend.domain.news.dto;
+
+import lombok.*;
+
+@Getter
+@Setter
+@AllArgsConstructor
+@NoArgsConstructor
+public class ContentMessageDto {
+    private Long id;
+    private String content;
+}