diff --git a/components/camel-cdi/src/main/java/org/apache/camel/cdi/CdiCamelExtension.java b/components/camel-cdi/src/main/java/org/apache/camel/cdi/CdiCamelExtension.java index aac4b84807183..d4d87f51d5f56 100644 --- a/components/camel-cdi/src/main/java/org/apache/camel/cdi/CdiCamelExtension.java +++ b/components/camel-cdi/src/main/java/org/apache/camel/cdi/CdiCamelExtension.java @@ -412,7 +412,7 @@ private SyntheticBean camelContextBean(BeanManager manager, Class beanClas private void afterDeploymentValidation(@Observes AfterDeploymentValidation adv, BeanManager manager) { // Send event for Camel CDI configuration - manager.fireEvent(configuration); + manager.getEvent().fire(configuration); configuration.unmodifiable(); Collection contexts = new ArrayList<>(); diff --git a/components/camel-cdi/src/main/java/org/apache/camel/cdi/CdiEventNotifier.java b/components/camel-cdi/src/main/java/org/apache/camel/cdi/CdiEventNotifier.java index f3d7dfe62b04d..80280add12503 100644 --- a/components/camel-cdi/src/main/java/org/apache/camel/cdi/CdiEventNotifier.java +++ b/components/camel-cdi/src/main/java/org/apache/camel/cdi/CdiEventNotifier.java @@ -56,9 +56,9 @@ public void notify(CamelEvent event) { List annotations = new ArrayList<>(); Collections.addAll(annotations, qualifiers); annotations.add(NamedLiteral.of(id)); - manager.fireEvent(event, annotations.toArray(new Annotation[0])); + manager.getEvent().select(annotations.toArray(new Annotation[0])).fire(event); } else { - manager.fireEvent(event, qualifiers); + manager.getEvent().select(qualifiers).fire(event); } }