Units test to investigate AMQP generation

.gitignore

@@ -24,6 +24,7 @@ springwolf-bindings/springwolf-sqs-binding/build/
 node_modules/
 
 asyncapi.actual.json
+asyncapi.actual.yaml
 
 # Eclipse IDE
 .classpath

springwolf-examples/springwolf-amqp-example/src/main/java/io/github/springwolf/examples/amqp/AmqpConstants.java

@@ -0,0 +1,45 @@
+// SPDX-License-Identifier: Apache-2.0
+package io.github.springwolf.examples.amqp;
+
+import lombok.AccessLevel;
+import lombok.NoArgsConstructor;
+
+@NoArgsConstructor(access = AccessLevel.PRIVATE)
+public final class AmqpConstants {
+
+    // Exchanges
+
+    public static final String EXCHANGE_EXAMPLE_TOPIC_EXCHANGE = "example-topic-exchange";
+    public static final String EXCHANGE_CRUD_TOPIC_EXCHANGE_1 = "CRUD-topic-exchange-1";
+    public static final String EXCHANGE_CRUD_TOPIC_EXCHANGE_2 = "CRUD-topic-exchange-2";
+    /**
+     *  Direct Exchange - Routing is based on 'Routing key'.
+     *  Messages are 'routed' towards queue which name is equals to 'routing key' <BR/>
+     *  Note:<BR/>
+     *  The 'Default exchange' is a 'Direct exchange' with an empty name ( name= "")
+     */
+    public static final String EXCHANGE_DEFAULT_EXCHANGE = "";
+
+    // Routing keys
+
+    /**
+     * When a queue is bound with "#" (hash) binding key,
+     * it will receive all the messages, regardless of the routing key - like in fanout exchange.
+     */
+    public static final String ROUTING_KEY_ALL_MESSAGES = "#";
+
+    public static final String ROUTING_KEY_CRUD = "crud-routing-key";
+    public static final String ROUTING_KEY_EXAMPLE_TOPIC_ROUTING_KEY = "example-topic-routing-key";
+
+    // Queues
+
+    public static final String QUEUE_EXAMPLE_QUEUE = "example-queue";
+    public static final String QUEUE_ANOTHER_QUEUE = "another-queue";
+    public static final String QUEUE_MULTI_PAYLOAD_QUEUE = "multi-payload-queue";
+    public static final String QUEUE_EXAMPLE_BINDINGS_QUEUE = "example-bindings-queue";
+
+    public static final String QUEUE_CREATE = "queue-create";
+    public static final String QUEUE_READ = "queue-read";
+    public static final String QUEUE_DELETE = "queue-delete";
+    public static final String QUEUE_UPDATE = "queue-update";
+}

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

@@ -1,6 +1,7 @@
 // SPDX-License-Identifier: Apache-2.0
 package io.github.springwolf.examples.amqp.configuration;
 
+import io.github.springwolf.examples.amqp.AmqpConstants;
 import org.springframework.amqp.core.Binding;
 import org.springframework.amqp.core.BindingBuilder;
 import org.springframework.amqp.core.Exchange;
@@ -23,34 +24,39 @@ public Jackson2JsonMessageConverter converter() {
 
     @Bean
     public Queue exampleQueue() {
-        return new Queue("example-queue", false);
+        return new Queue(AmqpConstants.QUEUE_EXAMPLE_QUEUE, false);
     }
 
     @Bean
     public Queue anotherQueue() {
-        return new Queue("another-queue", false);
+        return new Queue(AmqpConstants.QUEUE_ANOTHER_QUEUE, false);
     }
 
     @Bean
     public Queue exampleBindingsQueue() {
-        return new Queue("example-bindings-queue", false, true, true);
+        return new Queue(AmqpConstants.QUEUE_EXAMPLE_BINDINGS_QUEUE, false, true, true);
+    }
+
+    @Bean
+    public Queue queueRead() {
+        return new Queue(AmqpConstants.QUEUE_READ, false);
     }
 
     @Bean
     public Exchange exampleTopicExchange() {
-        return new TopicExchange("example-topic-exchange");
+        return new TopicExchange(AmqpConstants.EXCHANGE_EXAMPLE_TOPIC_EXCHANGE);
     }
 
     @Bean
     public Queue multiPayloadQueue() {
-        return new Queue("multi-payload-queue");
+        return new Queue(AmqpConstants.QUEUE_MULTI_PAYLOAD_QUEUE);
     }
 
     @Bean
     public Binding exampleTopicBinding(Queue exampleBindingsQueue, Exchange exampleTopicExchange) {
         return BindingBuilder.bind(exampleBindingsQueue)
                 .to(exampleTopicExchange)
-                .with("example-topic-routing-key")
+                .with(AmqpConstants.ROUTING_KEY_EXAMPLE_TOPIC_ROUTING_KEY)
                 .noargs();
     }
 }

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

