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();