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 <[email protected]> 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
