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:21 UTC
[camel] 15/16: CAMEL-15562: minor adjustments to the resume API log messages
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 519f6ab86649b671a9c719b7d826ead9f5b4d00a
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Tue Mar 1 12:59:13 2022 +0100
CAMEL-15562: minor adjustments to the resume API log messages
---
.../org/apache/camel/processor/resume/ResumableCompletion.java | 2 +-
.../java/org/apache/camel/processor/resume/ResumableProcessor.java | 7 ++++++-
2 files changed, 7 insertions(+), 2 deletions(-)
diff --git a/core/camel-core-processor/src/main/java/org/apache/camel/processor/resume/ResumableCompletion.java b/core/camel-core-processor/src/main/java/org/apache/camel/processor/resume/ResumableCompletion.java
index 62dba42..c7e712f 100644
--- a/core/camel-core-processor/src/main/java/org/apache/camel/processor/resume/ResumableCompletion.java
+++ b/core/camel-core-processor/src/main/java/org/apache/camel/processor/resume/ResumableCompletion.java
@@ -49,7 +49,7 @@ public class ResumableCompletion implements Synchronization {
LOG.error("Unable to update the offset: {}", e.getMessage(), e);
}
} else {
- LOG.warn("Cannot perform an offset update because the strategy is not updatable");
+ LOG.debug("Cannot perform an offset update because the strategy is not updatable");
}
}
}
diff --git a/core/camel-core-processor/src/main/java/org/apache/camel/processor/resume/ResumableProcessor.java b/core/camel-core-processor/src/main/java/org/apache/camel/processor/resume/ResumableProcessor.java
index 4c64a1c..ebc4d78 100644
--- a/core/camel-core-processor/src/main/java/org/apache/camel/processor/resume/ResumableProcessor.java
+++ b/core/camel-core-processor/src/main/java/org/apache/camel/processor/resume/ResumableProcessor.java
@@ -76,8 +76,13 @@ public class ResumableProcessor extends AsyncProcessorSupport
public ResumableProcessor(ResumeStrategy resumeStrategy, Processor processor) {
this.resumeStrategy = Objects.requireNonNull(resumeStrategy);
this.processor = AsyncProcessorConverterHelper.convert(processor);
+ }
+
+ @Override
+ protected void doStart() throws Exception {
+ LOG.debug("Enabling the resumable strategy of type: {}", resumeStrategy.getClass().getSimpleName());
- LOG.info("Enabling the resumable strategy of type: {}", resumeStrategy.getClass().getSimpleName());
+ super.doStart();
}
@Override