This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch camel-4.4.x
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/camel-4.4.x by this push:
new 26e3075a960 CAMEL-20752: camel-saga - NPE in compesating
26e3075a960 is described below
commit 26e3075a9600dd5f24cd255236719c905329e731
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);
+ }
}