@@ -1,16 +1,20 @@
 // SPDX-License-Identifier: Apache-2.0
 package io.github.springwolf.examples.amqp.consumers;
 
+import io.github.springwolf.examples.amqp.AmqpConstants;
 import io.github.springwolf.examples.amqp.dtos.AnotherPayloadDto;
 import io.github.springwolf.examples.amqp.dtos.ExamplePayloadDto;
+import io.github.springwolf.examples.amqp.dtos.GenericPayloadDto;
 import io.github.springwolf.examples.amqp.producers.AnotherProducer;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.amqp.core.ExchangeTypes;
+import org.springframework.amqp.core.Message;
 import org.springframework.amqp.rabbit.annotation.Exchange;
 import org.springframework.amqp.rabbit.annotation.Queue;
 import org.springframework.amqp.rabbit.annotation.QueueBinding;
 import org.springframework.amqp.rabbit.annotation.RabbitListener;
+import org.springframework.messaging.handler.annotation.Payload;
 import org.springframework.stereotype.Component;
 
 @Component
@@ -20,9 +24,9 @@ public class ExampleConsumer {
 
     private final AnotherProducer anotherProducer;
 
-    @RabbitListener(queues = "example-queue")
+    @RabbitListener(queues = AmqpConstants.QUEUE_EXAMPLE_QUEUE)
     public void receiveExamplePayload(ExamplePayloadDto payload) {
-        log.info("Received new message in example-queue: {}", payload.toString());
+        log.info("Received new message in {}: {}", AmqpConstants.QUEUE_EXAMPLE_QUEUE, payload.toString());
 
         AnotherPayloadDto example = new AnotherPayloadDto();
         example.setExample(payload);
@@ -31,37 +35,106 @@ public void receiveExamplePayload(ExamplePayloadDto payload) {
         anotherProducer.sendMessage(example);
     }
 
-    @RabbitListener(queues = "another-queue")
+    @RabbitListener(queues = AmqpConstants.QUEUE_ANOTHER_QUEUE)
     public void receiveAnotherPayload(AnotherPayloadDto payload) {
-        log.info("Received new message in another-queue: {}", payload.toString());
+        log.info("Received new message in {}: {}", AmqpConstants.QUEUE_ANOTHER_QUEUE, payload.toString());
     }
 
     @RabbitListener(
             bindings = {
                 @QueueBinding(
-                        exchange = @Exchange(name = "example-topic-exchange", type = ExchangeTypes.TOPIC),
+                        exchange =
+                                @Exchange(
+                                        name = AmqpConstants.EXCHANGE_EXAMPLE_TOPIC_EXCHANGE,
+                                        type = ExchangeTypes.TOPIC),
                         value =
                                 @Queue(
-                                        name = "example-bindings-queue",
+                                        name = AmqpConstants.QUEUE_EXAMPLE_BINDINGS_QUEUE,
                                         durable = "false",
                                         exclusive = "true",
                                         autoDelete = "true"),
-                        key = "example-topic-routing-key")
+                        key = AmqpConstants.ROUTING_KEY_EXAMPLE_TOPIC_ROUTING_KEY)
             })
     public void bindingsExample(AnotherPayloadDto payload) {
         log.info(
-                "Received new message in example-bindings-queue"
-                        + " through exchange example-topic-exchange using routing key example-topic-routing-key: {}",
+                "Received new message in {}" + " through exchange {}" + " using routing key {}: {}",
+                AmqpConstants.QUEUE_EXAMPLE_BINDINGS_QUEUE,
+                AmqpConstants.EXCHANGE_EXAMPLE_TOPIC_EXCHANGE,
+                AmqpConstants.ROUTING_KEY_EXAMPLE_TOPIC_ROUTING_KEY,
                 payload.toString());
     }
 
-    @RabbitListener(queues = "multi-payload-queue")
+    @RabbitListener(queues = AmqpConstants.QUEUE_MULTI_PAYLOAD_QUEUE)
     public void bindingsBeanExample(AnotherPayloadDto payload) {
-        log.info("Received new message in multi-payload-queue (AnotherPayloadDto): {}", payload.toString());
+        log.info(
+                "Received new message in {} (AnotherPayloadDto): {}",
+                AmqpConstants.QUEUE_MULTI_PAYLOAD_QUEUE,
+                payload.toString());
     }
 
-    @RabbitListener(queues = "multi-payload-queue")
+    @RabbitListener(queues = AmqpConstants.QUEUE_MULTI_PAYLOAD_QUEUE)
     public void bindingsBeanExample(ExamplePayloadDto payload) {
-        log.info("Received new message in multi-payload-queue (ExamplePayloadDto): {}", payload.toString());
+        log.info(
+                "Received new message in {} (ExamplePayloadDto): {}",
+                AmqpConstants.QUEUE_MULTI_PAYLOAD_QUEUE,
+                payload.toString());
+    }
+
+    @RabbitListener(
+            autoStartup = "false",
+            queuesToDeclare = @Queue(name = AmqpConstants.QUEUE_CREATE, autoDelete = "false", durable = "true"))
+    public void queuesToDeclareCreate(Message message, @Payload GenericPayloadDto<String> payload) {
+        log.info(
+                "Received new message {} in {} (GenericPayloadDto<String>): {}",
+                message,
+                AmqpConstants.QUEUE_CREATE,
+                payload.toString());
+    }
+
+    @RabbitListener(
+            autoStartup = "false",
+            queuesToDeclare = @Queue(name = AmqpConstants.QUEUE_DELETE, autoDelete = "false", durable = "true"))
+    public void queuesToDeclareDelete(Message message, @Payload GenericPayloadDto<Long> payload) {
+        log.info(
+                "Received new message {} in {} (GenericPayloadDto<Long>): {}",
+                message,
+                AmqpConstants.QUEUE_DELETE,
+                payload.toString());
+    }
+
+    @RabbitListener(
+            autoStartup = "false",
+            bindings =
+                    @QueueBinding(
+                            exchange =
+                                    @Exchange(
+                                            name = AmqpConstants.EXCHANGE_CRUD_TOPIC_EXCHANGE_1,
+                                            type = ExchangeTypes.TOPIC),
+                            key = AmqpConstants.ROUTING_KEY_ALL_MESSAGES,
+                            value = @Queue(name = AmqpConstants.QUEUE_UPDATE, durable = "true", autoDelete = "false")))
+    public void bindingsUpdate(Message message, @Payload GenericPayloadDto<ExamplePayloadDto> payload) {
+        log.info(
+                "Received new message {} in {} (GenericPayloadDto<ExamplePayloadDto>): {}",
+                message,
+                AmqpConstants.QUEUE_UPDATE,
+                payload.toString());
+    }
+
+    @RabbitListener(
+            autoStartup = "false",
+            bindings =
+                    @QueueBinding(
+                            exchange =
+                                    @Exchange(
+                                            name = AmqpConstants.EXCHANGE_CRUD_TOPIC_EXCHANGE_2,
+                                            type = ExchangeTypes.TOPIC),
+                            key = AmqpConstants.ROUTING_KEY_ALL_MESSAGES,
+                            value = @Queue(name = AmqpConstants.QUEUE_READ, durable = "true", autoDelete = "false")))
+    public void bindingsRead(Message message, @Payload ExamplePayloadDto payload) {
+        log.info(
+                "Received new message {} in {} (ExamplePayloadDto): {}",
+                message,
+                AmqpConstants.QUEUE_UPDATE,
+                payload.toString());
     }
 }

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

