Repository: camel Updated Branches: refs/heads/master 5f44bb979 -> 11ccb8231
CAMEL-8834 Camel-AWS EC2: Add describeInstances Operation Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/11ccb823 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/11ccb823 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/11ccb823 Branch: refs/heads/master Commit: 11ccb8231c703b97cb9ad2c0cc565496964c9061 Parents: 5f44bb9 Author: Andrea Cosentino <anco...@gmail.com> Authored: Sat Jun 6 23:13:21 2015 +0200 Committer: Andrea Cosentino <anco...@gmail.com> Committed: Sat Jun 6 23:13:21 2015 +0200 ---------------------------------------------------------------------- .../aws/ec2/EC2ComponentSpringTest.java | 19 +++++++++++++++++++ .../aws/ec2/EC2ComponentSpringTest-context.xml | 4 ++++ 2 files changed, 23 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/11ccb823/components/camel-aws/src/test/java/org/apache/camel/component/aws/ec2/EC2ComponentSpringTest.java ---------------------------------------------------------------------- diff --git a/components/camel-aws/src/test/java/org/apache/camel/component/aws/ec2/EC2ComponentSpringTest.java b/components/camel-aws/src/test/java/org/apache/camel/component/aws/ec2/EC2ComponentSpringTest.java index 82b3484..2754c58 100644 --- a/components/camel-aws/src/test/java/org/apache/camel/component/aws/ec2/EC2ComponentSpringTest.java +++ b/components/camel-aws/src/test/java/org/apache/camel/component/aws/ec2/EC2ComponentSpringTest.java @@ -21,6 +21,7 @@ import java.util.Arrays; import java.util.Collection; import java.util.List; +import com.amazonaws.services.ec2.model.DescribeInstancesResult; import com.amazonaws.services.ec2.model.InstanceStateName; import com.amazonaws.services.ec2.model.InstanceType; import com.amazonaws.services.ec2.model.RunInstancesResult; @@ -128,6 +129,24 @@ public class EC2ComponentSpringTest extends CamelSpringTestSupport { assertEquals(resultGet.getTerminatingInstances().get(0).getCurrentState().getName(), InstanceStateName.Terminated.toString()); } + @Test + public void ec2DescribeSpecificInstancesTest() throws Exception { + + Exchange exchange = template.request("direct:describe", new Processor() { + + @Override + public void process(Exchange exchange) throws Exception { + Collection l = new ArrayList(); + l.add("instance-1"); + exchange.getIn().setHeader(EC2Constants.INSTANCES_IDS, l); + } + }); + + DescribeInstancesResult resultGet = (DescribeInstancesResult) exchange.getIn().getBody(); + assertEquals(resultGet.getReservations().size(), 1); + assertEquals(resultGet.getReservations().get(0).getInstances().size(), 1); + } + @Override protected AbstractApplicationContext createApplicationContext() { return new ClassPathXmlApplicationContext( http://git-wip-us.apache.org/repos/asf/camel/blob/11ccb823/components/camel-aws/src/test/resources/org/apache/camel/component/aws/ec2/EC2ComponentSpringTest-context.xml ---------------------------------------------------------------------- diff --git a/components/camel-aws/src/test/resources/org/apache/camel/component/aws/ec2/EC2ComponentSpringTest-context.xml b/components/camel-aws/src/test/resources/org/apache/camel/component/aws/ec2/EC2ComponentSpringTest-context.xml index af0042d..5791f88 100644 --- a/components/camel-aws/src/test/resources/org/apache/camel/component/aws/ec2/EC2ComponentSpringTest-context.xml +++ b/components/camel-aws/src/test/resources/org/apache/camel/component/aws/ec2/EC2ComponentSpringTest-context.xml @@ -37,6 +37,10 @@ <from uri="direct:terminate"/> <to uri="aws-ec2://Test?amazonEc2Client=#amazonEc2Client&operation=terminateInstances"/> </route> + <route> + <from uri="direct:describe"/> + <to uri="aws-ec2://Test?amazonEc2Client=#amazonEc2Client&operation=describeInstances"/> + </route> </camelContext> <bean id="amazonEc2Client" class="org.apache.camel.component.aws.ec2.AmazonEC2ClientMock"/>
