You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by or...@apache.org on 2022/08/19 04:20:28 UTC
[camel-examples] 02/12: (chores) camel-resume-api-examples: add a new route for checking the results
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 <an...@gmail.com>
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);
}
}