[camel] 01/03: CAMEL-14354: camel-core - Optimize. Ah okay making the after task static was an expeirment as the classload would load it bootstrap vs load on first use.

[da...@apache.org]

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 f23f9fb4bcb636b9150758e5b58ff0643219371b
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Sun Feb 2 19:22:07 2020 +0100

    CAMEL-14354: camel-core - Optimize. Ah okay making the after task static was an expeirment as the classload would load it bootstrap vs load on first use.
---
 .../org/apache/camel/processor/CamelInternalProcessor.java    | 11 +++--------
 1 file changed, 3 insertions(+), 8 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 84c4ac0..e8f5a60 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
@@ -149,21 +149,16 @@ public class CamelInternalProcessor extends DelegateAsyncProcessor {
     /**
      * Callback task to process the advices after processing.
      */
-    private static final class AsyncAfterTask implements AsyncCallback {
+    private final class AsyncAfterTask implements AsyncCallback {
 
-        private final List<CamelInternalProcessorAdvice<?>> advices;
         private final Object[] states;
         private final Exchange exchange;
         private final AsyncCallback originalCallback;
-        private final ReactiveExecutor reactiveExecutor;
 
-        private AsyncAfterTask(List<CamelInternalProcessorAdvice<?>> advices, Object[] states,
-                               Exchange exchange, AsyncCallback originalCallback, ReactiveExecutor reactiveExecutor) {
-            this.advices = advices;
+        private AsyncAfterTask(Object[] states, Exchange exchange, AsyncCallback originalCallback) {
             this.states = states;
             this.exchange = exchange;
             this.originalCallback = originalCallback;
-            this.reactiveExecutor = reactiveExecutor;
         }
 
         @Override
@@ -256,7 +251,7 @@ public class CamelInternalProcessor extends DelegateAsyncProcessor {
         }
 
         // create internal callback which will execute the advices in reverse order when done
-        AsyncCallback callback = new AsyncAfterTask(advices, states, exchange, originalCallback, reactiveExecutor);
+        AsyncCallback callback = new AsyncAfterTask(states, exchange, originalCallback);
 
         if (exchange.isTransacted()) {
             // must be synchronized for transacted exchanges