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 <[email protected]> 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); } /**
