[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 eafc03b  CAMEL-14354: camel-core optimize
eafc03b is described below

commit eafc03b877526598d5708b79fa77feb754ec3059
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Tue Jan 28 08:19:34 2020 +0100

    CAMEL-14354: camel-core optimize
---
 .../src/main/java/org/apache/camel/cdi/CdiEventConsumer.java         | 5 +++--
 .../java/org/apache/camel/component/undertow/ExchangeHeaders.java    | 2 --
 2 files changed, 3 insertions(+), 4 deletions(-)

diff --git 
a/components/camel-cdi/src/main/java/org/apache/camel/cdi/CdiEventConsumer.java 
b/components/camel-cdi/src/main/java/org/apache/camel/cdi/CdiEventConsumer.java
index fca2d6e..393b13f 100644
--- 
a/components/camel-cdi/src/main/java/org/apache/camel/cdi/CdiEventConsumer.java
+++ 
b/components/camel-cdi/src/main/java/org/apache/camel/cdi/CdiEventConsumer.java
@@ -17,6 +17,7 @@
 package org.apache.camel.cdi;
 
 import org.apache.camel.Exchange;
+import org.apache.camel.ExtendedExchange;
 import org.apache.camel.Processor;
 import org.apache.camel.RuntimeExchangeException;
 import org.apache.camel.spi.CamelEvent.ExchangeEvent;
@@ -56,7 +57,7 @@ final class CdiEventConsumer<T> extends DefaultConsumer {
 
         // Avoid infinite loop of exchange events
         if (event instanceof ExchangeEvent) {
-            exchange.setProperty(Exchange.NOTIFY_EVENT, Boolean.TRUE);
+            exchange.adapt(ExtendedExchange.class).setNotifyEvent(true);
         }
         try {
             getProcessor().process(exchange);
@@ -64,7 +65,7 @@ final class CdiEventConsumer<T> extends DefaultConsumer {
             throw new RuntimeExchangeException("Error while processing CDI 
event", exchange, cause);
         } finally {
             if (event instanceof ExchangeEvent) {
-                exchange.setProperty(Exchange.NOTIFY_EVENT, Boolean.FALSE);
+                exchange.adapt(ExtendedExchange.class).setNotifyEvent(false);
             }
         }
     }
diff --git 
a/components/camel-undertow/src/main/java/org/apache/camel/component/undertow/ExchangeHeaders.java
 
b/components/camel-undertow/src/main/java/org/apache/camel/component/undertow/ExchangeHeaders.java
index ad3d373..05e47b1 100644
--- 
a/components/camel-undertow/src/main/java/org/apache/camel/component/undertow/ExchangeHeaders.java
+++ 
b/components/camel-undertow/src/main/java/org/apache/camel/component/undertow/ExchangeHeaders.java
@@ -115,8 +115,6 @@ public final class ExchangeHeaders {
     public static final HttpString MULTICAST_INDEX = new 
HttpString("CamelMulticastIndex");
     public static final HttpString MULTICAST_COMPLETE = new 
HttpString("CamelMulticastComplete");
 
-    public static final HttpString NOTIFY_EVENT = new 
HttpString("CamelNotifyEvent");
-
     public static final HttpString ON_COMPLETION = new 
HttpString("CamelOnCompletion");
     public static final HttpString OVERRULE_FILE_NAME = new 
HttpString("CamelOverruleFileName");