This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch regen_bot
in repository https://gitbox.apache.org/repos/asf/camel.git
from 5d642dc6b07 CAMEL-17949 - Infinite loop when setting retries
add 4a61168caeb (chores) ci: run PR checks for backports to LTS branches
add c05c928da1b CAMEL-18127: implement adapter auto-configuration in the
resume API
add fce963f62ab Regen for commit c05c928da1b831c51c5d4617bbf81e0165b2bcf6
No new revisions were added by this update.
Summary of changes:
.github/workflows/master-pr-build.yml | 2 +
.../org/apache/camel/resume/adapter.properties | 18 ++
.../resume/{single => }/CaffeineCache.java | 61 +++++--
.../caffeine/resume/multi/CaffeineCache.java | 98 -----------
.../integration/ConsumeResumeStrategyIT.java | 2 +-
.../couchdb/consumer/CouchDbResumable.java | 15 +-
.../apache/camel/component/file/FileConsumer.java | 28 +++-
.../apache/camel/component/file/GenericFile.java | 10 +-
...ble.java => DirectoryEntriesResumeAdapter.java} | 6 +-
...meAdapter.java => FileOffsetResumeAdapter.java} | 18 +-
.../component/file/consumer/FileResumeAdapter.java | 8 +-
.../adapters/AbstractFileResumeAdapter.java} | 37 +++--
.../DefaultDirectoryEntriesResumeAdapter.java | 75 +++++++++
.../adapters/DefaultFileOffsetResumeAdapter.java | 95 +++++++++++
.../adapters/DefaultFileSetResumeAdapter.java | 65 --------
.../adapters/DefaultGenericFileResumeAdapter.java | 64 --------
.../DirectoryEntries.java} | 33 ++--
.../file/consumer/adapters/FileOffset.java} | 31 ++--
.../adapters/FileResumeAdapterDelegate.java | 92 +++++++++++
.../FileSet.java} | 47 ++++--
.../org/apache/camel/resume/adapter.properties | 18 ++
.../kafka/consumer/support/KafkaResumable.java | 15 +-
.../resume/kafka/KafkaResumeStrategy.java | 5 +-
.../resume/kafka/MultiNodeKafkaResumeStrategy.java | 84 +++++-----
.../kafka/SingleNodeKafkaResumeStrategy.java | 159 +++++++++++-------
.../KafkaConsumerWithResumeRouteStrategyIT.java | 16 +-
.../resume/{ResumeStrategy.java => Cacheable.java} | 32 ++--
.../org/apache/camel/resume/Deserializable.java | 56 +++++++
.../main/java/org/apache/camel/resume/Offset.java | 15 +-
.../SingleEntryCache.java => OffsetKey.java} | 32 ++--
.../java/org/apache/camel/resume/Resumable.java | 21 +--
.../java/org/apache/camel/resume/ResumableSet.java | 81 ---------
.../org/apache/camel/resume/ResumeAdapter.java | 3 +
.../org/apache/camel/resume/ResumeStrategy.java | 16 ++
.../java/org/apache/camel/resume/Serializable.java | 83 ++++++++++
.../resume/UpdatableConsumerResumeStrategy.java | 4 +-
.../apache/camel/resume/cache/MultiEntryCache.java | 29 ----
.../org/apache/camel/resume/cache/ResumeCache.java | 47 +++++-
.../org/apache/camel/impl/engine/DefaultRoute.java | 6 +-
.../docs/modules/eips/pages/resume-strategies.adoc | 51 +-----
.../processor/resume/DelegatingResumeAdapter.java | 181 ---------------------
.../processor/resume/ResumableCompletion.java | 14 +-
.../processor/resume/TransientResumeStrategy.java | 10 ++
.../FileConsumerResumeFromOffsetStrategyTest.java | 54 ++++--
.../file/FileConsumerResumeStrategyTest.java | 36 ++--
.../apache/camel/support/resume/AdapterHelper.java | 112 +++++++++++++
.../apache/camel/support/resume/OffsetKeys.java | 109 +++++++++++++
.../org/apache/camel/support/resume/Offsets.java | 24 ++-
.../apache/camel/support/resume/Resumables.java | 59 ++++++-
49 files changed, 1290 insertions(+), 887 deletions(-)
create mode 100644
components/camel-atom/src/main/resources/org/apache/camel/resume/adapter.properties
rename
components/camel-caffeine/src/main/java/org/apache/camel/component/caffeine/resume/{single
=> }/CaffeineCache.java (58%)
delete mode 100644
components/camel-caffeine/src/main/java/org/apache/camel/component/caffeine/resume/multi/CaffeineCache.java
rename
components/camel-file/src/main/java/org/apache/camel/component/file/consumer/{GenericFileResumable.java
=> DirectoryEntriesResumeAdapter.java} (81%)
rename
components/camel-file/src/main/java/org/apache/camel/component/file/consumer/{FileSetResumeAdapter.java
=> FileOffsetResumeAdapter.java} (69%)
copy
components/{camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/KafkaResumable.java
=>
camel-file/src/main/java/org/apache/camel/component/file/consumer/adapters/AbstractFileResumeAdapter.java}
(50%)
create mode 100644
components/camel-file/src/main/java/org/apache/camel/component/file/consumer/adapters/DefaultDirectoryEntriesResumeAdapter.java
create mode 100644
components/camel-file/src/main/java/org/apache/camel/component/file/consumer/adapters/DefaultFileOffsetResumeAdapter.java
delete mode 100644
components/camel-file/src/main/java/org/apache/camel/component/file/consumer/adapters/DefaultFileSetResumeAdapter.java
delete mode 100644
components/camel-file/src/main/java/org/apache/camel/component/file/consumer/adapters/DefaultGenericFileResumeAdapter.java
rename
components/camel-file/src/main/java/org/apache/camel/component/file/consumer/{FileResumeSet.java
=> adapters/DirectoryEntries.java} (70%)
rename
components/{camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/KafkaOffset.java
=>
camel-file/src/main/java/org/apache/camel/component/file/consumer/adapters/FileOffset.java}
(63%)
create mode 100644
components/camel-file/src/main/java/org/apache/camel/component/file/consumer/adapters/FileResumeAdapterDelegate.java
rename
components/camel-file/src/main/java/org/apache/camel/component/file/consumer/{GenericFileResumeAdapter.java
=> adapters/FileSet.java} (55%)
create mode 100644
components/camel-file/src/main/resources/org/apache/camel/resume/adapter.properties
copy core/camel-api/src/main/java/org/apache/camel/resume/{ResumeStrategy.java
=> Cacheable.java} (53%)
create mode 100644
core/camel-api/src/main/java/org/apache/camel/resume/Deserializable.java
rename
core/camel-api/src/main/java/org/apache/camel/resume/{cache/SingleEntryCache.java
=> OffsetKey.java} (62%)
delete mode 100644
core/camel-api/src/main/java/org/apache/camel/resume/ResumableSet.java
create mode 100644
core/camel-api/src/main/java/org/apache/camel/resume/Serializable.java
delete mode 100644
core/camel-api/src/main/java/org/apache/camel/resume/cache/MultiEntryCache.java
delete mode 100644
core/camel-core-processor/src/main/java/org/apache/camel/processor/resume/DelegatingResumeAdapter.java
create mode 100644
core/camel-support/src/main/java/org/apache/camel/support/resume/AdapterHelper.java
create mode 100644
core/camel-support/src/main/java/org/apache/camel/support/resume/OffsetKeys.java
