You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by gi...@apache.org on 2022/02/07 21:35:47 UTC
[camel] branch regen_bot updated (4d470f4 -> 855f367)
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 4d470f4 Regen for commit b46d3a3049df74ef8772f267d37c563f1cab6661
add 855f367 CAMEL-15562: simplify the resume API
No new revisions were added by this update.
Summary of changes:
.../component/aws2/kinesis/Kinesis2Consumer.java | 3 +-
.../kinesis/consumer/KinesisResumeStrategy.java | 1 +
.../KinesisUserConfigurationResumeStrategy.java | 8 +-
.../component/couchdb/CouchDbChangesetTracker.java | 5 +-
.../couchdb/consumer/CouchDbResumable.java | 15 +++-
.../couchdb/consumer/CouchDbResumeStrategy.java | 2 +-
.../LatestUpdateSequenceResumeStrategy.java | 10 ++-
.../apache/camel/component/file/FileConsumer.java | 11 +--
.../apache/camel/component/file/GenericFile.java | 17 ++--
.../camel/component/file/GenericFileConverter.java | 2 +-
.../file/consumer/FileConsumerResumeStrategy.java | 17 +---
.../component/file/consumer/FileResumeSet.java | 26 ++-----
.../file/consumer/FileSetResumeStrategy.java} | 9 +--
.../file/consumer/GenericFileResumable.java} | 9 +--
.../file/consumer/GenericFileResumeStrategy.java} | 9 +--
.../support/KafkaConsumerResumeStrategy.java | 19 +++--
.../kafka/consumer/support/KafkaOffset.java} | 22 ++++--
.../kafka/consumer/support/KafkaResumable.java} | 32 ++++----
.../support/OffsetKafkaConsumerResumeStrategy.java | 18 ++++-
.../support/PartitionAssignmentListener.java | 9 ++-
.../consumer/support/ResumeStrategyFactory.java | 11 ++-
.../SeekPolicyKafkaConsumerResumeStrategy.java | 17 +++-
.../KafkaConsumerWithResumeStrategyIT.java | 14 +++-
.../src/main/java/org/apache/camel/Offset.java | 17 ++--
.../src/main/java/org/apache/camel/Resumable.java | 20 +++--
.../main/java/org/apache/camel/ResumableSet.java | 72 +++++++++++++++++
.../main/java/org/apache/camel/ResumeStrategy.java | 3 +-
...e.java => UpdatableConsumerResumeStrategy.java} | 25 +++---
.../FileConsumerResumeFromOffsetStrategyTest.java | 18 ++---
.../file/FileConsumerResumeStrategyTest.java | 29 +++----
.../main/java/org/apache/camel/resume/Offsets.java | 62 +++++++++++++++
.../java/org/apache/camel/resume/Resumables.java | 91 ++++++++++++++++++++++
32 files changed, 450 insertions(+), 173 deletions(-)
copy components/{camel-couchdb/src/main/java/org/apache/camel/component/couchdb/consumer/CouchDbResumeStrategy.java => camel-file/src/main/java/org/apache/camel/component/file/consumer/FileSetResumeStrategy.java} (76%)
copy components/{camel-couchdb/src/main/java/org/apache/camel/component/couchdb/consumer/CouchDbResumeStrategy.java => camel-file/src/main/java/org/apache/camel/component/file/consumer/GenericFileResumable.java} (76%)
copy components/{camel-couchdb/src/main/java/org/apache/camel/component/couchdb/consumer/CouchDbResumeStrategy.java => camel-file/src/main/java/org/apache/camel/component/file/consumer/GenericFileResumeStrategy.java} (76%)
copy components/{camel-couchdb/src/main/java/org/apache/camel/component/couchdb/consumer/LatestUpdateSequenceResumeStrategy.java => camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/KafkaOffset.java} (59%)
copy components/{camel-couchdb/src/main/java/org/apache/camel/component/couchdb/consumer/CouchDbResumable.java => camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/KafkaResumable.java} (56%)
copy components/camel-couchdb/src/main/java/org/apache/camel/component/couchdb/consumer/CouchDbResumeStrategy.java => core/camel-api/src/main/java/org/apache/camel/Offset.java (77%)
create mode 100644 core/camel-api/src/main/java/org/apache/camel/ResumableSet.java
copy core/camel-api/src/main/java/org/apache/camel/{Resumable.java => UpdatableConsumerResumeStrategy.java} (57%)
create mode 100644 core/camel-support/src/main/java/org/apache/camel/resume/Offsets.java
create mode 100644 core/camel-support/src/main/java/org/apache/camel/resume/Resumables.java