Add test for coverage

apache · Sep 18, 2024 · 0d95589 · 0d95589
1 parent 7a75190
commit 0d95589
Show file tree

Hide file tree

Showing 3 changed files with 400 additions and 0 deletions.
diff --git a/quarkus/addons/events/process/runtime/pom.xml b/quarkus/addons/events/process/runtime/pom.xml
@@ -78,6 +78,17 @@
       <groupId>org.slf4j</groupId>
       <artifactId>slf4j-api</artifactId>
     </dependency>
+
+    <dependency>
+      <groupId>org.junit.jupiter</groupId>
+      <artifactId>junit-jupiter</artifactId>
+      <scope>test</scope>
+    </dependency>
+    <dependency>
+      <groupId>io.quarkus</groupId>
+      <artifactId>quarkus-junit5-mockito</artifactId>
+      <scope>test</scope>
+    </dependency>
   </dependencies>
 
   <build>

diff --git a/.../runtime/src/main/java/org/kie/kogito/events/process/GroupingMessagingEventPublisher.java b/.../runtime/src/main/java/org/kie/kogito/events/process/GroupingMessagingEventPublisher.java
@@ -44,6 +44,9 @@ public void publish(DataEvent<?> event) {
     public void publish(Collection<DataEvent<?>> events) {
         Map<AbstractMessageEmitter, Collection<DataEvent<?>>> eventsByChannel = new HashMap<>();
         for (DataEvent<?> event : events) {
+            if (event == null) {
+                continue;
+            }
             getConsumer(event).ifPresent(c -> eventsByChannel.computeIfAbsent(c, k -> new ArrayList<>()).add(event));
         }
         for (Entry<AbstractMessageEmitter, Collection<DataEvent<?>>> item : eventsByChannel.entrySet()) {