[camel] 05/12: CAMEL-15105: move the history node source 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 8ebfb88e57de4c6e759a98d89395a2ba672135dc
Author: Otavio Rodolfo Piske <angusyo...@gmail.com>
AuthorDate: Wed Apr 26 18:35:29 2023 +0200

    CAMEL-15105: move the history node source flag to the extension
---
 .../src/main/java/org/apache/camel/support/AbstractExchange.java     | 1 -
 .../java/org/apache/camel/support/ExtendedExchangeExtension.java     | 5 +++--
 2 files changed, 3 insertions(+), 3 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 31da48d4ed9..a19e5da1c60 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
@@ -71,7 +71,6 @@ class AbstractExchange implements Exchange {
     List<Synchronization> onCompletions;
     Boolean externalRedelivered;
     String historyNodeLabel;
-    String historyNodeSource;
     boolean transacted;
     boolean routeStop;
     boolean rollbackOnly;
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 10696473c67..ab1f93d6586 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
@@ -37,6 +37,7 @@ public class ExtendedExchangeExtension implements 
ExchangeExtension {
     private boolean streamCacheDisabled;
     private boolean redeliveryExhausted;
     private String historyNodeId;
+    private String historyNodeSource;
 
     ExtendedExchangeExtension(AbstractExchange exchange) {
         this.exchange = exchange;
@@ -147,12 +148,12 @@ public class ExtendedExchangeExtension implements 
ExchangeExtension {
 
     @Override
     public String getHistoryNodeSource() {
-        return this.exchange.historyNodeSource;
+        return this.historyNodeSource;
     }
 
     @Override
     public void setHistoryNodeSource(String historyNodeSource) {
-        this.exchange.historyNodeSource = historyNodeSource;
+        this.historyNodeSource = historyNodeSource;
     }
 
     @Override