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 49dafb20225e40440048defbd31c2c4f73e0a406 Author: Andrea Cosentino <anco...@gmail.com> AuthorDate: Wed Mar 31 08:55:13 2021 +0200 Fixed CS --- .../component/aws2/lambda/Lambda2Producer.java | 46 +++++++++++----------- 1 file changed, 23 insertions(+), 23 deletions(-) diff --git a/components/camel-aws/camel-aws2-lambda/src/main/java/org/apache/camel/component/aws2/lambda/Lambda2Producer.java b/components/camel-aws/camel-aws2-lambda/src/main/java/org/apache/camel/component/aws2/lambda/Lambda2Producer.java index afc6bf9..8d4e574 100644 --- a/components/camel-aws/camel-aws2-lambda/src/main/java/org/apache/camel/component/aws2/lambda/Lambda2Producer.java +++ b/components/camel-aws/camel-aws2-lambda/src/main/java/org/apache/camel/component/aws2/lambda/Lambda2Producer.java @@ -504,34 +504,34 @@ public class Lambda2Producer extends DefaultProducer { @SuppressWarnings("unchecked") private void tagResource(LambdaClient lambdaClient, Exchange exchange) throws InvalidPayloadException { - TagResourceRequest request = null; - TagResourceResponse result; + TagResourceRequest request = null; + TagResourceResponse result; if (getConfiguration().isPojoRequest()) { request = exchange.getIn().getMandatoryBody(TagResourceRequest.class); } else { - TagResourceRequest.Builder builder = TagResourceRequest.builder(); - if (ObjectHelper.isNotEmpty(exchange.getIn().getHeader(Lambda2Constants.RESOURCE_ARN))) { - String resource = exchange.getIn().getHeader(Lambda2Constants.RESOURCE_ARN, String.class); - builder.resource(resource); - } else { - throw new IllegalArgumentException("The resource ARN must be specified"); - } - if (ObjectHelper.isNotEmpty(exchange.getIn().getHeader(Lambda2Constants.RESOURCE_TAGS))) { - Map<String, String> tags = exchange.getIn().getHeader(Lambda2Constants.RESOURCE_TAGS, Map.class); - builder.tags(tags); - } else { - throw new IllegalArgumentException("The tags must be specified"); - } - request = builder.build(); + TagResourceRequest.Builder builder = TagResourceRequest.builder(); + if (ObjectHelper.isNotEmpty(exchange.getIn().getHeader(Lambda2Constants.RESOURCE_ARN))) { + String resource = exchange.getIn().getHeader(Lambda2Constants.RESOURCE_ARN, String.class); + builder.resource(resource); + } else { + throw new IllegalArgumentException("The resource ARN must be specified"); + } + if (ObjectHelper.isNotEmpty(exchange.getIn().getHeader(Lambda2Constants.RESOURCE_TAGS))) { + Map<String, String> tags = exchange.getIn().getHeader(Lambda2Constants.RESOURCE_TAGS, Map.class); + builder.tags(tags); + } else { + throw new IllegalArgumentException("The tags must be specified"); + } + request = builder.build(); } try { - result = lambdaClient.tagResource(request); - } catch (AwsServiceException ase) { - LOG.trace("listTags command returned the error code {}", ase.awsErrorDetails().errorCode()); - throw ase; - } - Message message = getMessageForResponse(exchange); - message.setBody(result); + result = lambdaClient.tagResource(request); + } catch (AwsServiceException ase) { + LOG.trace("listTags command returned the error code {}", ase.awsErrorDetails().errorCode()); + throw ase; + } + Message message = getMessageForResponse(exchange); + message.setBody(result); } @SuppressWarnings("unchecked")