adding uniqueId and type for node definition

apache · Nov 14, 2023 · c6eda2f · c6eda2f
1 parent f744015
commit c6eda2f
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 3 deletions.
diff --git a/api/kogito-api/src/main/java/org/kie/kogito/internal/process/runtime/KogitoNode.java b/api/kogito-api/src/main/java/org/kie/kogito/internal/process/runtime/KogitoNode.java
@@ -24,4 +24,6 @@
 public interface KogitoNode extends Node {
 
     NodeContainer getParentContainer();
+
+    String getUniqueId();
 }
diff --git a/...rvices/src/main/java/org/kie/kogito/services/registry/ProcessDefinitionEventRegistry.java b/...rvices/src/main/java/org/kie/kogito/services/registry/ProcessDefinitionEventRegistry.java
@@ -105,8 +105,8 @@ private List<NodeDefinition> getNodesDefinitions(Process<?> p) {
                 .map(node -> NodeDefinition.builder()
                         .setId(String.valueOf(node.getId()))
                         .setName(node.getName())
-                        .setType(node.getNodeType().name())
-                        .setUniqueId(node.getNodeUniqueId())
+                        .setType(node.getClass().getSimpleName())
+                        .setUniqueId(node.getUniqueId())
                         .setMetadata(node.getMetaData())
                         .build())
                 .collect(Collectors.toList());

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,7 +20,6 @@
 
 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;
@@ -31,6 +30,8 @@
 import org.springframework.kafka.core.KafkaTemplate;
 import org.springframework.stereotype.Component;
 
+import com.fasterxml.jackson.databind.ObjectMapper;
+
 @Component
 public class KafkaEventPublisher implements EventPublisher {