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 80f0295def92efe8e79f6f324f3fab73ae407283 Author: Otavio Rodolfo Piske <[email protected]> AuthorDate: Fri Jun 24 09:27:56 2022 +0200 (chores) camel-atmos: cleanup setting up the exchange --- .../camel/component/atmos/dto/AtmosFileUploadResult.java | 15 ++++++--------- 1 file changed, 6 insertions(+), 9 deletions(-) diff --git a/components/camel-atmos/src/main/java/org/apache/camel/component/atmos/dto/AtmosFileUploadResult.java b/components/camel-atmos/src/main/java/org/apache/camel/component/atmos/dto/AtmosFileUploadResult.java index 9b29212da59..a59699d5443 100644 --- a/components/camel-atmos/src/main/java/org/apache/camel/component/atmos/dto/AtmosFileUploadResult.java +++ b/components/camel-atmos/src/main/java/org/apache/camel/component/atmos/dto/AtmosFileUploadResult.java @@ -37,15 +37,12 @@ public class AtmosFileUploadResult extends AtmosResult { public void populateExchange(Exchange exchange) { Map<String, AtmosResultCode> map = (Map<String, AtmosResultCode>) resultEntries; if (map.size() == 1) { - //set info in exchange - String pathExtracted = null; - AtmosResultCode codeExtracted = null; - for (Map.Entry<String, AtmosResultCode> entry : map.entrySet()) { - pathExtracted = entry.getKey(); - codeExtracted = entry.getValue(); - } - exchange.getIn().setHeader(AtmosConstants.UPLOADED_FILE, pathExtracted); - exchange.getIn().setBody(codeExtracted.name()); + //set info in exchange (note: it runs only once) + map.forEach((pathExtracted, codeExtracted) -> { + exchange.getIn().setHeader(AtmosConstants.UPLOADED_FILE, pathExtracted); + exchange.getIn().setBody(codeExtracted.name()); + }); + } else { StringBuffer pathsExtracted = new StringBuffer(); for (Map.Entry<String, AtmosResultCode> entry : map.entrySet()) {
