This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git
commit 240f68ae3a28eb24b7134d0cecdbd021ea3a8921 Author: Claus Ibsen <claus.ib...@gmail.com> AuthorDate: Fri Mar 5 15:36:14 2021 +0100 do not init in constructor --- .../camel/oaipmh/component/OAIPMHConsumer.java | 30 +++++++++++++--------- 1 file changed, 18 insertions(+), 12 deletions(-) diff --git a/components/camel-oaipmh/src/main/java/org/apache/camel/oaipmh/component/OAIPMHConsumer.java b/components/camel-oaipmh/src/main/java/org/apache/camel/oaipmh/component/OAIPMHConsumer.java index fa83a7b..39b66ed 100644 --- a/components/camel-oaipmh/src/main/java/org/apache/camel/oaipmh/component/OAIPMHConsumer.java +++ b/components/camel-oaipmh/src/main/java/org/apache/camel/oaipmh/component/OAIPMHConsumer.java @@ -20,30 +20,36 @@ import org.apache.camel.Processor; import org.apache.camel.oaipmh.handler.ConsumerResponseHandler; import org.apache.camel.oaipmh.handler.Harvester; import org.apache.camel.support.DefaultScheduledPollConsumer; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; /** * The OAIPMH consumer. */ public class OAIPMHConsumer extends DefaultScheduledPollConsumer { - private static final Logger LOG = LoggerFactory.getLogger(OAIPMHConsumer.class); - private Harvester harvester; public OAIPMHConsumer(OAIPMHEndpoint endpoint, Processor processor) throws Exception { super(endpoint, processor); + } + + @Override + public OAIPMHEndpoint getEndpoint() { + return (OAIPMHEndpoint) super.getEndpoint(); + } + + @Override + protected void doInit() throws Exception { + super.doInit(); this.harvester = new Harvester( new ConsumerResponseHandler(this), - endpoint.getUrl(), - endpoint.getVerb(), - endpoint.getMetadataPrefix(), - endpoint.getUntil(), - endpoint.getFrom(), - endpoint.getSet(), - endpoint.getIdentifier()); - if (endpoint.isIgnoreSSLWarnings()) { + getEndpoint().getUrl(), + getEndpoint().getVerb(), + getEndpoint().getMetadataPrefix(), + getEndpoint().getUntil(), + getEndpoint().getFrom(), + getEndpoint().getSet(), + getEndpoint().getIdentifier()); + if (getEndpoint().isIgnoreSSLWarnings()) { this.harvester.getHttpClient().setIgnoreSSLWarnings(true); } }