Repository: incubator-unomi Updated Branches: refs/heads/master fde293249 -> bb96940da
UNOMI-102 : Line separator must be a char not a string Project: http://git-wip-us.apache.org/repos/asf/incubator-unomi/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-unomi/commit/bb96940d Tree: http://git-wip-us.apache.org/repos/asf/incubator-unomi/tree/bb96940d Diff: http://git-wip-us.apache.org/repos/asf/incubator-unomi/diff/bb96940d Branch: refs/heads/master Commit: bb96940dabbd90481594f84774a06b16f0f402c7 Parents: fde2932 Author: Abdelkader Midani <[email protected]> Authored: Thu Jul 6 17:40:22 2017 +0200 Committer: Abdelkader Midani <[email protected]> Committed: Thu Jul 6 17:40:22 2017 +0200 ---------------------------------------------------------------------- .../router/core/strategy/StringLinesAggregationStrategy.java | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-unomi/blob/bb96940d/extensions/router/router-core/src/main/java/org/apache/unomi/router/core/strategy/StringLinesAggregationStrategy.java ---------------------------------------------------------------------- diff --git a/extensions/router/router-core/src/main/java/org/apache/unomi/router/core/strategy/StringLinesAggregationStrategy.java b/extensions/router/router-core/src/main/java/org/apache/unomi/router/core/strategy/StringLinesAggregationStrategy.java index 5a69001..d01859f 100644 --- a/extensions/router/router-core/src/main/java/org/apache/unomi/router/core/strategy/StringLinesAggregationStrategy.java +++ b/extensions/router/router-core/src/main/java/org/apache/unomi/router/core/strategy/StringLinesAggregationStrategy.java @@ -19,6 +19,7 @@ package org.apache.unomi.router.core.strategy; import org.apache.camel.Exchange; import org.apache.camel.processor.aggregate.AggregationStrategy; import org.apache.unomi.router.api.ExportConfiguration; +import org.apache.unomi.router.api.RouterUtils; /** * Created by amidani on 29/06/2017. @@ -29,9 +30,11 @@ public class StringLinesAggregationStrategy implements AggregationStrategy { Object newBody = newExchange.getIn().getBody(String.class); String lineSeparator = newExchange.getIn().getHeader("exportConfig", ExportConfiguration.class).getLineSeparator(); if (oldExchange != null) { - String fileContent = oldExchange.getIn().getBody(String.class); + StringBuilder fileContent = new StringBuilder(); + fileContent.append(oldExchange.getIn().getBody(String.class)); + fileContent.append(RouterUtils.getCharFromLineSeparator(lineSeparator)); + fileContent.append(newBody); - fileContent += lineSeparator + newBody; oldExchange.getIn().setBody(fileContent); return oldExchange; } else {
