feat: add RabbitMQ test with TestContainers

Author: hebcodee

domain/src/main/java/br/com/alura/marketplace/domain/usecase/CadastroProdutoUseCase.java

@@ -36,6 +36,7 @@ public Produto cadastrar(Produto produto) {
         var produtoSalvo = produtoRepository.save(produto);
 
 //        queueRepository.notificarCadastro(produtoSalvo);
+
 //        return produtoSalvo;
 
         return Produto.builder().build();

iandt/src/test/java/br/com/alura/marketplace/iandt/CadastroProdutoTest.java

@@ -1,17 +1,16 @@
 package br.com.alura.marketplace.iandt;
 
 import br.com.alura.marketplace.application.Application;
+import br.com.alura.marketplace.domain.repository.ProdutoRepository;
 import br.com.alura.marketplace.iandt.setup.LocalStackSetup;
 import br.com.alura.marketplace.iandt.setup.PostgresSetup;
+import br.com.alura.marketplace.iandt.setup.RabbitMQSetup;
 import br.com.alura.marketplace.iandt.setup.WiremockSetup;
 import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import io.awspring.cloud.s3.S3Template;
 import io.restassured.RestAssured;
-import org.junit.jupiter.api.BeforeEach;
-import org.junit.jupiter.api.DisplayName;
-import org.junit.jupiter.api.Nested;
-import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.*;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.boot.test.context.SpringBootTest;
@@ -34,7 +33,7 @@
 @SpringBootTest(webEnvironment = RANDOM_PORT)
 @ContextConfiguration(classes = Application.class)
 @Testcontainers
-public class CadastroProdutoTest implements LocalStackSetup, WiremockSetup, PostgresSetup {
+public class CadastroProdutoTest implements LocalStackSetup, WiremockSetup, PostgresSetup, RabbitMQSetup {
 
     @LocalServerPort
     Integer port;
@@ -45,6 +44,8 @@ public class CadastroProdutoTest implements LocalStackSetup, WiremockSetup, Post
     @Autowired
     S3Template s3Template;
 
+    @Autowired
+    ProdutoRepository produtoRepository;
 
     @Value("${aws.s3.bucket.name}")
     String bucketName;
@@ -58,6 +59,11 @@ void beforeEach() {
         }
     }
 
+    @AfterEach
+    void afterEach() {
+        produtoRepository.deleteAll();
+    }
+
 
     @DisplayName("Quando criar um produto")
     @Nested

iandt/src/test/java/br/com/alura/marketplace/iandt/setup/RabbitMQSetup.java

@@ -0,0 +1,25 @@
+package br.com.alura.marketplace.iandt.setup;
+
+import org.junit.jupiter.api.BeforeAll;
+import org.springframework.test.context.DynamicPropertyRegistry;
+import org.springframework.test.context.DynamicPropertySource;
+import org.testcontainers.containers.RabbitMQContainer;
+import org.testcontainers.utility.DockerImageName;
+
+public interface RabbitMQSetup {
+
+    RabbitMQContainer RABBIT_MQ = new RabbitMQContainer(DockerImageName.parse("rabbitmq:3.7.25-management-alpine"));
+
+    @DynamicPropertySource
+    static void rabbitMQDynamicPropertySource(DynamicPropertyRegistry registry) {
+        registry.add("spring.rabbitmq.host", RABBIT_MQ::getHost);
+        registry.add("spring.rabbitmq.port", RABBIT_MQ::getAmqpPort);
+        registry.add("spring.rabbitmq.username", RABBIT_MQ::getAdminUsername);
+        registry.add("spring.rabbitmq.password", RABBIT_MQ::getAdminPassword);
+    }
+
+    @BeforeAll
+    static void rabbitMQBeforeAll() {
+        RABBIT_MQ.start();
+    }
+}