From 068ec4984e3921a9bfb569fca82e34ef13288abb Mon Sep 17 00:00:00 2001 From: Tiago Dolphine Date: Mon, 13 Nov 2023 09:11:55 -0300 Subject: [PATCH] minor fixes --- .../workflow/devservices/DataIndexEventPublisher.java | 9 ++++----- .../kie/kogito/events/spring/KafkaEventPublisher.java | 5 ++--- 2 files changed, 6 insertions(+), 8 deletions(-) diff --git a/quarkus/extensions/kogito-quarkus-workflow-extension-common/kogito-quarkus-workflow-common/src/main/java/org/kie/kogito/quarkus/workflow/devservices/DataIndexEventPublisher.java b/quarkus/extensions/kogito-quarkus-workflow-extension-common/kogito-quarkus-workflow-common/src/main/java/org/kie/kogito/quarkus/workflow/devservices/DataIndexEventPublisher.java index c78d02ae2f7..8a3143ed520 100644 --- a/quarkus/extensions/kogito-quarkus-workflow-extension-common/kogito-quarkus-workflow-common/src/main/java/org/kie/kogito/quarkus/workflow/devservices/DataIndexEventPublisher.java +++ b/quarkus/extensions/kogito-quarkus-workflow-extension-common/kogito-quarkus-workflow-common/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/springboot/addons/events/kafka/src/main/java/org/kie/kogito/events/spring/KafkaEventPublisher.java b/springboot/addons/events/kafka/src/main/java/org/kie/kogito/events/spring/KafkaEventPublisher.java index 3f82f9b734c..93b9779259a 100644 --- a/springboot/addons/events/kafka/src/main/java/org/kie/kogito/events/spring/KafkaEventPublisher.java +++ b/springboot/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}")