Feat/amqp handle routing key

springwolf-examples/springwolf-amqp-example/README.md

@@ -4,3 +4,4 @@
 1. Copy the `docker-compose.yml` file to your machine.
 2. Run `$ docker-compose up`.
 3. Visit `localhost:8080/springwolf/asyncapi-ui.html` or try the API: `$ curl localhost:8080/springwolf/docs`.
+4. RabbitMQ Management: `http://localhost:15672` using `guest:guest` as login

springwolf-examples/springwolf-amqp-example/build.gradle

@@ -33,6 +33,8 @@ dependencies {
     testImplementation "com.vaadin.external.google:android-json:${androidJsonVersion}"
 
     testImplementation "org.assertj:assertj-core:${assertjCoreVersion}"
+    testImplementation "org.awaitility:awaitility:${awaitilityVersion}"
+    testImplementation "org.mockito:mockito-core:${mockitoCoreVersion}"
     testImplementation "org.junit.jupiter:junit-jupiter-api:${junitJupiterVersion}"
 
     testImplementation "org.springframework.boot:spring-boot-test"

springwolf-examples/springwolf-amqp-example/src/main/java/io/github/stavshamir/springwolf/example/amqp/configuration/RabbitConfiguration.java

@@ -32,7 +32,7 @@ public Queue anotherQueue() {
 
     @Bean
     public Queue exampleBindingsQueue() {
-        return new Queue("example-bindings-queue", false);
+        return new Queue("example-bindings-queue", false, true, true);
     }
 
     @Bean

springwolf-examples/springwolf-amqp-example/src/main/java/io/github/stavshamir/springwolf/example/amqp/consumers/ExampleConsumer.java

@@ -2,6 +2,8 @@
 
 import io.github.stavshamir.springwolf.example.amqp.dtos.AnotherPayloadDto;
 import io.github.stavshamir.springwolf.example.amqp.dtos.ExamplePayloadDto;
+import io.github.stavshamir.springwolf.example.amqp.producers.ExampleProducer;
+import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.amqp.core.ExchangeTypes;
 import org.springframework.amqp.rabbit.annotation.Exchange;
@@ -12,11 +14,15 @@
 
 @Service
 @Slf4j
+@RequiredArgsConstructor
 public class ExampleConsumer {
 
+    private final ExampleProducer exampleProducer;
+
     @RabbitListener(queues = "example-queue")
     public void receiveExamplePayload(ExamplePayloadDto payload) {
         log.info("Received new message in example-queue: {}", payload.toString());
+        exampleProducer.sendMessage(payload);
     }
 
     @RabbitListener(queues = "another-queue")
@@ -27,8 +33,14 @@ public void receiveAnotherPayload(AnotherPayloadDto payload) {
     @RabbitListener(
             bindings = {
                 @QueueBinding(
-                        exchange = @Exchange(name = "name", type = ExchangeTypes.TOPIC),
-                        value = @Queue(name = "example-bindings-queue"))
+                        exchange = @Exchange(name = "example-bindings-exchange-name", type = ExchangeTypes.TOPIC),
+                        value =
+                                @Queue(
+                                        name = "example-bindings-queue",
+                                        durable = "false",
+                                        exclusive = "true",
+                                        autoDelete = "true"),
+                        key = "example-topic-routing-key")
             })
     public void bindingsExample(AnotherPayloadDto payload) {
         log.info("Received new message in example-bindings-queue: {}", payload.toString());

springwolf-examples/springwolf-amqp-example/src/main/java/io/github/stavshamir/springwolf/example/amqp/dtos/AnotherPayloadDto.java

@@ -1,37 +1,22 @@
 package io.github.stavshamir.springwolf.example.amqp.dtos;
 
 import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
 
 import static io.swagger.v3.oas.annotations.media.Schema.RequiredMode.NOT_REQUIRED;
 import static io.swagger.v3.oas.annotations.media.Schema.RequiredMode.REQUIRED;
 
 @Schema(description = "Another payload model")
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
 public class AnotherPayloadDto {
 
     @Schema(description = "Foo field", example = "bar", requiredMode = NOT_REQUIRED)
     private String foo;
 
     @Schema(description = "Example field", requiredMode = REQUIRED)
     private ExamplePayloadDto example;
-
-    public String getFoo() {
-        return foo;
-    }
-
-    public void setFoo(String foo) {
-        this.foo = foo;
-    }
-
-    public ExamplePayloadDto getExample() {
-        return example;
-    }
-
-    public void setExample(ExamplePayloadDto example) {
-        this.example = example;
-    }
-
-    @Override
-    public String toString() {
-        return "AnotherPayloadDto{" + "foo='" + foo + '\'' + ", example=" + example + '}';
-    }
 }

springwolf-examples/springwolf-amqp-example/src/main/java/io/github/stavshamir/springwolf/example/amqp/dtos/ExamplePayloadDto.java

@@ -1,10 +1,16 @@
 package io.github.stavshamir.springwolf.example.amqp.dtos;
 
 import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
 
 import static io.swagger.v3.oas.annotations.media.Schema.RequiredMode.REQUIRED;
 
 @Schema(description = "Example payload model")
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
 public class ExamplePayloadDto {
     @Schema(description = "Some string field", example = "some string value", requiredMode = REQUIRED)
     private String someString;
@@ -15,41 +21,9 @@ public class ExamplePayloadDto {
     @Schema(description = "Some enum field", example = "FOO2", requiredMode = REQUIRED)
     private ExampleEnum someEnum;
 
-    public String getSomeString() {
-        return someString;
-    }
-
-    public void setSomeString(String someString) {
-        this.someString = someString;
-    }
-
-    public long getSomeLong() {
-        return someLong;
-    }
-
-    public void setSomeLong(long someLong) {
-        this.someLong = someLong;
-    }
-
-    public ExampleEnum getSomeEnum() {
-        return someEnum;
-    }
-
-    public void setSomeEnum(ExampleEnum someEnum) {
-        this.someEnum = someEnum;
-    }
-
-    enum ExampleEnum {
+    public enum ExampleEnum {
         FOO1,
         FOO2,
         FOO3
     }
-
-    @Override
-    public String toString() {
-        return "ExamplePayloadDto{" + "someString='"
-                + someString + '\'' + ", someLong="
-                + someLong + ", someEnum="
-                + someEnum + '}';
-    }
 }

springwolf-examples/springwolf-amqp-example/src/main/java/io/github/stavshamir/springwolf/example/amqp/producers/ExampleProducer.java

@@ -3,11 +3,16 @@
 import io.github.stavshamir.springwolf.asyncapi.scanners.channels.operationdata.annotation.AmqpAsyncOperationBinding;
 import io.github.stavshamir.springwolf.asyncapi.scanners.channels.operationdata.annotation.AsyncOperation;
 import io.github.stavshamir.springwolf.asyncapi.scanners.channels.operationdata.annotation.AsyncPublisher;
+import io.github.stavshamir.springwolf.example.amqp.dtos.AnotherPayloadDto;
 import io.github.stavshamir.springwolf.example.amqp.dtos.ExamplePayloadDto;
+import lombok.RequiredArgsConstructor;
+import org.springframework.amqp.rabbit.core.RabbitTemplate;
 import org.springframework.stereotype.Component;
 
 @Component
+@RequiredArgsConstructor
 public class ExampleProducer {
+    private final RabbitTemplate rabbitTemplate;
 
     @AsyncPublisher(
             operation =
@@ -17,5 +22,7 @@ public class ExampleProducer {
     @AmqpAsyncOperationBinding()
     public void sendMessage(ExamplePayloadDto msg) {
         // send
+        AnotherPayloadDto dto = new AnotherPayloadDto("fooValue", msg);
+        rabbitTemplate.convertAndSend("example-topic-exchange", "example-topic-routing-key", dto);
     }
 }

springwolf-examples/springwolf-amqp-example/src/test/java/io/github/stavshamir/springwolf/example/amqp/ProducerIntegrationWithDockerIntegrationTest.java

@@ -0,0 +1,80 @@
+package io.github.stavshamir.springwolf.example.amqp;
+
+import io.github.stavshamir.springwolf.example.amqp.consumers.ExampleConsumer;
+import io.github.stavshamir.springwolf.example.amqp.dtos.ExamplePayloadDto;
+import io.github.stavshamir.springwolf.producer.SpringwolfAmqpProducer;
+import org.junit.jupiter.api.MethodOrderer.OrderAnnotation;
+import org.junit.jupiter.api.Order;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.TestMethodOrder;
+import org.springframework.amqp.AmqpIOException;
+import org.springframework.amqp.rabbit.connection.CachingConnectionFactory;
+import org.springframework.amqp.rabbit.connection.ConnectionFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.boot.test.mock.mockito.SpyBean;
+import org.springframework.test.annotation.DirtiesContext;
+import org.springframework.test.context.TestPropertySource;
+import org.testcontainers.containers.DockerComposeContainer;
+import org.testcontainers.junit.jupiter.Container;
+import org.testcontainers.junit.jupiter.Testcontainers;
+
+import java.io.File;
+
+import static io.github.stavshamir.springwolf.example.amqp.dtos.ExamplePayloadDto.ExampleEnum.FOO1;
+import static java.util.concurrent.TimeUnit.SECONDS;
+import static org.assertj.core.api.Assertions.assertThat;
+import static org.awaitility.Awaitility.await;
+import static org.mockito.Mockito.timeout;
+import static org.mockito.Mockito.verify;
+
+/**
+ * While the assertion of this test is identical to ApiIntegrationTests,
+ * the setup uses a full docker-compose context with a real sqs instance.
+ */
+@SpringBootTest(
+        classes = {SpringwolfAmqpExampleApplication.class},
+        webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)
+@Testcontainers
+@DirtiesContext
+@TestMethodOrder(OrderAnnotation.class)
+@TestPropertySource(properties = {"spring.rabbitmq.host=localhost"})
+// @Ignore("Uncomment this line if you have issues running this test on your local machine.")
+public class ProducerIntegrationWithDockerIntegrationTest {
+
+    @Autowired
+    SpringwolfAmqpProducer springwolfAmqpProducer;
+
+    @SpyBean
+    ExampleConsumer exampleConsumer;
+
+    @Container
+    public static DockerComposeContainer<?> environment =
+            new DockerComposeContainer<>(new File("docker-compose.yml")).withServices("amqp");
+
+    @Test
+    @Order(1)
+    void verifyAmqpIsAvailable() {
+        ConnectionFactory factory = new CachingConnectionFactory("localhost");
+
+        await().atMost(60, SECONDS).ignoreException(AmqpIOException.class).untilAsserted(() -> assertThat(
+                        factory.createConnection().isOpen())
+                .isTrue());
+    }
+
+    @Test
+    @Order(2)
+    void producerCanUseSpringwolfConfigurationToSendMessage() {
+        // given
+        ExamplePayloadDto payload = new ExamplePayloadDto();
+        payload.setSomeString("foo");
+        payload.setSomeLong(5);
+        payload.setSomeEnum(FOO1);
+
+        // when
+        springwolfAmqpProducer.send("example-queue", payload);
+
+        // then
+        verify(exampleConsumer, timeout(10000)).receiveExamplePayload(payload);
+    }
+}