This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push: new 11076e47371 Defer lookup vertx to doStart 11076e47371 is described below commit 11076e473714980d87a033369cc2567c9fbd19a3 Author: Claus Ibsen <claus.ib...@gmail.com> AuthorDate: Sun Apr 2 14:33:52 2023 +0200 Defer lookup vertx to doStart --- .../org/apache/camel/reactive/vertx/VertXThreadPoolFactory.java | 9 ++------- 1 file changed, 2 insertions(+), 7 deletions(-) diff --git a/components/camel-threadpoolfactory-vertx/src/main/java/org/apache/camel/reactive/vertx/VertXThreadPoolFactory.java b/components/camel-threadpoolfactory-vertx/src/main/java/org/apache/camel/reactive/vertx/VertXThreadPoolFactory.java index e0c1d5801cd..5dd384c150e 100644 --- a/components/camel-threadpoolfactory-vertx/src/main/java/org/apache/camel/reactive/vertx/VertXThreadPoolFactory.java +++ b/components/camel-threadpoolfactory-vertx/src/main/java/org/apache/camel/reactive/vertx/VertXThreadPoolFactory.java @@ -57,19 +57,14 @@ public class VertXThreadPoolFactory extends DefaultThreadPoolFactory implements } @Override - protected void doInit() throws Exception { - super.doInit(); + protected void doStart() throws Exception { + super.doStart(); if (vertx == null) { Set<Vertx> set = getCamelContext().getRegistry().findByType(Vertx.class); if (set.size() == 1) { vertx = set.iterator().next(); } } - } - - @Override - protected void doStart() throws Exception { - super.doStart(); if (vertx == null) { throw new IllegalArgumentException("VertX instance must be configured."); }