This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 896c08d99912ddbed796d10fd1ac5d5fe66c6b49
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Tue Oct 19 07:38:22 2021 +0200
CAMEL-17102: camel-core - EventNotifier for
CamelContextInitializing/Initiazed should fire even if the notifier has not
been fully started.
---
.../org/apache/camel/cdi/test/CamelEventNotifierTest.java | 15 +++++++++++++++
1 file changed, 15 insertions(+)
diff --git
a/components/camel-cdi/src/test/java/org/apache/camel/cdi/test/CamelEventNotifierTest.java
b/components/camel-cdi/src/test/java/org/apache/camel/cdi/test/CamelEventNotifierTest.java
index 2f29f62..b6d80bc 100644
---
a/components/camel-cdi/src/test/java/org/apache/camel/cdi/test/CamelEventNotifierTest.java
+++
b/components/camel-cdi/src/test/java/org/apache/camel/cdi/test/CamelEventNotifierTest.java
@@ -31,6 +31,7 @@ import org.apache.camel.cdi.CdiCamelExtension;
import org.apache.camel.cdi.Uri;
import org.apache.camel.cdi.bean.SimpleCamelRoute;
import org.apache.camel.component.mock.MockEndpoint;
+import org.apache.camel.spi.CamelEvent;
import org.apache.camel.spi.CamelEvent.CamelContextStartedEvent;
import org.apache.camel.spi.CamelEvent.CamelContextStartingEvent;
import org.apache.camel.spi.CamelEvent.CamelContextStoppedEvent;
@@ -69,6 +70,14 @@ public class CamelEventNotifierTest {
@ApplicationScoped
private List<Class> firedEvents = new ArrayList<>();
+ private void onCamelContextStartingEvent(@Observes
CamelEvent.CamelContextInitializingEvent event, List<Class> events) {
+ events.add(CamelEvent.CamelContextInitializingEvent.class);
+ }
+
+ private void onCamelContextStartingEvent(@Observes
CamelEvent.CamelContextInitializedEvent event, List<Class> events) {
+ events.add(CamelEvent.CamelContextInitializedEvent.class);
+ }
+
private void onCamelContextStartingEvent(@Observes
CamelContextStartingEvent event, List<Class> events) {
events.add(CamelContextStartingEvent.class);
}
@@ -105,6 +114,8 @@ public class CamelEventNotifierTest {
public void startedCamelContext(List<Class> events) {
assertThat("Events fired are incorrect!", events,
contains(
+ CamelEvent.CamelContextInitializingEvent.class,
+ CamelEvent.CamelContextInitializedEvent.class,
CamelContextStartingEvent.class,
CamelContextStartedEvent.class));
}
@@ -121,6 +132,8 @@ public class CamelEventNotifierTest {
assertThat("Events fired are incorrect!", events,
contains(
+ CamelEvent.CamelContextInitializingEvent.class,
+ CamelEvent.CamelContextInitializedEvent.class,
CamelContextStartingEvent.class,
CamelContextStartedEvent.class,
ExchangeSendingEvent.class,
@@ -138,6 +151,8 @@ public class CamelEventNotifierTest {
assertThat("Events fired are incorrect!", events,
contains(
+ CamelEvent.CamelContextInitializingEvent.class,
+ CamelEvent.CamelContextInitializedEvent.class,
CamelContextStartingEvent.class,
CamelContextStartedEvent.class,
ExchangeSendingEvent.class,
