Extend springwolf-amqp-plugin to implement the new methods in abstract class and method level listener scanners to include an empty message binding so that there is always a message binding

Author: sam0r040

springwolf-plugins/springwolf-amqp-plugin/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/annotation/MethodLevelRabbitListenerScanner.java

@@ -1,8 +1,10 @@
 package io.github.stavshamir.springwolf.asyncapi.scanners.channels.annotation;
 
 import com.asyncapi.v2.binding.ChannelBinding;
+import com.asyncapi.v2.binding.MessageBinding;
 import com.asyncapi.v2.binding.OperationBinding;
 import com.asyncapi.v2.binding.amqp.AMQPChannelBinding;
+import com.asyncapi.v2.binding.amqp.AMQPMessageBinding;
 import com.asyncapi.v2.binding.amqp.AMQPOperationBinding;
 import com.google.common.collect.ImmutableMap;
 import io.github.stavshamir.springwolf.asyncapi.scanners.channels.ChannelPriority;
@@ -107,6 +109,12 @@ private String getExchangeName(RabbitListener annotation) {
         return ImmutableMap.of("amqp", AMQPOperationBinding.builder().cc(getRoutingKeys(annotation)).build());
     }
 
+    @Override
+    protected Map<String, ? extends MessageBinding> buildMessageBinding(RabbitListener annotation) {
+        // currently the feature to define amqp message binding is not implemented.
+        return ImmutableMap.of("amqp", new AMQPMessageBinding());
+    }
+
     private List<String> getRoutingKeys(RabbitListener annotation) {
         /*
             The routing key is taken from the binding. As the key field in the @QueueBinding can be an empty array,

springwolf-plugins/springwolf-amqp-plugin/src/test/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/annotation/MethodLevelRabbitListenerScannerTest.java

@@ -2,6 +2,7 @@
 
 import com.asyncapi.v2.binding.ChannelBinding;
 import com.asyncapi.v2.binding.amqp.AMQPChannelBinding;
+import com.asyncapi.v2.binding.amqp.AMQPMessageBinding;
 import com.asyncapi.v2.binding.amqp.AMQPOperationBinding;
 import com.asyncapi.v2.model.channel.ChannelItem;
 import com.asyncapi.v2.model.channel.operation.Operation;
@@ -99,6 +100,7 @@ public void scan_componentHasRabbitListenerMethods_hardCodedTopic() {
                 .title(SimpleFoo.class.getSimpleName())
                 .payload(PayloadReference.fromModelName(SimpleFoo.class.getSimpleName()))
                 .headers(HeaderReference.fromModelName(AsyncHeaders.NOT_DOCUMENTED.getSchemaName()))
+                .bindings(ImmutableMap.of("amqp", new AMQPMessageBinding()))
                 .build();
 
         Operation operation = Operation.builder()
@@ -140,6 +142,7 @@ public void scan_componentHasRabbitListenerMethods_embeddedValueTopic() {
                 .title(SimpleFoo.class.getSimpleName())
                 .payload(PayloadReference.fromModelName(SimpleFoo.class.getSimpleName()))
                 .headers(HeaderReference.fromModelName(AsyncHeaders.NOT_DOCUMENTED.getSchemaName()))
+                .bindings(ImmutableMap.of("amqp", new AMQPMessageBinding()))
                 .build();
 
         Operation operation = Operation.builder()
@@ -178,6 +181,7 @@ public void scan_componentHasRabbitListenerMethods_bindingsAnnotation() {
                 .title(SimpleFoo.class.getSimpleName())
                 .payload(PayloadReference.fromModelName(SimpleFoo.class.getSimpleName()))
                 .headers(HeaderReference.fromModelName(AsyncHeaders.NOT_DOCUMENTED.getSchemaName()))
+                .bindings(ImmutableMap.of("amqp", new AMQPMessageBinding()))
                 .build();
 
         Operation operation = Operation.builder()
@@ -216,6 +220,7 @@ public void scan_componentHasRabbitListenerMethods_bindingBean() {
                 .title(SimpleFoo.class.getSimpleName())
                 .payload(PayloadReference.fromModelName(SimpleFoo.class.getSimpleName()))
                 .headers(HeaderReference.fromModelName(AsyncHeaders.NOT_DOCUMENTED.getSchemaName()))
+                .bindings(ImmutableMap.of("amqp", new AMQPMessageBinding()))
                 .build();
 
         Operation operation = Operation.builder()
@@ -271,6 +276,7 @@ public void scan_componentHasRabbitListenerMethods_multipleParamsWithPayloadAnno
                 .title(SimpleFoo.class.getSimpleName())
                 .payload(PayloadReference.fromModelName(SimpleFoo.class.getSimpleName()))
                 .headers(HeaderReference.fromModelName(AsyncHeaders.NOT_DOCUMENTED.getSchemaName()))
+                .bindings(ImmutableMap.of("amqp", new AMQPMessageBinding()))
                 .build();
 
         Operation operation = Operation.builder()