[camel] 07/12: CAMEL-15105: move the transacted flag to the extension

[orpiske]

This is an automated email from the ASF dual-hosted git repository.

orpiske pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git

commit 7b0ff81957b01736ae293d7a9b91fded8db800f9
Author: Otavio Rodolfo Piske <angusyo...@gmail.com>
AuthorDate: Wed Apr 26 18:40:37 2023 +0200

    CAMEL-15105: move the transacted flag to the extension
---
 .../src/main/java/org/apache/camel/support/AbstractExchange.java   | 3 +--
 .../main/java/org/apache/camel/support/DefaultPooledExchange.java  | 2 +-
 .../java/org/apache/camel/support/ExtendedExchangeExtension.java   | 7 ++++++-
 3 files changed, 8 insertions(+), 4 deletions(-)

diff --git 
a/core/camel-support/src/main/java/org/apache/camel/support/AbstractExchange.java
 
b/core/camel-support/src/main/java/org/apache/camel/support/AbstractExchange.java
index 60c8299e9a4..f26711aa6f7 100644
--- 
a/core/camel-support/src/main/java/org/apache/camel/support/AbstractExchange.java
+++ 
b/core/camel-support/src/main/java/org/apache/camel/support/AbstractExchange.java
@@ -70,7 +70,6 @@ class AbstractExchange implements Exchange {
     ExchangePattern pattern;
     List<Synchronization> onCompletions;
     Boolean externalRedelivered;
-    boolean transacted;
     boolean routeStop;
     boolean rollbackOnly;
     boolean rollbackOnlyLast;
@@ -630,7 +629,7 @@ class AbstractExchange implements Exchange {
 
     @Override
     public boolean isTransacted() {
-        return transacted;
+        return privateExtension.isTransacted();
     }
 
     @Override
diff --git 
a/core/camel-support/src/main/java/org/apache/camel/support/DefaultPooledExchange.java
 
b/core/camel-support/src/main/java/org/apache/camel/support/DefaultPooledExchange.java
index 00bbbebfe2f..d80972babd7 100644
--- 
a/core/camel-support/src/main/java/org/apache/camel/support/DefaultPooledExchange.java
+++ 
b/core/camel-support/src/main/java/org/apache/camel/support/DefaultPooledExchange.java
@@ -112,7 +112,7 @@ public final class DefaultPooledExchange extends 
AbstractExchange implements Poo
             this.externalRedelivered = null;
             getExchangeExtension().setHistoryNodeId(null);
             getExchangeExtension().setHistoryNodeLabel(null);
-            this.transacted = false;
+            getExchangeExtension().setTransacted(false);
             this.routeStop = false;
             this.rollbackOnly = false;
             this.rollbackOnlyLast = false;
diff --git 
a/core/camel-support/src/main/java/org/apache/camel/support/ExtendedExchangeExtension.java
 
b/core/camel-support/src/main/java/org/apache/camel/support/ExtendedExchangeExtension.java
index b59fb811e28..baf4aece5ac 100644
--- 
a/core/camel-support/src/main/java/org/apache/camel/support/ExtendedExchangeExtension.java
+++ 
b/core/camel-support/src/main/java/org/apache/camel/support/ExtendedExchangeExtension.java
@@ -39,6 +39,7 @@ public class ExtendedExchangeExtension implements 
ExchangeExtension {
     private String historyNodeId;
     private String historyNodeSource;
     private String historyNodeLabel;
+    private boolean transacted;
 
     ExtendedExchangeExtension(AbstractExchange exchange) {
         this.exchange = exchange;
@@ -189,7 +190,11 @@ public class ExtendedExchangeExtension implements 
ExchangeExtension {
 
     @Override
     public void setTransacted(boolean transacted) {
-        this.exchange.transacted = transacted;
+        this.transacted = transacted;
+    }
+
+    public boolean isTransacted() {
+        return transacted;
     }
 
     @Override