You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2021/12/21 13:56:46 UTC
[camel-examples] branch main updated: CAMEL-17194: endpointdsl - Prepare for generate only once during project build.
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-examples.git
The following commit(s) were added to refs/heads/main by this push:
new ed6ff7a CAMEL-17194: endpointdsl - Prepare for generate only once during project build.
ed6ff7a is described below
commit ed6ff7a758c37d0b63a17c194bcaa3e5d50dfa78
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Tue Dec 21 14:56:35 2021 +0100
CAMEL-17194: endpointdsl - Prepare for generate only once during project build.
---
.../org/apache/camel/example/MyRouteBuilder.java | 31 ++++++++--------------
.../org/apache/camel/example/MyRouteBuilder.java | 12 ++++++---
.../org/apache/camel/example/MyRouteBuilder.java | 8 +++---
3 files changed, 22 insertions(+), 29 deletions(-)
diff --git a/examples/aws/main-endpointdsl-aws2/aws2-eventbridge-creator/src/main/java/org/apache/camel/example/MyRouteBuilder.java b/examples/aws/main-endpointdsl-aws2/aws2-eventbridge-creator/src/main/java/org/apache/camel/example/MyRouteBuilder.java
index 690ba44..3076ddd 100644
--- a/examples/aws/main-endpointdsl-aws2/aws2-eventbridge-creator/src/main/java/org/apache/camel/example/MyRouteBuilder.java
+++ b/examples/aws/main-endpointdsl-aws2/aws2-eventbridge-creator/src/main/java/org/apache/camel/example/MyRouteBuilder.java
@@ -19,12 +19,9 @@ package org.apache.camel.example;
import java.util.ArrayList;
import java.util.List;
-import org.apache.camel.Exchange;
-import org.apache.camel.Processor;
import org.apache.camel.builder.endpoint.EndpointRouteBuilder;
-import org.apache.camel.builder.endpoint.dsl.EventbridgeEndpointBuilderFactory.EventbridgeOperations;
import org.apache.camel.component.aws2.eventbridge.EventbridgeConstants;
-
+import org.apache.camel.component.aws2.eventbridge.EventbridgeOperations;
import software.amazon.awssdk.services.eventbridge.model.Target;
/**
@@ -34,26 +31,20 @@ public class MyRouteBuilder extends EndpointRouteBuilder {
@Override
public void configure() throws Exception {
-
from(timer("fire").repeatCount("1"))
- .setHeader(EventbridgeConstants.RULE_NAME, constant("s3-events-rule"))
- .to(aws2Eventbridge("default")
+ .setHeader(EventbridgeConstants.RULE_NAME, constant("s3-events-rule"))
+ .to(aws2Eventbridge("default")
.operation(EventbridgeOperations.putRule)
.eventPatternFile("file:src/main/resources/eventpattern.json"))
- .process(new Processor() {
-
- @Override
- public void process(Exchange exchange) throws Exception {
- exchange.getIn().setHeader(EventbridgeConstants.RULE_NAME, "s3-events-rule");
- Target target = Target.builder().id("sqs-queue").arn("arn:aws:sqs:eu-west-1:780410022472:camel-connector-test")
- .build();
- List<Target> targets = new ArrayList<Target>();
+ .process(exchange -> {
+ exchange.getMessage().setHeader(EventbridgeConstants.RULE_NAME, "s3-events-rule");
+ Target target = Target.builder().id("sqs-queue").arn("arn:aws:sqs:eu-west-1:780410022472:camel-connector-test").build();
+ List<Target> targets = new ArrayList<>();
targets.add(target);
- exchange.getIn().setHeader(EventbridgeConstants.TARGETS, targets);
- }
- })
- .to(aws2Eventbridge("default")
+ exchange.getMessage().setHeader(EventbridgeConstants.TARGETS, targets);
+ })
+ .to(aws2Eventbridge("default")
.operation(EventbridgeOperations.putTargets))
- .log("All set, enjoy!");
+ .log("All set, enjoy!");
}
}
diff --git a/examples/aws/main-endpointdsl-kafka-aws2-s3-restarting-policy/src/main/java/org/apache/camel/example/MyRouteBuilder.java b/examples/aws/main-endpointdsl-kafka-aws2-s3-restarting-policy/src/main/java/org/apache/camel/example/MyRouteBuilder.java
index a3ed90d..dd9be98 100644
--- a/examples/aws/main-endpointdsl-kafka-aws2-s3-restarting-policy/src/main/java/org/apache/camel/example/MyRouteBuilder.java
+++ b/examples/aws/main-endpointdsl-kafka-aws2-s3-restarting-policy/src/main/java/org/apache/camel/example/MyRouteBuilder.java
@@ -17,17 +17,21 @@
package org.apache.camel.example;
import org.apache.camel.builder.endpoint.EndpointRouteBuilder;
-import org.apache.camel.builder.endpoint.dsl.AWS2S3EndpointBuilderFactory;
-import software.amazon.awssdk.regions.Region;
+import org.apache.camel.component.aws2.s3.stream.AWSS3NamingStrategyEnum;
+import org.apache.camel.component.aws2.s3.stream.AWSS3RestartingPolicyEnum;
public class MyRouteBuilder extends EndpointRouteBuilder {
@Override
public void configure() throws Exception {
-
from(kafka("{{kafkaTopic1}}").brokers("{{kafkaBrokers}}"))
.log("Kafka Message is: ${body}")
- .toD(aws2S3("{{bucketName}}").streamingUploadMode(true).useDefaultCredentialsProvider(true).restartingPolicy(AWS2S3EndpointBuilderFactory.AWSS3RestartingPolicyEnum.lastPart).batchMessageNumber(25).namingStrategy(AWS2S3EndpointBuilderFactory.AWSS3NamingStrategyEnum.progressive).keyName("{{kafkaTopic1}}/partition_${headers.kafka.PARTITION}/{{kafkaTopic1}}.txt"));
+ .toD(aws2S3("{{bucketName}}")
+ .streamingUploadMode(true)
+ .useDefaultCredentialsProvider(true)
+ .restartingPolicy(AWSS3RestartingPolicyEnum.lastPart)
+ .batchMessageNumber(25).namingStrategy(AWSS3NamingStrategyEnum.progressive)
+ .keyName("{{kafkaTopic1}}/partition_${headers.kafka.PARTITION}/{{kafkaTopic1}}.txt"));
}
}
diff --git a/examples/aws/main-endpointdsl-kafka-aws2-s3/src/main/java/org/apache/camel/example/MyRouteBuilder.java b/examples/aws/main-endpointdsl-kafka-aws2-s3/src/main/java/org/apache/camel/example/MyRouteBuilder.java
index 32f0a7f..d51038b 100644
--- a/examples/aws/main-endpointdsl-kafka-aws2-s3/src/main/java/org/apache/camel/example/MyRouteBuilder.java
+++ b/examples/aws/main-endpointdsl-kafka-aws2-s3/src/main/java/org/apache/camel/example/MyRouteBuilder.java
@@ -17,21 +17,19 @@
package org.apache.camel.example;
import org.apache.camel.builder.endpoint.EndpointRouteBuilder;
-import org.apache.camel.builder.endpoint.dsl.AWS2S3EndpointBuilderFactory;
-import software.amazon.awssdk.regions.Region;
+import org.apache.camel.component.aws2.s3.stream.AWSS3NamingStrategyEnum;
public class MyRouteBuilder extends EndpointRouteBuilder {
@Override
public void configure() throws Exception {
-
from(kafka("{{kafkaTopic1}}").brokers("{{kafkaBrokers}}"))
.log("Kafka Message is: ${body}")
- .to(aws2S3("{{bucketName}}").useDefaultCredentialsProvider(true).streamingUploadMode(true).batchMessageNumber(25).namingStrategy(AWS2S3EndpointBuilderFactory.AWSS3NamingStrategyEnum.progressive).keyName("{{kafkaTopic1}}/{{kafkaTopic1}}.txt"));
+ .to(aws2S3("{{bucketName}}").useDefaultCredentialsProvider(true).streamingUploadMode(true).batchMessageNumber(25).namingStrategy(AWSS3NamingStrategyEnum.progressive).keyName("{{kafkaTopic1}}/{{kafkaTopic1}}.txt"));
from(kafka("{{kafkaTopic2}}").brokers("{{kafkaBrokers}}"))
.log("Kafka Message is: ${body}")
- .to(aws2S3("{{bucketName}}").useDefaultCredentialsProvider(true).streamingUploadMode(true).batchMessageNumber(25).namingStrategy(AWS2S3EndpointBuilderFactory.AWSS3NamingStrategyEnum.progressive).keyName("{{kafkaTopic2}}/{{kafkaTopic2}}.txt"));
+ .to(aws2S3("{{bucketName}}").useDefaultCredentialsProvider(true).streamingUploadMode(true).batchMessageNumber(25).namingStrategy(AWSS3NamingStrategyEnum.progressive).keyName("{{kafkaTopic2}}/{{kafkaTopic2}}.txt"));
}
}