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 c5f96dff5488f6a577a6640c6ce60b786ce4c477 Author: Claus Ibsen <[email protected]> AuthorDate: Mon Jan 27 15:24:52 2020 +0100 CAMEL-14354: camel-core optimize --- .../apache/camel/impl/engine/DefaultUnitOfWork.java | 19 +++++++++---------- 1 file changed, 9 insertions(+), 10 deletions(-) diff --git a/core/camel-base/src/main/java/org/apache/camel/impl/engine/DefaultUnitOfWork.java b/core/camel-base/src/main/java/org/apache/camel/impl/engine/DefaultUnitOfWork.java index 8218d4f..030f1c3 100644 --- a/core/camel-base/src/main/java/org/apache/camel/impl/engine/DefaultUnitOfWork.java +++ b/core/camel-base/src/main/java/org/apache/camel/impl/engine/DefaultUnitOfWork.java @@ -16,11 +16,9 @@ */ package org.apache.camel.impl.engine; -import java.util.ArrayDeque; import java.util.ArrayList; -import java.util.Deque; +import java.util.HashSet; import java.util.Iterator; -import java.util.LinkedHashSet; import java.util.List; import java.util.Set; import java.util.function.Predicate; @@ -58,24 +56,24 @@ public class DefaultUnitOfWork implements UnitOfWork, Service { // SubUnitOfWork into a general parent/child unit of work concept. However this // requires API changes and thus is best kept for future Camel work - private String id; private final Exchange exchange; - private final Logger log; private final CamelContext context; private final InflightRepository inflightRepository; + private Logger log; private RouteContext prevRouteContext; private RouteContext routeContext; private List<Synchronization> synchronizations; private Message originalInMessage; private Set<Object> transactedBy; - public DefaultUnitOfWork(Exchange exchange) { - this(exchange, LOG); + protected DefaultUnitOfWork(Exchange exchange, Logger logger) { + this(exchange); + this.log = logger; } - protected DefaultUnitOfWork(Exchange exchange, Logger logger) { + public DefaultUnitOfWork(Exchange exchange) { this.exchange = exchange; - this.log = logger; + this.log = LOG; if (log.isTraceEnabled()) { log.trace("UnitOfWork created for ExchangeId: {} with {}", exchange.getExchangeId(), exchange); } @@ -319,7 +317,8 @@ public class DefaultUnitOfWork implements UnitOfWork, Service { private Set<Object> getTransactedBy() { if (transactedBy == null) { - transactedBy = new LinkedHashSet<>(); + // no need to take up so much space so use a lille set + transactedBy = new HashSet<>(4); } return transactedBy; }
