This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/camel-examples.git
from 77537fe3 CAMEL-6645: A camel-mapstruct example
new 907be061 (chores) camel-resume-api-examples: avoid blocking for too
long by default
new 32d671c9 (chores) camel-resume-api-examples: add a new route for
checking the results
new 2491ed2b (chores) camel-resume-api-examples: minor logging adjustments
for debugging
new ddfa2658 (chores) camel-resume-api-examples: remove the unnecessary
throttling
new e17fb5fd (chores) camel-resume-api-examples: add support for verifying
the results
new e37b65f0 (chores) camel-resume-api-examples: logging cleanups for
resume-api-file-offset
new f2664dce (chores) camel-resume-api-examples: use the default strategy
builder as part of CAMEL-18362
new 9674ff8e (chores) camel-resume-api-examples: support checking results
for the offset example
new f2469b66 (chores) camel-resume-api-examples: adjust the initialization
duration to match the launch script
new 3236a87b (chores) camel-resume-api-examples: avoid blocking the check
route for too long
new 7fc2c181 (chores) camel-resume-api-examples: minor stability cleanups
new e97db54a (chores) camel-resume-api: cleaned up the example with
clustering
The 12 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
examples/resume-api/resume-api-common/pom.xml | 4 +++
.../example/resume/strategies/kafka/KafkaUtil.java | 19 +++--------
.../resume/strategies/kafka/check/CheckRoute.java | 14 ++++++++
.../kafka/file/LargeFileRouteBuilder.java | 8 +++++
.../kafka/fileset/LargeDirectoryRouteBuilder.java | 5 +--
.../src/main/docker/Dockerfile | 2 +-
.../example/resume/file/offset/main/MainApp.java | 2 +-
.../src/main/resources/log4j2.properties | 15 ++++++++-
.../resume-api-file-offset/src/main/scripts/run.sh | 37 +++++++++++++++++---
.../clusterized/main/ClusterizedListener.java | 22 +++---------
.../ClusterizedLargeDirectoryRouteBuilder.java | 2 +-
.../resume-api-fileset/src/main/docker/Dockerfile | 1 +
.../camel/example/resume/fileset/main/MainApp.java | 3 ++
.../src/main/resources/log4j2.properties | 14 +++++++-
.../resume-api-fileset/src/main/scripts/run.sh | 39 ++++++++++++++++++----
15 files changed, 134 insertions(+), 53 deletions(-)
create mode 100644
examples/resume-api/resume-api-common/src/main/java/org/apache/camel/example/resume/strategies/kafka/check/CheckRoute.java