This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git
commit d739e2544c3ec820eef1801aed86bcaad1c16d39 Author: Claus Ibsen <claus.ib...@gmail.com> AuthorDate: Tue Apr 6 11:48:20 2021 +0200 CAMEL-16457: camel-core - Optimize ExchangeHelper.copyResults - No need to copy message id not in use --- .../component/file/FileConsumerThreadsInProgressIssueTest.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/core/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerThreadsInProgressIssueTest.java b/core/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerThreadsInProgressIssueTest.java index e9286a0..5b53f9f 100644 --- a/core/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerThreadsInProgressIssueTest.java +++ b/core/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerThreadsInProgressIssueTest.java @@ -101,14 +101,14 @@ public class FileConsumerThreadsInProgressIssueTest extends ContextTestSupport { @Override public void process(Exchange exchange) throws Exception { - Integer integer = duplicate.get(exchange.toString()); + Integer integer = duplicate.get(exchange.getExchangeId()); if (integer == null) { - duplicate.put(exchange.toString(), 1); + duplicate.put(exchange.getExchangeId(), 1); } else { integer++; - duplicate.put(exchange.toString(), integer); + duplicate.put(exchange.getExchangeId(), integer); } - log.info("Process called for-" + exchange); + log.info("Process called for-" + exchange.getExchangeId()); Thread.sleep(20); }