You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by or...@apache.org on 2022/03/01 18:24:18 UTC
[camel] 12/16: CAMEL-155623: implement getters on the ResumeAware
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 <an...@gmail.com>
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();
}