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 2021/03/30 11:32:32 UTC
[camel] 02/04: Fixed CS
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 99a8ed1113d4fdacf81329c9ad4d5e01374ae41f
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue Mar 30 13:25:51 2021 +0200
Fixed CS
---
.../component/aws2/lambda/Lambda2Producer.java | 216 ++++++++++-----------
1 file changed, 108 insertions(+), 108 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 63f282e..23cbbbb 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
@@ -234,139 +234,139 @@ public class Lambda2Producer extends DefaultProducer {
@SuppressWarnings("unchecked")
private void createFunction(LambdaClient lambdaClient, Exchange exchange) throws Exception {
- CreateFunctionRequest request = null;
- CreateFunctionResponse result;
+ CreateFunctionRequest request = null;
+ CreateFunctionResponse result;
if (getConfiguration().isPojoRequest()) {
request = exchange.getIn().getMandatoryBody(CreateFunctionRequest.class);
} else {
- CreateFunctionRequest.Builder builder = CreateFunctionRequest.builder();
- builder.functionName(getEndpoint().getFunction());
+ CreateFunctionRequest.Builder builder = CreateFunctionRequest.builder();
+ builder.functionName(getEndpoint().getFunction());
- FunctionCode.Builder functionCode = FunctionCode.builder();
- if (ObjectHelper.isNotEmpty(exchange.getIn().getHeader(Lambda2Constants.S3_BUCKET))) {
- String s3Bucket = exchange.getIn().getHeader(Lambda2Constants.S3_BUCKET, String.class);
- functionCode.s3Bucket(s3Bucket);
- }
+ FunctionCode.Builder functionCode = FunctionCode.builder();
+ if (ObjectHelper.isNotEmpty(exchange.getIn().getHeader(Lambda2Constants.S3_BUCKET))) {
+ String s3Bucket = exchange.getIn().getHeader(Lambda2Constants.S3_BUCKET, String.class);
+ functionCode.s3Bucket(s3Bucket);
+ }
- if (ObjectHelper.isNotEmpty(exchange.getIn().getHeader(Lambda2Constants.S3_KEY))) {
- String s3Key = exchange.getIn().getHeader(Lambda2Constants.S3_KEY, String.class);
- functionCode.s3Key(s3Key);
- }
+ if (ObjectHelper.isNotEmpty(exchange.getIn().getHeader(Lambda2Constants.S3_KEY))) {
+ String s3Key = exchange.getIn().getHeader(Lambda2Constants.S3_KEY, String.class);
+ functionCode.s3Key(s3Key);
+ }
- if (ObjectHelper.isNotEmpty(exchange.getIn().getHeader(Lambda2Constants.S3_OBJECT_VERSION))) {
- String s3ObjectVersion = exchange.getIn().getHeader(Lambda2Constants.S3_OBJECT_VERSION, String.class);
- functionCode.s3ObjectVersion(s3ObjectVersion);
- }
+ if (ObjectHelper.isNotEmpty(exchange.getIn().getHeader(Lambda2Constants.S3_OBJECT_VERSION))) {
+ String s3ObjectVersion = exchange.getIn().getHeader(Lambda2Constants.S3_OBJECT_VERSION, String.class);
+ functionCode.s3ObjectVersion(s3ObjectVersion);
+ }
- if (ObjectHelper.isNotEmpty(exchange.getIn().getHeader(Lambda2Constants.ZIP_FILE))) {
- String zipFile = exchange.getIn().getHeader(Lambda2Constants.ZIP_FILE, String.class);
- File fileLocalPath = new File(zipFile);
- try (FileInputStream inputStream = new FileInputStream(fileLocalPath)) {
- functionCode.zipFile(SdkBytes.fromInputStream(inputStream));
- }
- }
- if (ObjectHelper.isNotEmpty(exchange.getIn().getBody())) {
- functionCode.zipFile(SdkBytes.fromByteBuffer(exchange.getIn().getBody(ByteBuffer.class)));
+ if (ObjectHelper.isNotEmpty(exchange.getIn().getHeader(Lambda2Constants.ZIP_FILE))) {
+ String zipFile = exchange.getIn().getHeader(Lambda2Constants.ZIP_FILE, String.class);
+ File fileLocalPath = new File(zipFile);
+ try (FileInputStream inputStream = new FileInputStream(fileLocalPath)) {
+ functionCode.zipFile(SdkBytes.fromInputStream(inputStream));
}
+ }
+ if (ObjectHelper.isNotEmpty(exchange.getIn().getBody())) {
+ functionCode.zipFile(SdkBytes.fromByteBuffer(exchange.getIn().getBody(ByteBuffer.class)));
+ }
- if (ObjectHelper.isNotEmpty(exchange.getIn().getBody())
- || (ObjectHelper.isNotEmpty(exchange.getIn().getHeader(Lambda2Constants.S3_BUCKET))
- && ObjectHelper.isNotEmpty(exchange.getIn().getHeader(Lambda2Constants.S3_KEY)))) {
- builder.code(functionCode.build());
- } else {
- throw new IllegalArgumentException("At least S3 bucket/S3 key or zip file must be specified");
- }
+ if (ObjectHelper.isNotEmpty(exchange.getIn().getBody())
+ || (ObjectHelper.isNotEmpty(exchange.getIn().getHeader(Lambda2Constants.S3_BUCKET))
+ && ObjectHelper.isNotEmpty(exchange.getIn().getHeader(Lambda2Constants.S3_KEY)))) {
+ builder.code(functionCode.build());
+ } else {
+ throw new IllegalArgumentException("At least S3 bucket/S3 key or zip file must be specified");
+ }
- if (ObjectHelper.isNotEmpty(exchange.getIn().getHeader(Lambda2Constants.ROLE))) {
- builder.role(exchange.getIn().getHeader(Lambda2Constants.ROLE, String.class));
- } else {
- throw new IllegalArgumentException("Role must be specified");
- }
+ if (ObjectHelper.isNotEmpty(exchange.getIn().getHeader(Lambda2Constants.ROLE))) {
+ builder.role(exchange.getIn().getHeader(Lambda2Constants.ROLE, String.class));
+ } else {
+ throw new IllegalArgumentException("Role must be specified");
+ }
- if (ObjectHelper.isNotEmpty(exchange.getIn().getHeader(Lambda2Constants.RUNTIME))) {
- builder.runtime(exchange.getIn().getHeader(Lambda2Constants.RUNTIME, String.class));
- } else {
- throw new IllegalArgumentException("Runtime must be specified");
- }
+ if (ObjectHelper.isNotEmpty(exchange.getIn().getHeader(Lambda2Constants.RUNTIME))) {
+ builder.runtime(exchange.getIn().getHeader(Lambda2Constants.RUNTIME, String.class));
+ } else {
+ throw new IllegalArgumentException("Runtime must be specified");
+ }
- if (ObjectHelper.isNotEmpty(exchange.getIn().getHeader(Lambda2Constants.HANDLER))) {
- builder.handler(exchange.getIn().getHeader(Lambda2Constants.HANDLER, String.class));
- } else {
- throw new IllegalArgumentException("Handler must be specified");
- }
+ if (ObjectHelper.isNotEmpty(exchange.getIn().getHeader(Lambda2Constants.HANDLER))) {
+ builder.handler(exchange.getIn().getHeader(Lambda2Constants.HANDLER, String.class));
+ } else {
+ throw new IllegalArgumentException("Handler must be specified");
+ }
- if (ObjectHelper.isNotEmpty(exchange.getIn().getHeader(Lambda2Constants.DESCRIPTION))) {
- String description = exchange.getIn().getHeader(Lambda2Constants.DESCRIPTION, String.class);
- builder.description(description);
- }
+ if (ObjectHelper.isNotEmpty(exchange.getIn().getHeader(Lambda2Constants.DESCRIPTION))) {
+ String description = exchange.getIn().getHeader(Lambda2Constants.DESCRIPTION, String.class);
+ builder.description(description);
+ }
- if (ObjectHelper.isNotEmpty(exchange.getIn().getHeader(Lambda2Constants.TARGET_ARN))) {
- String targetArn = exchange.getIn().getHeader(Lambda2Constants.TARGET_ARN, String.class);
- builder.deadLetterConfig(DeadLetterConfig.builder().targetArn(targetArn).build());
- }
+ if (ObjectHelper.isNotEmpty(exchange.getIn().getHeader(Lambda2Constants.TARGET_ARN))) {
+ String targetArn = exchange.getIn().getHeader(Lambda2Constants.TARGET_ARN, String.class);
+ builder.deadLetterConfig(DeadLetterConfig.builder().targetArn(targetArn).build());
+ }
- if (ObjectHelper.isNotEmpty(exchange.getIn().getHeader(Lambda2Constants.MEMORY_SIZE))) {
- Integer memorySize = exchange.getIn().getHeader(Lambda2Constants.MEMORY_SIZE, Integer.class);
- builder.memorySize(memorySize);
- }
+ if (ObjectHelper.isNotEmpty(exchange.getIn().getHeader(Lambda2Constants.MEMORY_SIZE))) {
+ Integer memorySize = exchange.getIn().getHeader(Lambda2Constants.MEMORY_SIZE, Integer.class);
+ builder.memorySize(memorySize);
+ }
- if (ObjectHelper.isNotEmpty(exchange.getIn().getHeader(Lambda2Constants.KMS_KEY_ARN))) {
- String kmsKeyARN = exchange.getIn().getHeader(Lambda2Constants.KMS_KEY_ARN, String.class);
- builder.kmsKeyArn(kmsKeyARN);
- }
- if (ObjectHelper.isNotEmpty(exchange.getIn().getHeader(Lambda2Constants.PUBLISH))) {
- Boolean publish = exchange.getIn().getHeader(Lambda2Constants.PUBLISH, Boolean.class);
- builder.publish(publish);
- }
+ if (ObjectHelper.isNotEmpty(exchange.getIn().getHeader(Lambda2Constants.KMS_KEY_ARN))) {
+ String kmsKeyARN = exchange.getIn().getHeader(Lambda2Constants.KMS_KEY_ARN, String.class);
+ builder.kmsKeyArn(kmsKeyARN);
+ }
+ if (ObjectHelper.isNotEmpty(exchange.getIn().getHeader(Lambda2Constants.PUBLISH))) {
+ Boolean publish = exchange.getIn().getHeader(Lambda2Constants.PUBLISH, Boolean.class);
+ builder.publish(publish);
+ }
- if (ObjectHelper.isNotEmpty(exchange.getIn().getHeader(Lambda2Constants.TIMEOUT))) {
- Integer timeout = exchange.getIn().getHeader(Lambda2Constants.TIMEOUT, Integer.class);
- builder.timeout(timeout);
- }
+ if (ObjectHelper.isNotEmpty(exchange.getIn().getHeader(Lambda2Constants.TIMEOUT))) {
+ Integer timeout = exchange.getIn().getHeader(Lambda2Constants.TIMEOUT, Integer.class);
+ builder.timeout(timeout);
+ }
- if (ObjectHelper.isNotEmpty(exchange.getIn().getHeader(Lambda2Constants.TRACING_CONFIG))) {
- String tracingConfigMode = exchange.getIn().getHeader(Lambda2Constants.TRACING_CONFIG, String.class);
- builder.tracingConfig(TracingConfig.builder().mode(tracingConfigMode).build());
- }
+ if (ObjectHelper.isNotEmpty(exchange.getIn().getHeader(Lambda2Constants.TRACING_CONFIG))) {
+ String tracingConfigMode = exchange.getIn().getHeader(Lambda2Constants.TRACING_CONFIG, String.class);
+ builder.tracingConfig(TracingConfig.builder().mode(tracingConfigMode).build());
+ }
- Map<String, String> environmentVariables
- = CastUtils.cast(exchange.getIn().getHeader(Lambda2Constants.ENVIRONMENT_VARIABLES, Map.class));
- if (environmentVariables != null) {
- builder.environment(Environment.builder().variables(environmentVariables).build());
- }
+ Map<String, String> environmentVariables
+ = CastUtils.cast(exchange.getIn().getHeader(Lambda2Constants.ENVIRONMENT_VARIABLES, Map.class));
+ if (environmentVariables != null) {
+ builder.environment(Environment.builder().variables(environmentVariables).build());
+ }
- Map<String, String> tags = CastUtils.cast(exchange.getIn().getHeader(Lambda2Constants.TAGS, Map.class));
- if (tags != null) {
- builder.tags(tags);
- }
+ Map<String, String> tags = CastUtils.cast(exchange.getIn().getHeader(Lambda2Constants.TAGS, Map.class));
+ if (tags != null) {
+ builder.tags(tags);
+ }
- List<String> securityGroupIds = CastUtils.cast(exchange.getIn().getHeader(Lambda2Constants.SECURITY_GROUP_IDS,
- (Class<List<String>>) (Object) List.class));
- List<String> subnetIds = CastUtils.cast(
- exchange.getIn().getHeader(Lambda2Constants.SUBNET_IDS, (Class<List<String>>) (Object) List.class));
- if (securityGroupIds != null || subnetIds != null) {
- VpcConfig.Builder vpcConfig = VpcConfig.builder();
- if (securityGroupIds != null) {
- vpcConfig.securityGroupIds(securityGroupIds);
- }
- if (subnetIds != null) {
- vpcConfig.subnetIds(subnetIds);
- }
- builder.vpcConfig(vpcConfig.build());
+ List<String> securityGroupIds = CastUtils.cast(exchange.getIn().getHeader(Lambda2Constants.SECURITY_GROUP_IDS,
+ (Class<List<String>>) (Object) List.class));
+ List<String> subnetIds = CastUtils.cast(
+ exchange.getIn().getHeader(Lambda2Constants.SUBNET_IDS, (Class<List<String>>) (Object) List.class));
+ if (securityGroupIds != null || subnetIds != null) {
+ VpcConfig.Builder vpcConfig = VpcConfig.builder();
+ if (securityGroupIds != null) {
+ vpcConfig.securityGroupIds(securityGroupIds);
+ }
+ if (subnetIds != null) {
+ vpcConfig.subnetIds(subnetIds);
}
-
- request = builder.build();
+ builder.vpcConfig(vpcConfig.build());
+ }
+
+ request = builder.build();
}
- try {
- result = lambdaClient.createFunction(request);
+ try {
+ result = lambdaClient.createFunction(request);
- } catch (AwsServiceException ase) {
- LOG.trace("createFunction command returned the error code {}", ase.awsErrorDetails().errorCode());
- throw ase;
- }
+ } catch (AwsServiceException ase) {
+ LOG.trace("createFunction command returned the error code {}", ase.awsErrorDetails().errorCode());
+ throw ase;
+ }
- Message message = getMessageForResponse(exchange);
- message.setBody(result);
+ Message message = getMessageForResponse(exchange);
+ message.setBody(result);
}
private void updateFunction(LambdaClient lambdaClient, Exchange exchange) throws Exception {