test: SnsOutboundChannelAdapterParserTest

Author: boolivar

int-aws/src/main/resources/org/springframework/schema/integration/aws/spring-integration-aws.xsd

@@ -858,11 +858,11 @@
                     <attribute name="sns" type="string" use="required">
                         <annotation>
                             <documentation><![CDATA[
-                                The 'software.amazon.awssdk.services.sns.SnsClient' bean reference.
+                                The 'software.amazon.awssdk.services.sns.SnsAsyncClient' bean reference.
                             ]]></documentation>
                             <appinfo>
                                 <tool:annotation kind="ref">
-                                    <tool:expected-type type="software.amazon.awssdk.services.sns.SnsClient"/>
+                                    <tool:expected-type type="software.amazon.awssdk.services.sns.SnsAsyncClient"/>
                                 </tool:annotation>
                             </appinfo>
                         </annotation>

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

@@ -0,0 +1,54 @@
+package org.springframework.integration.aws.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;
+
+class SnsOutboundChannelAdapterParserTest extends ParserTestBase {
+
+    @Mock
+    private SnsAsyncClient sns;
+
+    @ConstructionMock(SnsMessageHandler.class)
+    @Test
+    void testHandler() {
+        registerBean("sns", SnsAsyncClient.class, sns);
+
+        var handler = loadBean(SnsMessageHandler.class, """
+            <int-aws:sns-outbound-channel-adapter
+                    id="snsoca"
+                    channel="c"
+                    sns="sns"
+                    topic-arn="arn"
+                    subject="subj"
+                    message-group-id="groupid"
+                    body-expression="body.exp"
+                    message-deduplication-id-expression="mdi.exp"
+                    order="#{5}"
+                    async="#{true}"
+                    output-channel="out"
+                    send-timeout="#{50}"/>
+            """);
+
+        verify(handler).setTopicArn("arn");
+        verify(handler).setSubject("subj");
+        verify(handler).setMessageGroupId("groupid");
+        verify(handler).setMessageDeduplicationIdExpression(argThat(e -> "mdi.exp".equals(e.getExpressionString())));
+        verify(handler).setOrder(5);
+        verify(handler).setOutputChannelName("out");
+        verify(handler).setSendTimeout(50L);
+        verify(handler).setAsync(true);
+    }
+
+    void testHandler(SnsMessageHandler mock, Context context) {
+        assertThat(context.arguments()).asInstanceOf(InstanceOfAssertFactories.LIST)
+            .contains(sns);
+    }
+}