This is an automated email from the ASF dual-hosted git repository. orpiske pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-examples.git
commit 32d671c906161d2c86ce0600682ee5c49ec55ccf Author: Otavio Rodolfo Piske <[email protected]> AuthorDate: Tue Aug 9 10:10:11 2022 +0200 (chores) camel-resume-api-examples: add a new route for checking the results --- .../example/resume/strategies/kafka/check/CheckRoute.java | 14 ++++++++++++++ .../apache/camel/example/resume/fileset/main/MainApp.java | 2 ++ 2 files changed, 16 insertions(+) diff --git a/examples/resume-api/resume-api-common/src/main/java/org/apache/camel/example/resume/strategies/kafka/check/CheckRoute.java b/examples/resume-api/resume-api-common/src/main/java/org/apache/camel/example/resume/strategies/kafka/check/CheckRoute.java new file mode 100644 index 00000000..fbc3ab02 --- /dev/null +++ b/examples/resume-api/resume-api-common/src/main/java/org/apache/camel/example/resume/strategies/kafka/check/CheckRoute.java @@ -0,0 +1,14 @@ +package org.apache.camel.example.resume.strategies.kafka.check; + +import org.apache.camel.builder.RouteBuilder; + +public class CheckRoute extends RouteBuilder { + + @Override + public void configure() { + from("kafka:{{resume.type.kafka.topic}}?brokers={{bootstrap.address}}") + .to("file:{{output.dir}}?fileName=summary.txt&fileExist=Append&appendChars=\n"); + } + + +} diff --git a/examples/resume-api/resume-api-fileset/src/main/java/org/apache/camel/example/resume/fileset/main/MainApp.java b/examples/resume-api/resume-api-fileset/src/main/java/org/apache/camel/example/resume/fileset/main/MainApp.java index ae30afae..8bf8bfea 100644 --- a/examples/resume-api/resume-api-fileset/src/main/java/org/apache/camel/example/resume/fileset/main/MainApp.java +++ b/examples/resume-api/resume-api-fileset/src/main/java/org/apache/camel/example/resume/fileset/main/MainApp.java @@ -20,6 +20,7 @@ package org.apache.camel.example.resume.fileset.main; import org.apache.camel.builder.RouteBuilder; import org.apache.camel.component.caffeine.resume.CaffeineCache; import org.apache.camel.example.resume.strategies.kafka.KafkaUtil; +import org.apache.camel.example.resume.strategies.kafka.check.CheckRoute; import org.apache.camel.example.resume.strategies.kafka.fileset.LargeDirectoryRouteBuilder; import org.apache.camel.main.Main; import org.apache.camel.processor.resume.kafka.SingleNodeKafkaResumeStrategy; @@ -40,6 +41,7 @@ public class MainApp { RouteBuilder routeBuilder = new LargeDirectoryRouteBuilder(resumeStrategy, new CaffeineCache<>(10000)); main.configure().addRoutesBuilder(routeBuilder); + main.configure().addRoutesBuilder(new CheckRoute()); main.run(args); } }
