You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by or...@apache.org on 2022/06/24 08:36:38 UTC
[camel] branch main updated (7d1a829719e -> 85022df1a85)
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
from 7d1a829719e (chores) camel-support: removed unused parameters
new 80f0295def9 (chores) camel-atmos: cleanup setting up the exchange
new 85022df1a85 (chores) camel-atmos: avoid using a StringBuffer
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../component/atmos/dto/AtmosFileUploadResult.java | 24 +++++++++-------------
1 file changed, 10 insertions(+), 14 deletions(-)
[camel] 02/02: (chores) camel-atmos: avoid using a StringBuffer
Posted by or...@apache.org.
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 85022df1a858dc7459702119877a99e8c18a086d
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Fri Jun 24 09:33:56 2022 +0200
(chores) camel-atmos: avoid using a StringBuffer
---
.../apache/camel/component/atmos/dto/AtmosFileUploadResult.java | 9 ++++-----
1 file changed, 4 insertions(+), 5 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 a59699d5443..b5c14b838bb 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
@@ -17,6 +17,7 @@
package org.apache.camel.component.atmos.dto;
import java.util.Map;
+import java.util.stream.Collectors;
import org.apache.camel.Exchange;
import org.apache.camel.component.atmos.util.AtmosConstants;
@@ -44,11 +45,9 @@ public class AtmosFileUploadResult extends AtmosResult {
});
} else {
- StringBuffer pathsExtracted = new StringBuffer();
- for (Map.Entry<String, AtmosResultCode> entry : map.entrySet()) {
- pathsExtracted.append(entry.getKey() + "\n");
- }
- exchange.getIn().setHeader(AtmosConstants.UPLOADED_FILES, pathsExtracted.toString());
+ final String pathsExtracted = map.keySet().stream().collect(Collectors.joining("\n"));
+
+ exchange.getIn().setHeader(AtmosConstants.UPLOADED_FILES, pathsExtracted);
exchange.getIn().setBody(map);
}
}
[camel] 01/02: (chores) camel-atmos: cleanup setting up the exchange
Posted by or...@apache.org.
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 <an...@gmail.com>
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()) {