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.");
         }

Reply via email to