minor fixes

apache · Nov 14, 2023 · 068ec49 · 068ec49
1 parent e7a5db8
commit 068ec49
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 8 deletions.
diff --git a/...on/src/main/java/org/kie/kogito/quarkus/workflow/devservices/DataIndexEventPublisher.java b/...on/src/main/java/org/kie/kogito/quarkus/workflow/devservices/DataIndexEventPublisher.java
@@ -24,16 +24,15 @@
 import javax.annotation.PostConstruct;
 import javax.inject.Inject;
 
+import io.vertx.core.Vertx;
+import io.vertx.ext.web.client.WebClient;
+import io.vertx.ext.web.client.predicate.ResponsePredicate;
 import org.eclipse.microprofile.config.inject.ConfigProperty;
 import org.kie.kogito.event.DataEvent;
 import org.kie.kogito.event.EventPublisher;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-import io.vertx.core.Vertx;
-import io.vertx.ext.web.client.WebClient;
-import io.vertx.ext.web.client.predicate.ResponsePredicate;
-
 public class DataIndexEventPublisher implements EventPublisher {
 
     public static final String KOGITO_DATA_INDEX = "kogito.data-index.url";
@@ -62,7 +61,7 @@ public void publish(DataEvent<?> event) {
 
         LOGGER.debug("Sending event to data index: {}", event);
         switch (event.getType()) {
-            case "ProcessDefinitionDataEvent":
+            case "ProcessDefinitionEvent":
                 webClient.postAbs(dataIndexUrl.get() + "/definitions")
                         .putHeader(CONTENT_TYPE, CLOUD_EVENTS_CONTENT_TYPE)
                         .expect(ResponsePredicate.SC_ACCEPTED)

diff --git a/...t/addons/events/kafka/src/main/java/org/kie/kogito/events/spring/KafkaEventPublisher.java b/...t/addons/events/kafka/src/main/java/org/kie/kogito/events/spring/KafkaEventPublisher.java
@@ -20,6 +20,7 @@
 
 import java.util.Collection;
 
+import com.fasterxml.jackson.databind.ObjectMapper;
 import org.kie.kogito.event.DataEvent;
 import org.kie.kogito.event.EventPublisher;
 import org.slf4j.Logger;
@@ -30,8 +31,6 @@
 import org.springframework.kafka.core.KafkaTemplate;
 import org.springframework.stereotype.Component;
 
-import com.fasterxml.jackson.databind.ObjectMapper;
-
 @Component
 public class KafkaEventPublisher implements EventPublisher {
 
@@ -49,7 +48,7 @@ public class KafkaEventPublisher implements EventPublisher {
     @Value("${kogito.events.processinstances.enabled:true}")
     private boolean processInstancesEvents;
 
-    @Value("${kogito.events.process-definition.enabled:true}")
+    @Value("${kogito.events.processdefinitions.enabled:true}")
     private boolean processDefinitionEvents;
 
     @Value("${kogito.events.usertasks.enabled:true}")