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 2a4e4b908d17 CAMEL-24099: camel-bean - Use ServiceHelper for 
BeanProcessor lifecycle
2a4e4b908d17 is described below

commit 2a4e4b908d17901b6ce052a582cba6da0e2559db
Author: Claus Ibsen <[email protected]>
AuthorDate: Thu Jul 16 11:19:10 2026 +0200

    CAMEL-24099: camel-bean - Use ServiceHelper for BeanProcessor lifecycle
    
    Fix BeanProcessor lifecycle delegation to use ServiceHelper instead of
    direct method calls, ensuring the BaseService state machine is properly
    traversed. The key bug was doStop() calling delegate.doStop() (raw
    method), which bypassed state tracking and prevented bean restart.
    
    Closes #24758
    
    Co-Authored-By: Claude Opus 4.6 <[email protected]>
---
 .../main/java/org/apache/camel/component/bean/BeanProcessor.java | 9 +++++----
 1 file changed, 5 insertions(+), 4 deletions(-)

diff --git 
a/components/camel-bean/src/main/java/org/apache/camel/component/bean/BeanProcessor.java
 
b/components/camel-bean/src/main/java/org/apache/camel/component/bean/BeanProcessor.java
index 5d0746e996e9..561d798a2094 100644
--- 
a/components/camel-bean/src/main/java/org/apache/camel/component/bean/BeanProcessor.java
+++ 
b/components/camel-bean/src/main/java/org/apache/camel/component/bean/BeanProcessor.java
@@ -27,6 +27,7 @@ import org.apache.camel.Exchange;
 import org.apache.camel.Processor;
 import org.apache.camel.spi.ErrorHandlerAware;
 import org.apache.camel.spi.IdAware;
+import org.apache.camel.support.service.ServiceHelper;
 import org.apache.camel.support.service.ServiceSupport;
 
 public class BeanProcessor extends ServiceSupport implements AsyncProcessor, 
ErrorHandlerAware, IdAware {
@@ -124,7 +125,7 @@ public class BeanProcessor extends ServiceSupport 
implements AsyncProcessor, Err
 
     @Override
     protected void doInit() throws Exception {
-        delegate.init();
+        ServiceHelper.initService(delegate);
     }
 
     @Override
@@ -139,17 +140,17 @@ public class BeanProcessor extends ServiceSupport 
implements AsyncProcessor, Err
 
     @Override
     protected void doStart() throws Exception {
-        delegate.start();
+        ServiceHelper.startService(delegate);
     }
 
     @Override
     protected void doStop() throws Exception {
-        delegate.doStop();
+        ServiceHelper.stopService(delegate);
     }
 
     @Override
     protected void doShutdown() throws Exception {
-        delegate.shutdown();
+        ServiceHelper.stopAndShutdownService(delegate);
     }
 
     @Override

Reply via email to