This is an automated email from the ASF dual-hosted git repository.
jstastnycz pushed a commit to branch main
in repository
https://gitbox.apache.org/repos/asf/incubator-kie-kogito-runtimes.git
The following commit(s) were added to refs/heads/main by this push:
new 6900f43ed3 fix compilation problems in kafak integration test
6900f43ed3 is described below
commit 6900f43ed38340ced33ebb02e20cac91bcd2e64b
Author: Enrique Gonzalez Martinez <[email protected]>
AuthorDate: Mon Oct 23 16:03:59 2023 +0200
fix compilation problems in kafak integration test
---
.../kie/kogito/integrationtests/springboot/ProcessEventIT.java | 10 +++++-----
1 file changed, 5 insertions(+), 5 deletions(-)
diff --git
a/springboot/integration-tests/src/it/integration-tests-springboot-kafka-it/src/test/java/org/kie/kogito/integrationtests/springboot/ProcessEventIT.java
b/springboot/integration-tests/src/it/integration-tests-springboot-kafka-it/src/test/java/org/kie/kogito/integrationtests/springboot/ProcessEventIT.java
index 09c3332bc6..d52ddf29f7 100644
---
a/springboot/integration-tests/src/it/integration-tests-springboot-kafka-it/src/test/java/org/kie/kogito/integrationtests/springboot/ProcessEventIT.java
+++
b/springboot/integration-tests/src/it/integration-tests-springboot-kafka-it/src/test/java/org/kie/kogito/integrationtests/springboot/ProcessEventIT.java
@@ -31,7 +31,7 @@ import org.junit.jupiter.api.BeforeAll;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.ExtendWith;
-import org.kie.kogito.event.process.ProcessDataEvent;
+import org.kie.kogito.event.process.ProcessInstanceDataEvent;
import org.kie.kogito.test.springboot.kafka.KafkaTestClient;
import org.kie.kogito.testcontainers.springboot.KafkaSpringBootTestResource;
import org.slf4j.Logger;
@@ -83,11 +83,11 @@ class ProcessEventIT extends BaseRestTest {
kafkaClient.consume(Set.of(KOGITO_PROCESSINSTANCES_EVENTS,
KOGITO_USERTASKINSTANCES_EVENTS, KOGITO_VARIABLE_EVENTS), s -> {
LOGGER.info("Received from kafka: {}", s);
try {
- ProcessDataEvent event = mapper.readValue(s,
ProcessDataEvent.class);
+ ProcessInstanceDataEvent event = mapper.readValue(s,
ProcessInstanceDataEvent.class);
LinkedHashMap data = (LinkedHashMap) event.getData();
if ("handleApprovals".equals(data.get("processId"))) {
switch (event.getType()) {
- case "ProcessInstanceEvent":
+ case "ProcessInstanceStateDataEvent":
assertEquals("ProcessInstanceEvent",
event.getType());
assertEquals("/handleApprovals",
event.getSource().toString());
assertEquals("handleApprovals",
data.get("processId"));
@@ -95,13 +95,13 @@ class ProcessEventIT extends BaseRestTest {
assertEquals("BPMN", data.get("processType"));
assertEquals("BPMN", event.getKogitoProcessType());
break;
- case "UserTaskInstanceEvent":
+ case "UserTaskInstanceStateDataEvent":
assertEquals("UserTaskInstanceEvent",
event.getType());
assertEquals("/handleApprovals",
event.getSource().toString());
assertEquals("handleApprovals",
data.get("processId"));
assertEquals("1.0",
event.getKogitoProcessInstanceVersion());
break;
- case "VariableInstanceEvent":
+ case "ProcessInstanceVariableDataEvent":
assertEquals("VariableInstanceEvent",
event.getType());
assertEquals("/handleApprovals",
event.getSource().toString());
assertEquals("handleApprovals",
data.get("processId"));
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
