From aa27e22cfdc65dc7dbf2615f1ff41ad32ef9547c Mon Sep 17 00:00:00 2001
From: lucasmoraist <luksmnt1101@gmail.com>
Date: Fri, 4 Oct 2024 10:28:43 -0300
Subject: [PATCH] feat(develop): adding rabbitTemplate to adding  at queue

---
 .../tasks/service/impl/TaskServiceImpl.java    | 18 +++++++++++-------
 1 file changed, 11 insertions(+), 7 deletions(-)

diff --git a/tasks/src/main/java/com/lucasmoraist/tasks/service/impl/TaskServiceImpl.java b/tasks/src/main/java/com/lucasmoraist/tasks/service/impl/TaskServiceImpl.java
index 72128f0..335647e 100644
--- a/tasks/src/main/java/com/lucasmoraist/tasks/service/impl/TaskServiceImpl.java
+++ b/tasks/src/main/java/com/lucasmoraist/tasks/service/impl/TaskServiceImpl.java
@@ -10,10 +10,9 @@
 import jakarta.transaction.Transactional;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
-import org.springframework.data.domain.Page;
-import org.springframework.data.domain.Pageable;
+import org.springframework.amqp.rabbit.core.RabbitTemplate;
 import org.springframework.stereotype.Service;
-import org.modelmapper.ModelMapper;
+
 
 import java.util.List;
 
@@ -24,7 +23,7 @@ public class TaskServiceImpl implements TaskService {
 
     private final TaskRepository repository;
     private final CommentClient commentClient;
-    private final ModelMapper modelMapper;
+    private final RabbitTemplate rabbitTemplate;
 
     @Override
     public void createTask(TaskRequest request) {
@@ -69,14 +68,19 @@ public Task findById(Long id) {
 
     @Transactional
     @Override
-    public void addComment(Long id, CommentDTO comment) {
+    public void addComment(Long id, CommentDTO dto) {
+
+        CommentDTO comment = new CommentDTO(dto.text(), id);
 
-        Long commentId = this.commentClient.createComment(id, comment);
+        this.rabbitTemplate.convertAndSend(
+                "task.ex",
+                "",
+                comment);
 
         Task task = this.findById(id);
         task.getComment().add(Comment.builder()
-                .id(commentId)
                 .text(comment.text())
+                .taskId(id)
                 .build());
 
         this.repository.save(task);