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 11c5ab1e964383103d364e64f0c381648ddd361e Author: Andrea Cosentino <[email protected]> AuthorDate: Thu Apr 9 16:03:56 2020 +0200 CAMEL-14868 - Camel-AWS2-*: Where possible, give the possiblity to the end user to pass an AWS Request pojo as body, aws2-ecs fixed CS --- .../camel/component/aws2/ecs/ECS2Producer.java | 28 +++++++++++----------- 1 file changed, 14 insertions(+), 14 deletions(-) diff --git a/components/camel-aws2-ecs/src/main/java/org/apache/camel/component/aws2/ecs/ECS2Producer.java b/components/camel-aws2-ecs/src/main/java/org/apache/camel/component/aws2/ecs/ECS2Producer.java index 751143a..ad0fdbf 100644 --- a/components/camel-aws2-ecs/src/main/java/org/apache/camel/component/aws2/ecs/ECS2Producer.java +++ b/components/camel-aws2-ecs/src/main/java/org/apache/camel/component/aws2/ecs/ECS2Producer.java @@ -99,18 +99,18 @@ public class ECS2Producer extends DefaultProducer { private void listClusters(EcsClient ecsClient, Exchange exchange) throws InvalidPayloadException { if (getConfiguration().isPojoRequest()) { Object payload = exchange.getIn().getMandatoryBody(); - if (payload instanceof ListClustersRequest) { - ListClustersResponse result; - try { - ListClustersRequest request = (ListClustersRequest)payload; - result = ecsClient.listClusters(request); - } catch (AwsServiceException ase) { - LOG.trace("List Clusters command returned the error code {}", ase.awsErrorDetails().errorCode()); - throw ase; - } - Message message = getMessageForResponse(exchange); - message.setBody(result); + if (payload instanceof ListClustersRequest) { + ListClustersResponse result; + try { + ListClustersRequest request = (ListClustersRequest)payload; + result = ecsClient.listClusters(request); + } catch (AwsServiceException ase) { + LOG.trace("List Clusters command returned the error code {}", ase.awsErrorDetails().errorCode()); + throw ase; } + Message message = getMessageForResponse(exchange); + message.setBody(result); + } } else { Builder builder = ListClustersRequest.builder(); if (ObjectHelper.isNotEmpty(exchange.getIn().getHeader(ECS2Constants.MAX_RESULTS))) { @@ -144,7 +144,7 @@ public class ECS2Producer extends DefaultProducer { } Message message = getMessageForResponse(exchange); message.setBody(result); - } + } } else { CreateClusterRequest.Builder builder = CreateClusterRequest.builder(); if (ObjectHelper.isNotEmpty(exchange.getIn().getHeader(ECS2Constants.CLUSTER_NAME))) { @@ -178,7 +178,7 @@ public class ECS2Producer extends DefaultProducer { } Message message = getMessageForResponse(exchange); message.setBody(result); - } + } } else { DescribeClustersRequest.Builder builder = DescribeClustersRequest.builder(); if (ObjectHelper.isNotEmpty(exchange.getIn().getHeader(ECS2Constants.CLUSTER_NAME))) { @@ -212,7 +212,7 @@ public class ECS2Producer extends DefaultProducer { } Message message = getMessageForResponse(exchange); message.setBody(result); - } + } } else { DeleteClusterRequest.Builder builder = DeleteClusterRequest.builder(); if (ObjectHelper.isNotEmpty(exchange.getIn().getHeader(ECS2Constants.CLUSTER_NAME))) {
