You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2020/04/24 09:02:15 UTC
[camel] 03/03: 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
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 <an...@gmail.com>
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"/>