From 0041a3728cda0ed2aca98c84b5b343847aeccb97 Mon Sep 17 00:00:00 2001 From: Carlos Tasada Date: Mon, 6 Nov 2023 17:36:14 +0100 Subject: [PATCH] fix: Minor fix with SQS Message Binding The `SqsMessageBindingProcessor` was wrongly using the `AMQPMessageBinding` instead of `SQSMessageBinding`. --- .../bindings/processor/SqsMessageBindingProcessor.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/springwolf-plugins/springwolf-sqs-plugin/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/bindings/processor/SqsMessageBindingProcessor.java b/springwolf-plugins/springwolf-sqs-plugin/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/bindings/processor/SqsMessageBindingProcessor.java index fd8acfae1..a2462422a 100644 --- a/springwolf-plugins/springwolf-sqs-plugin/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/bindings/processor/SqsMessageBindingProcessor.java +++ b/springwolf-plugins/springwolf-sqs-plugin/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/bindings/processor/SqsMessageBindingProcessor.java @@ -1,7 +1,7 @@ // SPDX-License-Identifier: Apache-2.0 package io.github.stavshamir.springwolf.asyncapi.scanners.bindings.processor; -import com.asyncapi.v2.binding.message.amqp.AMQPMessageBinding; +import com.asyncapi.v2.binding.message.sqs.SQSMessageBinding; import io.github.stavshamir.springwolf.asyncapi.scanners.bindings.MessageBindingProcessor; import io.github.stavshamir.springwolf.asyncapi.scanners.bindings.ProcessedMessageBinding; import io.github.stavshamir.springwolf.asyncapi.scanners.channels.operationdata.annotation.SqsAsyncOperationBinding; @@ -23,15 +23,15 @@ public void setEmbeddedValueResolver(StringValueResolver resolver) { @Override public Optional process(Method method) { return Arrays.stream(method.getAnnotations()) - .filter(annotation -> annotation instanceof SqsAsyncOperationBinding) - .map(annotation -> (SqsAsyncOperationBinding) annotation) + .filter(SqsAsyncOperationBinding.class::isInstance) + .map(SqsAsyncOperationBinding.class::cast) .findAny() .map(this::mapToMessageBinding); } private ProcessedMessageBinding mapToMessageBinding(SqsAsyncOperationBinding bindingAnnotation) { - AMQPMessageBinding amqpMessageBinding = AMQPMessageBinding.builder().build(); + SQSMessageBinding sqsMessageBinding = new SQSMessageBinding(); - return new ProcessedMessageBinding(bindingAnnotation.type(), amqpMessageBinding); + return new ProcessedMessageBinding(bindingAnnotation.type(), sqsMessageBinding); } }