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
commit db69991c06744b3217f561ae11767669b75dd6c7 Author: Otavio Rodolfo Piske <angusyo...@gmail.com> AuthorDate: Tue Nov 22 18:36:50 2022 +0100 CAMEL-15105: convert setting notify events in camel-cdi and camel-management --- .../main/java/org/apache/camel/management/PublishEventNotifier.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/core/camel-management/src/main/java/org/apache/camel/management/PublishEventNotifier.java b/core/camel-management/src/main/java/org/apache/camel/management/PublishEventNotifier.java index 93489442f5e..4193ef54009 100644 --- a/core/camel-management/src/main/java/org/apache/camel/management/PublishEventNotifier.java +++ b/core/camel-management/src/main/java/org/apache/camel/management/PublishEventNotifier.java @@ -22,7 +22,6 @@ import org.apache.camel.CamelContext; import org.apache.camel.CamelContextAware; import org.apache.camel.Endpoint; import org.apache.camel.Exchange; -import org.apache.camel.ExtendedExchange; import org.apache.camel.Producer; import org.apache.camel.spi.CamelEvent; import org.apache.camel.support.EventNotifierSupport; @@ -69,12 +68,12 @@ public class PublishEventNotifier extends EventNotifierSupport implements CamelC // make sure we don't send out events for this as well // mark exchange as being published to event, to prevent creating new events // for this as well (causing a endless flood of events) - exchange.adapt(ExtendedExchange.class).setNotifyEvent(true); + exchange.getExchangeExtension().setNotifyEvent(true); try { producer.process(exchange); } finally { // and remove it when its done - exchange.adapt(ExtendedExchange.class).setNotifyEvent(false); + exchange.getExchangeExtension().setNotifyEvent(false); } }