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 <claus.ib...@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