This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch camel-4.14.x
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/camel-4.14.x by this push:
new 2fb3b62f6f9d CAMEL-23310: camel-core - Suspend/resume on CamelContext
should reset… (#22542)
2fb3b62f6f9d is described below
commit 2fb3b62f6f9db70797e2cdb97c68e7520ec8c36e
Author: Claus Ibsen <[email protected]>
AuthorDate: Fri Apr 10 12:26:55 2026 +0200
CAMEL-23310: camel-core - Suspend/resume on CamelContext should reset…
(#22542)
* CAMEL-23310: camel-core - Suspend/resume on CamelContext should reset
prepare shutdown flag
---
.../main/java/org/apache/camel/jta/TransactionErrorHandler.java | 7 +++++++
.../camel/processor/errorhandler/RedeliveryErrorHandler.java | 7 +++++++
2 files changed, 14 insertions(+)
diff --git
a/components/camel-jta/src/main/java/org/apache/camel/jta/TransactionErrorHandler.java
b/components/camel-jta/src/main/java/org/apache/camel/jta/TransactionErrorHandler.java
index 2958309726fa..4c86ed9663c5 100644
---
a/components/camel-jta/src/main/java/org/apache/camel/jta/TransactionErrorHandler.java
+++
b/components/camel-jta/src/main/java/org/apache/camel/jta/TransactionErrorHandler.java
@@ -309,6 +309,13 @@ public class TransactionErrorHandler extends
ErrorHandlerSupport
preparingShutdown = false;
}
+ @Override
+ protected void doResume() throws Exception {
+ super.doResume();
+ // reset flag when resuming
+ preparingShutdown = false;
+ }
+
@Override
protected void doStop() throws Exception {
// noop, do not stop any services which we only do when shutting down
diff --git
a/core/camel-core-processor/src/main/java/org/apache/camel/processor/errorhandler/RedeliveryErrorHandler.java
b/core/camel-core-processor/src/main/java/org/apache/camel/processor/errorhandler/RedeliveryErrorHandler.java
index df425f926ae0..8876ea521acd 100644
---
a/core/camel-core-processor/src/main/java/org/apache/camel/processor/errorhandler/RedeliveryErrorHandler.java
+++
b/core/camel-core-processor/src/main/java/org/apache/camel/processor/errorhandler/RedeliveryErrorHandler.java
@@ -1690,6 +1690,13 @@ public abstract class RedeliveryErrorHandler extends
ErrorHandlerSupport
ServiceHelper.startService(taskFactory, output, outputAsync,
deadLetter);
}
+ @Override
+ protected void doResume() throws Exception {
+ super.doResume();
+ // reset flag when resuming
+ preparingShutdown = false;
+ }
+
@Override
protected void doShutdown() throws Exception {
ServiceHelper.stopAndShutdownServices(deadLetter, output, outputAsync,
taskFactory);