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