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 2024/05/09 14:46:59 UTC
(camel) branch camel-4.4.x updated: CAMEL-20752: camel-saga - NPE in compesating
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 <cl...@gmail.com>
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);
+ }
}