[camel] branch master updated: CAMEL-14354: camel-core optimize

[davsclaus]

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


The following commit(s) were added to refs/heads/master by this push:
     new 25cd949  CAMEL-14354: camel-core optimize
25cd949 is described below

commit 25cd949b7f0557bcdddf10afabcfdee6b2aff0c5
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Sat Jan 25 22:38:53 2020 +0100

    CAMEL-14354: camel-core optimize
---
 .../org/apache/camel/processor/CamelInternalProcessor.java     | 10 ++++++----
 .../main/java/org/apache/camel/support/UnitOfWorkHelper.java   |  3 ++-
 2 files changed, 8 insertions(+), 5 deletions(-)

diff --git 
a/core/camel-base/src/main/java/org/apache/camel/processor/CamelInternalProcessor.java
 
b/core/camel-base/src/main/java/org/apache/camel/processor/CamelInternalProcessor.java
index c0269fb..8c7dcb1 100644
--- 
a/core/camel-base/src/main/java/org/apache/camel/processor/CamelInternalProcessor.java
+++ 
b/core/camel-base/src/main/java/org/apache/camel/processor/CamelInternalProcessor.java
@@ -606,7 +606,8 @@ public class CamelInternalProcessor extends 
DelegateAsyncProcessor {
                 if (routeId == null) {
                     this.routeId = routeContext.getRouteId();
                 }
-                exchange.adapt(ExtendedExchange.class).setFromRouteId(routeId);
+                ExtendedExchange ee = (ExtendedExchange) exchange;
+                ee.setFromRouteId(routeId);
             }
 
             // only return UnitOfWork if we created a new as then its us that 
handle the lifecycle to done the created UoW
@@ -616,7 +617,8 @@ public class CamelInternalProcessor extends 
DelegateAsyncProcessor {
                 // If there is no existing UoW, then we should start one and
                 // terminate it once processing is completed for the exchange.
                 created = createUnitOfWork(exchange);
-                exchange.adapt(ExtendedExchange.class).setUnitOfWork(created);
+                ExtendedExchange ee = (ExtendedExchange) exchange;
+                ee.setUnitOfWork(created);
                 created.start();
             }
 
@@ -740,7 +742,7 @@ public class CamelInternalProcessor extends 
DelegateAsyncProcessor {
 
         @Override
         public String before(Exchange exchange) throws Exception {
-            ExtendedExchange ee = exchange.adapt(ExtendedExchange.class);
+            ExtendedExchange ee = (ExtendedExchange) exchange;
             ee.setHistoryNodeId(id);
             ee.setHistoryNodeLabel(label);
             return null;
@@ -748,7 +750,7 @@ public class CamelInternalProcessor extends 
DelegateAsyncProcessor {
 
         @Override
         public void after(Exchange exchange, Object data) throws Exception {
-            ExtendedExchange ee = exchange.adapt(ExtendedExchange.class);
+            ExtendedExchange ee = (ExtendedExchange) exchange;
             ee.setHistoryNodeId(null);
             ee.setHistoryNodeLabel(null);
         }
diff --git 
a/core/camel-support/src/main/java/org/apache/camel/support/UnitOfWorkHelper.java
 
b/core/camel-support/src/main/java/org/apache/camel/support/UnitOfWorkHelper.java
index f4881ae..d6405fd 100644
--- 
a/core/camel-support/src/main/java/org/apache/camel/support/UnitOfWorkHelper.java
+++ 
b/core/camel-support/src/main/java/org/apache/camel/support/UnitOfWorkHelper.java
@@ -65,7 +65,8 @@ public final class UnitOfWorkHelper {
         }
 
         // remove uow from exchange as its done
-        exchange.adapt(ExtendedExchange.class).setUnitOfWork(null);
+        ExtendedExchange ee = (ExtendedExchange) exchange;
+        ee.setUnitOfWork(null);
     }
 
     public static void doneSynchronizations(Exchange exchange, 
List<Synchronization> synchronizations, Logger log) {