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 7fc2c181f66c1d91d27a9eb00b1c1bed3d964862 Author: Otavio Rodolfo Piske <[email protected]> AuthorDate: Wed Aug 10 13:18:48 2022 +0200 (chores) camel-resume-api-examples: minor stability cleanups --- .../java/org/apache/camel/example/resume/fileset/main/MainApp.java | 3 ++- examples/resume-api/resume-api-fileset/src/main/scripts/run.sh | 4 ++-- 2 files changed, 4 insertions(+), 3 deletions(-) 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 8bf8bfea..1b8268e0 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 @@ -40,8 +40,9 @@ public class MainApp { SingleNodeKafkaResumeStrategy<Resumable> resumeStrategy = KafkaUtil.getDefaultStrategy(); RouteBuilder routeBuilder = new LargeDirectoryRouteBuilder(resumeStrategy, new CaffeineCache<>(10000)); - main.configure().addRoutesBuilder(routeBuilder); main.configure().addRoutesBuilder(new CheckRoute()); + main.configure().addRoutesBuilder(routeBuilder); + main.run(args); } } diff --git a/examples/resume-api/resume-api-fileset/src/main/scripts/run.sh b/examples/resume-api/resume-api-fileset/src/main/scripts/run.sh index 972ad6bc..4a80ba9f 100644 --- a/examples/resume-api/resume-api-fileset/src/main/scripts/run.sh +++ b/examples/resume-api/resume-api-fileset/src/main/scripts/run.sh @@ -23,7 +23,7 @@ function checkResults() { echo "###**************************************************************************###" echo "Results: repeated items: ${repeated}" - echo "Results: processed items: ${processedRecords} (expected ${expectedItems})" + echo "Results: processed items: ${processedRecords} (expected at least ${expectedItems})" echo "###**************************************************************************###" echo "Resume simulation completed" echo "###**************************************************************************###" @@ -39,7 +39,7 @@ mkdir -p ${DATA_DIR} ITERATIONS=${1:-5} BATCH_SIZE=${2:-100} FILE_COUNT=${3:-100} -MAX_IDLE=5 +MAX_IDLE=10 for i in $(seq 0 ${ITERATIONS}) ; do mkdir -p ${DATA_DIR}/${i}
