chore(amqp): Align example producer (#429)

Author: timonback

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

@@ -3,7 +3,7 @@
 
 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 io.github.stavshamir.springwolf.example.amqp.producers.AnotherProducer;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.amqp.core.ExchangeTypes;
@@ -18,12 +18,17 @@
 @RequiredArgsConstructor
 public class ExampleConsumer {
 
-    private final ExampleProducer exampleProducer;
+    private final AnotherProducer anotherProducer;
 
     @RabbitListener(queues = "example-queue")
     public void receiveExamplePayload(ExamplePayloadDto payload) {
         log.info("Received new message in example-queue: {}", payload.toString());
-        exampleProducer.sendMessage(payload);
+
+        AnotherPayloadDto example = new AnotherPayloadDto();
+        example.setExample(payload);
+        example.setFoo("foo");
+
+        anotherProducer.sendMessage(example);
     }
 
     @RabbitListener(queues = "another-queue")

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

@@ -5,14 +5,13 @@
 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 {
+public class AnotherProducer {
     private final RabbitTemplate rabbitTemplate;
 
     @AsyncPublisher(
@@ -21,9 +20,8 @@ public class ExampleProducer {
                             channelName = "example-producer-channel-publisher",
                             description = "Custom, optional description defined in the AsyncPublisher annotation"))
     @AmqpAsyncOperationBinding()
-    public void sendMessage(ExamplePayloadDto msg) {
+    public void sendMessage(AnotherPayloadDto msg) {
         // send
-        AnotherPayloadDto dto = new AnotherPayloadDto("fooValue", msg);
-        rabbitTemplate.convertAndSend("example-topic-exchange", "example-topic-routing-key", dto);
+        rabbitTemplate.convertAndSend("example-topic-exchange", "example-topic-routing-key", msg);
     }
 }

springwolf-examples/springwolf-amqp-example/src/test/resources/asyncapi.json

@@ -174,11 +174,11 @@
         },
         "message": {
           "schemaFormat": "application/vnd.oai.openapi+json;version=3.0.0",
-          "name": "io.github.stavshamir.springwolf.example.amqp.dtos.ExamplePayloadDto",
-          "title": "ExamplePayloadDto",
-          "description": "Example payload model",
+          "name": "io.github.stavshamir.springwolf.example.amqp.dtos.AnotherPayloadDto",
+          "title": "AnotherPayloadDto",
+          "description": "Another payload model",
           "payload": {
-            "$ref": "#/components/schemas/io.github.stavshamir.springwolf.example.amqp.dtos.ExamplePayloadDto"
+            "$ref": "#/components/schemas/io.github.stavshamir.springwolf.example.amqp.dtos.AnotherPayloadDto"
           },
           "headers": {
             "$ref": "#/components/schemas/HeadersNotDocumented"

springwolf-examples/springwolf-amqp-example/src/test/resources/asyncapi_withdocketfromenvironment.json

@@ -92,11 +92,11 @@
         },
         "message": {
           "schemaFormat": "application/vnd.oai.openapi+json;version=3.0.0",
-          "name": "io.github.stavshamir.springwolf.example.amqp.dtos.ExamplePayloadDto",
-          "title": "ExamplePayloadDto",
-          "description": "Example payload model",
+          "name": "io.github.stavshamir.springwolf.example.amqp.dtos.AnotherPayloadDto",
+          "title": "AnotherPayloadDto",
+          "description": "Another payload model",
           "payload": {
-            "$ref": "#/components/schemas/io.github.stavshamir.springwolf.example.amqp.dtos.ExamplePayloadDto"
+            "$ref": "#/components/schemas/io.github.stavshamir.springwolf.example.amqp.dtos.AnotherPayloadDto"
           },
           "headers": {
             "$ref": "#/components/schemas/HeadersNotDocumented"