You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2026/07/16 09:19:16 UTC
(camel) branch main updated: CAMEL-24099: camel-bean - Use ServiceHelper for BeanProcessor lifecycle
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 <cl...@gmail.com>
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 <no...@anthropic.com>
---
.../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