This is an automated email from the ASF dual-hosted git repository. nferraro pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git
commit 5d4ee623587081f9c6f5eb151f23eba67945e346 Author: Nicola Ferraro <[email protected]> AuthorDate: Mon Jan 13 10:24:23 2020 +0100 CAMEL-14385: fix configure consumer --- .../src/main/java/org/apache/camel/component/cron/CronEndpoint.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/components/camel-cron/src/main/java/org/apache/camel/component/cron/CronEndpoint.java b/components/camel-cron/src/main/java/org/apache/camel/component/cron/CronEndpoint.java index d1ed013..41dbcec 100644 --- a/components/camel-cron/src/main/java/org/apache/camel/component/cron/CronEndpoint.java +++ b/components/camel-cron/src/main/java/org/apache/camel/component/cron/CronEndpoint.java @@ -55,7 +55,9 @@ public class CronEndpoint extends DefaultEndpoint implements DelegateEndpoint { @Override public Consumer createConsumer(Processor processor) throws Exception { - return delegate.createConsumer(processor); + Consumer consumer = delegate.createConsumer(processor); + configureConsumer(consumer); + return consumer; } public CamelCronConfiguration getConfiguration() {
