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.git
commit de8389ccc863928126bcc85b0123275bd3e28770 Author: Otavio Rodolfo Piske <[email protected]> AuthorDate: Tue Mar 1 10:44:03 2022 +0100 CAMEL-155623: implement getters on the ResumeAware This ensures compliance with others xxxAware classes --- .../apache/camel/component/couchdb/CouchDbConsumer.java | 1 + .../org/apache/camel/component/file/FileConsumer.java | 6 ++++++ .../org/apache/camel/component/kafka/KafkaConsumer.java | 1 + .../src/main/java/org/apache/camel/ResumeAware.java | 15 +++++++++++++++ 4 files changed, 23 insertions(+) diff --git a/components/camel-couchdb/src/main/java/org/apache/camel/component/couchdb/CouchDbConsumer.java b/components/camel-couchdb/src/main/java/org/apache/camel/component/couchdb/CouchDbConsumer.java index 1a22bf3..615823c 100644 --- a/components/camel-couchdb/src/main/java/org/apache/camel/component/couchdb/CouchDbConsumer.java +++ b/components/camel-couchdb/src/main/java/org/apache/camel/component/couchdb/CouchDbConsumer.java @@ -44,6 +44,7 @@ public class CouchDbConsumer extends DefaultConsumer implements ResumeAware<Couc this.resumeStrategy = resumeStrategy; } + @Override public CouchDbResumeStrategy getResumeStrategy() { return resumeStrategy; } diff --git a/components/camel-file/src/main/java/org/apache/camel/component/file/FileConsumer.java b/components/camel-file/src/main/java/org/apache/camel/component/file/FileConsumer.java index 1b3ae3b..1f5ca77 100644 --- a/components/camel-file/src/main/java/org/apache/camel/component/file/FileConsumer.java +++ b/components/camel-file/src/main/java/org/apache/camel/component/file/FileConsumer.java @@ -307,7 +307,13 @@ public class FileConsumer extends GenericFileConsumer<File> implements ResumeAwa } @Override + public FileConsumerResumeStrategy getResumeStrategy() { + return resumeStrategy; + } + + @Override public void setResumeStrategy(FileConsumerResumeStrategy resumeStrategy) { this.resumeStrategy = resumeStrategy; } + } diff --git a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConsumer.java b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConsumer.java index eaefec2..692a505 100644 --- a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConsumer.java +++ b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConsumer.java @@ -59,6 +59,7 @@ public class KafkaConsumer extends DefaultConsumer implements ResumeAware<KafkaC this.resumeStrategy = resumeStrategy; } + @Override public KafkaConsumerResumeStrategy getResumeStrategy() { return resumeStrategy; } diff --git a/core/camel-api/src/main/java/org/apache/camel/ResumeAware.java b/core/camel-api/src/main/java/org/apache/camel/ResumeAware.java index a04168f..6ee69db 100644 --- a/core/camel-api/src/main/java/org/apache/camel/ResumeAware.java +++ b/core/camel-api/src/main/java/org/apache/camel/ResumeAware.java @@ -17,7 +17,22 @@ package org.apache.camel; +/** + * An interface to represent an object which wishes to support resume operations using a {@link ResumeStrategy}. + */ public interface ResumeAware<T extends ResumeStrategy> { + /** + * Injects the {@link ResumeStrategy} instance into the object + * + * @param resumeStrategy the resume strategy + */ void setResumeStrategy(T resumeStrategy); + + /** + * Gets the {@link ResumeStrategy} instance + * + * @return the resume strategy + */ + T getResumeStrategy(); }
