This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git
commit 8580e0ae148d0682bb79eb1352c106700ebf7637 Author: Andrea Cosentino <[email protected]> AuthorDate: Fri Apr 24 11:01:41 2020 +0200 CAMEL-14868 - Camel-AWS2-*: Where possible, give the possiblity to the end user to pass an AWS Request pojo as body, aws2-mq added spring test --- .../component/aws2/mq/MQProducerSpringTest.java | 21 +++++++++++++++++++++ .../aws2/mq/MQComponentSpringTest-context.xml | 5 +++++ 2 files changed, 26 insertions(+) diff --git a/components/camel-aws2-mq/src/test/java/org/apache/camel/component/aws2/mq/MQProducerSpringTest.java b/components/camel-aws2-mq/src/test/java/org/apache/camel/component/aws2/mq/MQProducerSpringTest.java index 35768e4..47ce6b7 100644 --- a/components/camel-aws2-mq/src/test/java/org/apache/camel/component/aws2/mq/MQProducerSpringTest.java +++ b/components/camel-aws2-mq/src/test/java/org/apache/camel/component/aws2/mq/MQProducerSpringTest.java @@ -33,6 +33,7 @@ import software.amazon.awssdk.services.mq.model.DeleteBrokerResponse; import software.amazon.awssdk.services.mq.model.DeploymentMode; import software.amazon.awssdk.services.mq.model.DescribeBrokerResponse; import software.amazon.awssdk.services.mq.model.EngineType; +import software.amazon.awssdk.services.mq.model.ListBrokersRequest; import software.amazon.awssdk.services.mq.model.ListBrokersResponse; import software.amazon.awssdk.services.mq.model.UpdateBrokerResponse; import software.amazon.awssdk.services.mq.model.User; @@ -62,6 +63,26 @@ public class MQProducerSpringTest extends CamelSpringTestSupport { assertEquals("mybroker", resultGet.brokerSummaries().get(0).brokerName()); assertEquals(BrokerState.RUNNING.toString(), resultGet.brokerSummaries().get(0).brokerState().toString()); } + + @Test + public void mqListBrokersPojoTest() throws Exception { + + mock.expectedMessageCount(1); + Exchange exchange = template.request("direct:listBrokersPojo", new Processor() { + @Override + public void process(Exchange exchange) throws Exception { + exchange.getIn().setHeader(MQ2Constants.OPERATION, MQ2Operations.listBrokers); + exchange.getIn().setBody(ListBrokersRequest.builder().maxResults(10).build()); + } + }); + + assertMockEndpointsSatisfied(); + + ListBrokersResponse resultGet = (ListBrokersResponse)exchange.getIn().getBody(); + assertEquals(1, resultGet.brokerSummaries().size()); + assertEquals("mybroker", resultGet.brokerSummaries().get(0).brokerName()); + assertEquals(BrokerState.RUNNING.toString(), resultGet.brokerSummaries().get(0).brokerState().toString()); + } @Test public void mqCreateBrokerTest() throws Exception { diff --git a/components/camel-aws2-mq/src/test/resources/org/apache/camel/component/aws2/mq/MQComponentSpringTest-context.xml b/components/camel-aws2-mq/src/test/resources/org/apache/camel/component/aws2/mq/MQComponentSpringTest-context.xml index ba9981d..c74d6f5 100644 --- a/components/camel-aws2-mq/src/test/resources/org/apache/camel/component/aws2/mq/MQComponentSpringTest-context.xml +++ b/components/camel-aws2-mq/src/test/resources/org/apache/camel/component/aws2/mq/MQComponentSpringTest-context.xml @@ -30,6 +30,11 @@ <to uri="mock:result"/> </route> <route> + <from uri="direct:listBrokersPojo"/> + <to uri="aws2-mq://Test?amazonMqClient=#amazonMqClient&operation=listBrokers&pojoRequest=true"/> + <to uri="mock:result"/> + </route> + <route> <from uri="direct:createBroker"/> <to uri="aws2-mq://Test?amazonMqClient=#amazonMqClient&operation=createBroker"/> <to uri="mock:result"/>