@@ -0,0 +1,19 @@
+// SPDX-License-Identifier: Apache-2.0
+package io.github.springwolf.examples.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 = "Generic payload model")
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+public class GenericPayloadDto<T> {
+
+    @Schema(description = "Generic Payload field", requiredMode = REQUIRED)
+    private T genericValue;
+}

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

@@ -3,6 +3,7 @@
 
 import io.github.springwolf.core.asyncapi.annotations.AsyncOperation;
 import io.github.springwolf.core.asyncapi.annotations.AsyncPublisher;
+import io.github.springwolf.examples.amqp.AmqpConstants;
 import io.github.springwolf.examples.amqp.dtos.AnotherPayloadDto;
 import io.github.springwolf.plugins.amqp.asyncapi.annotations.AmqpAsyncOperationBinding;
 import lombok.RequiredArgsConstructor;
@@ -17,11 +18,14 @@ public class AnotherProducer {
     @AsyncPublisher(
             operation =
                     @AsyncOperation(
-                            channelName = "example-topic-exchange",
+                            channelName = AmqpConstants.EXCHANGE_EXAMPLE_TOPIC_EXCHANGE,
                             description = "Custom, optional description defined in the AsyncPublisher annotation"))
     @AmqpAsyncOperationBinding()
     public void sendMessage(AnotherPayloadDto msg) {
         // send
-        rabbitTemplate.convertAndSend("example-topic-exchange", "example-topic-routing-key", msg);
+        rabbitTemplate.convertAndSend(
+                AmqpConstants.EXCHANGE_EXAMPLE_TOPIC_EXCHANGE,
+                AmqpConstants.ROUTING_KEY_EXAMPLE_TOPIC_ROUTING_KEY,
+                msg);
     }
 }

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

