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 15fba6534407f232a7663fd5daa7d42dd4b61f70 Author: Andrea Cosentino <[email protected]> AuthorDate: Fri Apr 10 14:51:04 2020 +0200 CAMEL-14868 - Camel-AWS2-*: Where possible, give the possiblity to the end user to pass an AWS Request pojo as body, aws2-eks added test --- .../camel/component/aws2/eks/EKS2ProducerTest.java | 23 +++++++++++++++++++++- 1 file changed, 22 insertions(+), 1 deletion(-) diff --git a/components/camel-aws2-eks/src/test/java/org/apache/camel/component/aws2/eks/EKS2ProducerTest.java b/components/camel-aws2-eks/src/test/java/org/apache/camel/component/aws2/eks/EKS2ProducerTest.java index 73a55a6..eb1b6a0 100644 --- a/components/camel-aws2-eks/src/test/java/org/apache/camel/component/aws2/eks/EKS2ProducerTest.java +++ b/components/camel-aws2-eks/src/test/java/org/apache/camel/component/aws2/eks/EKS2ProducerTest.java @@ -27,6 +27,7 @@ import org.junit.jupiter.api.Test; import software.amazon.awssdk.services.eks.model.CreateClusterResponse; import software.amazon.awssdk.services.eks.model.DeleteClusterResponse; import software.amazon.awssdk.services.eks.model.DescribeClusterResponse; +import software.amazon.awssdk.services.eks.model.ListClustersRequest; import software.amazon.awssdk.services.eks.model.ListClustersResponse; import software.amazon.awssdk.services.eks.model.VpcConfigRequest; @@ -41,7 +42,7 @@ public class EKS2ProducerTest extends CamelTestSupport { private MockEndpoint mock; @Test - public void kmsListClustersTest() throws Exception { + public void eksListClustersTest() throws Exception { mock.expectedMessageCount(1); Exchange exchange = template.request("direct:listClusters", new Processor() { @@ -57,6 +58,25 @@ public class EKS2ProducerTest extends CamelTestSupport { assertEquals(1, resultGet.clusters().size()); assertEquals("Test", resultGet.clusters().get(0)); } + + @Test + public void eksListClustersPojoTest() throws Exception { + + mock.expectedMessageCount(1); + Exchange exchange = template.request("direct:listPojoClusters", new Processor() { + @Override + public void process(Exchange exchange) throws Exception { + exchange.getIn().setHeader(EKS2Constants.OPERATION, EKS2Operations.listClusters); + exchange.getIn().setBody(ListClustersRequest.builder().maxResults(12).build()); + } + }); + + assertMockEndpointsSatisfied(); + + ListClustersResponse resultGet = (ListClustersResponse)exchange.getIn().getBody(); + assertEquals(1, resultGet.clusters().size()); + assertEquals("Test", resultGet.clusters().get(0)); + } @Test public void eksCreateClusterTest() throws Exception { @@ -121,6 +141,7 @@ public class EKS2ProducerTest extends CamelTestSupport { @Override public void configure() throws Exception { from("direct:listClusters").to("aws2-eks://test?eksClient=#amazonEksClient&operation=listClusters").to("mock:result"); + from("direct:listPojoClusters").to("aws2-eks://test?eksClient=#amazonEksClient&operation=listClusters").to("mock:result"); from("direct:createCluster").to("aws2-eks://test?eksClient=#amazonEksClient&operation=createCluster").to("mock:result"); from("direct:deleteCluster").to("aws2-eks://test?eksClient=#amazonEksClient&operation=deleteCluster").to("mock:result"); from("direct:describeCluster").to("aws2-eks://test?eksClient=#amazonEksClient&operation=describeCluster").to("mock:result");
