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 2023/08/22 17:55:31 UTC
[camel] branch main updated: (chores) camel-base-engine: invert constructor order so we can use the logger as final (#11176)
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
The following commit(s) were added to refs/heads/main by this push:
new 2a457bdc052 (chores) camel-base-engine: invert constructor order so we can use the logger as final (#11176)
2a457bdc052 is described below
commit 2a457bdc052340331f43f0693930c9b9a9328f73
Author: Otavio Rodolfo Piske <or...@users.noreply.github.com>
AuthorDate: Tue Aug 22 19:55:24 2023 +0200
(chores) camel-base-engine: invert constructor order so we can use the logger as final (#11176)
---
.../org/apache/camel/impl/engine/DefaultUnitOfWork.java | 17 +++++++++--------
1 file changed, 9 insertions(+), 8 deletions(-)
diff --git a/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/DefaultUnitOfWork.java b/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/DefaultUnitOfWork.java
index dbbf1af44ad..fb75e66a6c7 100644
--- a/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/DefaultUnitOfWork.java
+++ b/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/DefaultUnitOfWork.java
@@ -57,7 +57,7 @@ public class DefaultUnitOfWork implements UnitOfWork {
private final CamelContext context;
private final Deque<Route> routes = new ArrayDeque<>(8);
- private Logger log;
+ private final Logger log;
private Exchange exchange;
private List<Synchronization> synchronizations;
private Message originalInMessage;
@@ -70,21 +70,22 @@ public class DefaultUnitOfWork implements UnitOfWork {
protected DefaultUnitOfWork(Exchange exchange, Logger logger, InflightRepository inflightRepository,
boolean allowUseOriginalMessage, boolean useBreadcrumb) {
- this(exchange, inflightRepository, allowUseOriginalMessage, useBreadcrumb);
- this.log = logger;
- }
-
- public DefaultUnitOfWork(Exchange exchange, InflightRepository inflightRepository, boolean allowUseOriginalMessage,
- boolean useBreadcrumb) {
- this.log = LOG;
this.allowUseOriginalMessage = allowUseOriginalMessage;
this.useBreadcrumb = useBreadcrumb;
this.context = exchange.getContext();
this.inflightRepository = inflightRepository;
this.streamCachingStrategy = exchange.getContext().getStreamCachingStrategy();
+ this.log = logger;
+
doOnPrepare(exchange);
}
+ public DefaultUnitOfWork(Exchange exchange, InflightRepository inflightRepository, boolean allowUseOriginalMessage,
+ boolean useBreadcrumb) {
+ this(exchange, LOG, inflightRepository, allowUseOriginalMessage, useBreadcrumb);
+
+ }
+
UnitOfWork newInstance(Exchange exchange) {
return new DefaultUnitOfWork(exchange, inflightRepository, allowUseOriginalMessage, useBreadcrumb);
}