@@ -25,13 +25,36 @@ class ApiIntegrationTest {
     private TestRestTemplate restTemplate;
 
     @Test
-    void asyncApiResourceArtifactTest() throws IOException {
+    void asyncApiResourceJsonArtifactTest() throws IOException {
         String url = "/springwolf/docs";
         String actual = restTemplate.getForObject(url, String.class);
         Files.writeString(Path.of("src", "test", "resources", "asyncapi.actual.json"), actual);
 
-        InputStream s = this.getClass().getResourceAsStream("/asyncapi.json");
-        String expected = new String(s.readAllBytes(), StandardCharsets.UTF_8).trim();
+        String expected;
+        try (InputStream s = this.getClass().getResourceAsStream("/asyncapi.json")) {
+            assert s != null;
+            expected = new String(s.readAllBytes(), StandardCharsets.UTF_8).trim();
+        }
+
+        assertEquals(expected, actual);
+    }
+
+    @Test
+    void asyncApiResourceYamlArtifactTest() throws IOException {
+        String url = "/springwolf/docs.yaml";
+        String actual = restTemplate
+                .getForObject(url, String.class)
+                .replaceAll("\r", "")
+                .trim();
+        Files.writeString(Path.of("src", "test", "resources", "asyncapi.actual.yaml"), actual);
+
+        String expected;
+        try (InputStream s = this.getClass().getResourceAsStream("/asyncapi.yaml")) {
+            assert s != null;
+            expected = new String(s.readAllBytes(), StandardCharsets.UTF_8)
+                    .replaceAll("\r", "")
+                    .trim();
+        }
 
         assertEquals(expected, actual);
     }

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

@@ -75,7 +75,7 @@ void producerCanUseSpringwolfConfigurationToSendMessage() {
         payload.setSomeEnum(FOO1);
 
         // when
-        springwolfAmqpProducer.send("example-queue", payload);
+        springwolfAmqpProducer.send(AmqpConstants.QUEUE_EXAMPLE_QUEUE, payload);
 
         // then
         verify(exampleConsumer, timeout(10000)).receiveExamplePayload(payload);