[camel] 02/02: CAMEL-18739 fix by handing over the completion to the original exchange (#8795)

[davsclaus]

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

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

commit 6acb68e1adf325cd069c8a5c12f99124d8dc54dd
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Wed Dec 14 18:59:13 2022 +0100

    CAMEL-18739 fix by handing over the completion to the original exchange 
(#8795)
---
 .../camel/processor/aggregate/tarfile/TarAggregationStrategy.java | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git 
a/components/camel-tarfile/src/main/java/org/apache/camel/processor/aggregate/tarfile/TarAggregationStrategy.java
 
b/components/camel-tarfile/src/main/java/org/apache/camel/processor/aggregate/tarfile/TarAggregationStrategy.java
index 82b97315aef..76710b322dd 100644
--- 
a/components/camel-tarfile/src/main/java/org/apache/camel/processor/aggregate/tarfile/TarAggregationStrategy.java
+++ 
b/components/camel-tarfile/src/main/java/org/apache/camel/processor/aggregate/tarfile/TarAggregationStrategy.java
@@ -197,6 +197,14 @@ public class TarAggregationStrategy implements 
AggregationStrategy {
         return answer;
     }
 
+    @Override
+    public void onCompletion(Exchange exchange, Exchange inputExchange) {
+        // this aggregation strategy added onCompletion which we should 
handover when we are complete
+        if (inputExchange != null) {
+            
exchange.adapt(ExtendedExchange.class).handoverCompletions(inputExchange);
+        }
+    }
+
     private void addFileToTar(File source, File file, String fileName) throws 
IOException, ArchiveException {
         File tmpTar = Files.createTempFile(parentDir.toPath(), 
source.getName(), null).toFile();
         tmpTar.delete();