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:30 UTC
[camel-examples] 04/12: (chores) camel-resume-api-examples: remove the unnecessary throttling
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 ddfa265874af2323778b4ad4259b056b7445fcd4
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Tue Aug 9 10:48:19 2022 +0200
(chores) camel-resume-api-examples: remove the unnecessary throttling
---
.../resume/strategies/kafka/fileset/LargeDirectoryRouteBuilder.java | 5 +----
1 file changed, 1 insertion(+), 4 deletions(-)
diff --git a/examples/resume-api/resume-api-common/src/main/java/org/apache/camel/example/resume/strategies/kafka/fileset/LargeDirectoryRouteBuilder.java b/examples/resume-api/resume-api-common/src/main/java/org/apache/camel/example/resume/strategies/kafka/fileset/LargeDirectoryRouteBuilder.java
index e5f1adec..9a34fdfd 100644
--- a/examples/resume-api/resume-api-common/src/main/java/org/apache/camel/example/resume/strategies/kafka/fileset/LargeDirectoryRouteBuilder.java
+++ b/examples/resume-api/resume-api-common/src/main/java/org/apache/camel/example/resume/strategies/kafka/fileset/LargeDirectoryRouteBuilder.java
@@ -39,13 +39,10 @@ public class LargeDirectoryRouteBuilder extends RouteBuilder {
this.cache = cache;
}
- private void process(Exchange exchange) throws Exception {
+ private void process(Exchange exchange) {
File path = exchange.getMessage().getHeader("CamelFilePath", File.class);
LOG.debug("Processing {}", path.getPath());
exchange.getMessage().setHeader(Exchange.OFFSET, Resumables.of(path.getParentFile(), path));
-
- // Put a delay to simulate slow processing
- Thread.sleep(50);
}
/**