fix(int-aws-support): SnsOutboundChannelAdapterParser sync attribute

Author: boolivar

int-aws-support/src/main/java/org/springframework/integration/aws/support/config/xml/InvertedBooleanFactoryBean.java

@@ -0,0 +1,22 @@
+package org.springframework.integration.aws.support.config.xml;
+
+import org.springframework.beans.factory.FactoryBean;
+
+public class InvertedBooleanFactoryBean implements FactoryBean<Boolean> {
+    
+    private final boolean value;
+
+    public InvertedBooleanFactoryBean(boolean value) {
+        this.value = value;
+    }
+
+    @Override
+    public Class<?> getObjectType() {
+        return Boolean.class;
+    }
+
+    @Override
+    public Boolean getObject() {
+        return !value;
+    }
+}

int-aws-support/src/main/java/org/springframework/integration/aws/support/config/xml/parsers/SnsOutboundChannelAdapterParser.java

@@ -2,8 +2,10 @@
 
 import org.springframework.beans.factory.support.AbstractBeanDefinition;
 import org.springframework.beans.factory.xml.ParserContext;
+import org.springframework.integration.aws.config.xml.ValueFactory;
 import org.springframework.integration.aws.config.xml.XmlBeanDefinitionBuilder;
 import org.springframework.integration.aws.outbound.SnsMessageHandler;
+import org.springframework.integration.aws.support.config.xml.InvertedBooleanFactoryBean;
 import org.springframework.integration.config.xml.AbstractOutboundChannelAdapterParser;
 import org.w3c.dom.Element;
 
@@ -14,7 +16,7 @@ protected AbstractBeanDefinition parseConsumer(Element element, ParserContext pa
         return XmlBeanDefinitionBuilder.newInstance(element, parserContext, SnsMessageHandler.class)
             .unsupportedAttributeWarning("failure-channel", "resource-id-resolver", "error-message-strategy", "async-handler")
             .addConstructorArgReference("sns")
-            .setPropertyIfAttributeDefined("async")
+            .setPropertyIfAttributeDefined("sync", "async", ValueFactory.bean(InvertedBooleanFactoryBean.class))
             .setPropertyOrExpressionIfAttributeDefined("topic-arn")
             .setPropertyOrExpressionIfAttributeDefined("subject")
             .setPropertyOrExpressionIfAttributeDefined("message-group-id")

int-aws-support/src/test/java/org/springframework/integration/aws/support/config/xml/parsers/SnsOutboundChannelAdapterParserTest.java

@@ -0,0 +1,62 @@
+package org.springframework.integration.aws.support.config.xml.parsers;
+
+import org.bool.junit.mockito.inline.ConstructionMock;
+
+import org.assertj.core.api.InstanceOfAssertFactories;
+import org.junit.jupiter.api.Test;
+import org.mockito.Mock;
+import org.mockito.MockedConstruction.Context;
+import org.springframework.integration.aws.outbound.SnsMessageHandler;
+import software.amazon.awssdk.services.sns.SnsAsyncClient;
+
+import static org.assertj.core.api.Assertions.assertThat;
+
+@ConstructionMock(SnsMessageHandler.class)
+class SnsOutboundChannelAdapterParserTest extends ParserTestBase {
+
+    @Mock
+    private SnsAsyncClient sns;
+
+    @Test
+    void testHandler() {
+        registerBean("sns", sns);
+
+        parse("""
+            <int-aws:sns-outbound-channel-adapter
+                    id="snsoca"
+                    channel="c"
+                    sns="sns"
+                    topic-arn-expression="topic.exp"
+                    subject-expression="subj.exp"
+                    body-expression="body.exp"
+                    message-group-id-expression="mgi.exp"
+                    message-deduplication-id-expression="mdi.exp"
+                    order="#{5}"
+                    send-timeout="#{50}"
+                    success-channel="sc"
+                    sync="#{false}"
+                    failure-channel="unknownChannel"
+                    error-message-strategy="unknownStrategy"
+                    resource-id-resolver="unknownResolver"
+                    async-handler="unknownHandler"
+                    />
+            """);
+
+        var handler = beanFactory.getBean(SnsMessageHandler.class);
+
+        verify(handler).setTopicArnExpression(assertArg(e -> assertThat(e.getExpressionString()).isEqualTo("topic.exp")));
+        verify(handler).setSubjectExpression(assertArg(e -> assertThat(e.getExpressionString()).isEqualTo("subj.exp")));
+        verify(handler).setBodyExpression(assertArg(e -> assertThat(e.getExpressionString()).isEqualTo("body.exp")));
+        verify(handler).setMessageGroupIdExpression(assertArg(e -> assertThat(e.getExpressionString()).isEqualTo("mgi.exp")));
+        verify(handler).setMessageDeduplicationIdExpression(assertArg(e -> assertThat(e.getExpressionString()).isEqualTo("mdi.exp")));
+        verify(handler).setOrder(5);
+        verify(handler).setOutputChannelName("sc");
+        verify(handler).setSendTimeout(50L);
+        verify(handler).setAsync(true);
+    }
+
+    void testHandler(SnsMessageHandler mock, Context context) {
+        assertThat(context.arguments()).asInstanceOf(InstanceOfAssertFactories.LIST)
+            .contains(sns);
+    }
+}