(camel) 01/02: CAMEL-20912, CAMEL-20913 - Camel-AWS-Kinesis: KCL Consumers add parameters for passing Cloudwatch and DynamoDB Clients and for profile/default/session credentials Providers
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel.git commit 8a2116fb4b91ed040a7134019b9b2d278d3b0919 Author: Andrea Cosentino AuthorDate: Tue Jun 25 11:29:31 2024 +0200 CAMEL-20912, CAMEL-20913 - Camel-AWS-Kinesis: KCL Consumers add parameters for passing Cloudwatch and DynamoDB Clients and for profile/default/session credentials Providers Signed-off-by: Andrea Cosentino --- .../aws2/kinesis/Kinesis2ComponentConfigurer.java | 12 +++ .../aws2/kinesis/Kinesis2EndpointConfigurer.java | 12 +++ .../aws2/kinesis/Kinesis2EndpointUriFactory.java | 4 +- .../camel/component/aws2/kinesis/aws2-kinesis.json | 84 .../aws2/kinesis/KclKinesis2Consumer.java | 112 - .../aws2/kinesis/Kinesis2Configuration.java| 26 + .../kinesis/integration/KclKinesisConsumerIT.java | 6 +- 7 files changed, 186 insertions(+), 70 deletions(-) diff --git a/components/camel-aws/camel-aws2-kinesis/src/generated/java/org/apache/camel/component/aws2/kinesis/Kinesis2ComponentConfigurer.java b/components/camel-aws/camel-aws2-kinesis/src/generated/java/org/apache/camel/component/aws2/kinesis/Kinesis2ComponentConfigurer.java index 47834f557c6..8f6412022df 100644 --- a/components/camel-aws/camel-aws2-kinesis/src/generated/java/org/apache/camel/component/aws2/kinesis/Kinesis2ComponentConfigurer.java +++ b/components/camel-aws/camel-aws2-kinesis/src/generated/java/org/apache/camel/component/aws2/kinesis/Kinesis2ComponentConfigurer.java @@ -42,7 +42,11 @@ public class Kinesis2ComponentConfigurer extends PropertyConfigurerSupport imple case "bridgeErrorHandler": target.setBridgeErrorHandler(property(camelContext, boolean.class, value)); return true; case "cborenabled": case "cborEnabled": getOrCreateConfiguration(target).setCborEnabled(property(camelContext, boolean.class, value)); return true; +case "cloudwatchasyncclient": +case "cloudWatchAsyncClient": getOrCreateConfiguration(target).setCloudWatchAsyncClient(property(camelContext, software.amazon.awssdk.services.cloudwatch.CloudWatchAsyncClient.class, value)); return true; case "configuration": target.setConfiguration(property(camelContext, org.apache.camel.component.aws2.kinesis.Kinesis2Configuration.class, value)); return true; +case "dynamodbasyncclient": +case "dynamoDbAsyncClient": getOrCreateConfiguration(target).setDynamoDbAsyncClient(property(camelContext, software.amazon.awssdk.services.dynamodb.DynamoDbAsyncClient.class, value)); return true; case "healthcheckconsumerenabled": case "healthCheckConsumerEnabled": target.setHealthCheckConsumerEnabled(property(camelContext, boolean.class, value)); return true; case "healthcheckproducerenabled": @@ -112,7 +116,11 @@ public class Kinesis2ComponentConfigurer extends PropertyConfigurerSupport imple case "bridgeErrorHandler": return boolean.class; case "cborenabled": case "cborEnabled": return boolean.class; +case "cloudwatchasyncclient": +case "cloudWatchAsyncClient": return software.amazon.awssdk.services.cloudwatch.CloudWatchAsyncClient.class; case "configuration": return org.apache.camel.component.aws2.kinesis.Kinesis2Configuration.class; +case "dynamodbasyncclient": +case "dynamoDbAsyncClient": return software.amazon.awssdk.services.dynamodb.DynamoDbAsyncClient.class; case "healthcheckconsumerenabled": case "healthCheckConsumerEnabled": return boolean.class; case "healthcheckproducerenabled": @@ -178,7 +186,11 @@ public class Kinesis2ComponentConfigurer extends PropertyConfigurerSupport imple case "bridgeErrorHandler": return target.isBridgeErrorHandler(); case "cborenabled": case "cborEnabled": return getOrCreateConfiguration(target).isCborEnabled(); +case "cloudwatchasyncclient": +case "cloudWatchAsyncClient": return getOrCreateConfiguration(target).getCloudWatchAsyncClient(); case "configuration": return target.getConfiguration(); +case "dynamodbasyncclient": +case "dynamoDbAsyncClient": return getOrCreateConfiguration(target).getDynamoDbAsyncClient(); case "healthcheckconsumerenabled": case "healthCheckConsumerEnabled": return target.isHealthCheckConsumerEnabled(); case "healthcheckproducerenabled": diff --git a/components/camel-aws/camel-aws2-kinesis/src/generated/java/org/apache/camel/component/aws2/kinesis/Kinesis2EndpointConfigurer.java b/components/camel-aws/camel-aws2-kinesis/src/generated/java/org/apache/camel/component/aws2/kinesis/Kinesis2EndpointConfigurer.java index c656b45554a..43aa3bdfddd 100644 ---
(camel) 01/02: CAMEL-20912, CAMEL-20913 - Camel-AWS-Kinesis: KCL Consumers add parameters for passing Cloudwatch and DynamoDB Clients and for profile/default/session credentials Providers
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch kinesis-kcl in repository https://gitbox.apache.org/repos/asf/camel.git commit 93295d03394e98bc4616c903437e0919fbd63154 Author: Andrea Cosentino AuthorDate: Tue Jun 25 11:29:31 2024 +0200 CAMEL-20912, CAMEL-20913 - Camel-AWS-Kinesis: KCL Consumers add parameters for passing Cloudwatch and DynamoDB Clients and for profile/default/session credentials Providers Signed-off-by: Andrea Cosentino --- .../aws2/kinesis/Kinesis2ComponentConfigurer.java | 12 +++ .../aws2/kinesis/Kinesis2EndpointConfigurer.java | 12 +++ .../aws2/kinesis/Kinesis2EndpointUriFactory.java | 4 +- .../camel/component/aws2/kinesis/aws2-kinesis.json | 84 .../aws2/kinesis/KclKinesis2Consumer.java | 112 - .../aws2/kinesis/Kinesis2Configuration.java| 26 + .../kinesis/integration/KclKinesisConsumerIT.java | 6 +- 7 files changed, 186 insertions(+), 70 deletions(-) diff --git a/components/camel-aws/camel-aws2-kinesis/src/generated/java/org/apache/camel/component/aws2/kinesis/Kinesis2ComponentConfigurer.java b/components/camel-aws/camel-aws2-kinesis/src/generated/java/org/apache/camel/component/aws2/kinesis/Kinesis2ComponentConfigurer.java index 47834f557c6..8f6412022df 100644 --- a/components/camel-aws/camel-aws2-kinesis/src/generated/java/org/apache/camel/component/aws2/kinesis/Kinesis2ComponentConfigurer.java +++ b/components/camel-aws/camel-aws2-kinesis/src/generated/java/org/apache/camel/component/aws2/kinesis/Kinesis2ComponentConfigurer.java @@ -42,7 +42,11 @@ public class Kinesis2ComponentConfigurer extends PropertyConfigurerSupport imple case "bridgeErrorHandler": target.setBridgeErrorHandler(property(camelContext, boolean.class, value)); return true; case "cborenabled": case "cborEnabled": getOrCreateConfiguration(target).setCborEnabled(property(camelContext, boolean.class, value)); return true; +case "cloudwatchasyncclient": +case "cloudWatchAsyncClient": getOrCreateConfiguration(target).setCloudWatchAsyncClient(property(camelContext, software.amazon.awssdk.services.cloudwatch.CloudWatchAsyncClient.class, value)); return true; case "configuration": target.setConfiguration(property(camelContext, org.apache.camel.component.aws2.kinesis.Kinesis2Configuration.class, value)); return true; +case "dynamodbasyncclient": +case "dynamoDbAsyncClient": getOrCreateConfiguration(target).setDynamoDbAsyncClient(property(camelContext, software.amazon.awssdk.services.dynamodb.DynamoDbAsyncClient.class, value)); return true; case "healthcheckconsumerenabled": case "healthCheckConsumerEnabled": target.setHealthCheckConsumerEnabled(property(camelContext, boolean.class, value)); return true; case "healthcheckproducerenabled": @@ -112,7 +116,11 @@ public class Kinesis2ComponentConfigurer extends PropertyConfigurerSupport imple case "bridgeErrorHandler": return boolean.class; case "cborenabled": case "cborEnabled": return boolean.class; +case "cloudwatchasyncclient": +case "cloudWatchAsyncClient": return software.amazon.awssdk.services.cloudwatch.CloudWatchAsyncClient.class; case "configuration": return org.apache.camel.component.aws2.kinesis.Kinesis2Configuration.class; +case "dynamodbasyncclient": +case "dynamoDbAsyncClient": return software.amazon.awssdk.services.dynamodb.DynamoDbAsyncClient.class; case "healthcheckconsumerenabled": case "healthCheckConsumerEnabled": return boolean.class; case "healthcheckproducerenabled": @@ -178,7 +186,11 @@ public class Kinesis2ComponentConfigurer extends PropertyConfigurerSupport imple case "bridgeErrorHandler": return target.isBridgeErrorHandler(); case "cborenabled": case "cborEnabled": return getOrCreateConfiguration(target).isCborEnabled(); +case "cloudwatchasyncclient": +case "cloudWatchAsyncClient": return getOrCreateConfiguration(target).getCloudWatchAsyncClient(); case "configuration": return target.getConfiguration(); +case "dynamodbasyncclient": +case "dynamoDbAsyncClient": return getOrCreateConfiguration(target).getDynamoDbAsyncClient(); case "healthcheckconsumerenabled": case "healthCheckConsumerEnabled": return target.isHealthCheckConsumerEnabled(); case "healthcheckproducerenabled": diff --git a/components/camel-aws/camel-aws2-kinesis/src/generated/java/org/apache/camel/component/aws2/kinesis/Kinesis2EndpointConfigurer.java b/components/camel-aws/camel-aws2-kinesis/src/generated/java/org/apache/camel/component/aws2/kinesis/Kinesis2EndpointConfigurer.java index c656b45554a..43aa3bdfddd 100644 ---
