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 919aeef41c0 CAMEL-20752: camel-saga - NPE in compesating
919aeef41c0 is described below

commit 919aeef41c0c4e76dec00feec67b9b074465b354
Author: Claus Ibsen <[email protected]>
AuthorDate: Thu May 9 16:46:05 2024 +0200

    CAMEL-20752: camel-saga - NPE in compesating
---
 .../java/org/apache/camel/processor/saga/SagaProcessor.java  | 12 ++++++++++++
 1 file changed, 12 insertions(+)

diff --git 
a/core/camel-core-processor/src/main/java/org/apache/camel/processor/saga/SagaProcessor.java
 
b/core/camel-core-processor/src/main/java/org/apache/camel/processor/saga/SagaProcessor.java
index 277299bcc72..1256720c820 100644
--- 
a/core/camel-core-processor/src/main/java/org/apache/camel/processor/saga/SagaProcessor.java
+++ 
b/core/camel-core-processor/src/main/java/org/apache/camel/processor/saga/SagaProcessor.java
@@ -29,6 +29,7 @@ import org.apache.camel.saga.CamelSagaStep;
 import org.apache.camel.spi.IdAware;
 import org.apache.camel.spi.RouteIdAware;
 import org.apache.camel.support.processor.DelegateAsyncProcessor;
+import org.apache.camel.support.service.ServiceHelper;
 import org.apache.camel.util.ObjectHelper;
 
 /**
@@ -152,4 +153,15 @@ public abstract class SagaProcessor extends 
DelegateAsyncProcessor implements Tr
         }
     }
 
+    @Override
+    protected void doStart() throws Exception {
+        super.doStart();
+        ServiceHelper.startService(sagaService);
+    }
+
+    @Override
+    protected void doStop() throws Exception {
+        super.doStop();
+        ServiceHelper.stopService(sagaService);
+    }
 }

Reply via email to