This is an automated email from the ASF dual-hosted git repository.
fjtiradosarti pushed a commit to branch quarkus-3.2LTS
in repository
https://gitbox.apache.org/repos/asf/incubator-kie-kogito-runtimes.git
The following commit(s) were added to refs/heads/quarkus-3.2LTS by this push:
new b8a6156aad Using different topics (#3322)
b8a6156aad is described below
commit b8a6156aad9243af07dfad1b3e0590e52046c6ee
Author: Francisco Javier Tirado Sarti
<[email protected]>
AuthorDate: Mon Dec 11 18:10:07 2023 +0100
Using different topics (#3322)
---
.../callback-state-with-timeouts-error-handler.sw.json | 2 +-
.../src/main/resources/eventWithError.sw.json | 2 +-
.../src/main/resources/specs/callbackResults.yaml | 13 ++++++++++---
.../kogito/quarkus/workflows/CallbackStateTimeoutsIT.java | 2 --
.../workflows/CallbackStateWithTimeoutsErrorHandlerIT.java | 4 +---
.../org/kie/kogito/quarkus/workflows/EventTimedoutIT.java | 4 +---
6 files changed, 14 insertions(+), 13 deletions(-)
diff --git
a/quarkus/extensions/kogito-quarkus-serverless-workflow-extension/kogito-quarkus-serverless-workflow-integration-test/src/main/resources/callback-state-with-timeouts-error-handler.sw.json
b/quarkus/extensions/kogito-quarkus-serverless-workflow-extension/kogito-quarkus-serverless-workflow-integration-test/src/main/resources/callback-state-with-timeouts-error-handler.sw.json
index eb5508c0ff..de849da2d9 100644
---
a/quarkus/extensions/kogito-quarkus-serverless-workflow-extension/kogito-quarkus-serverless-workflow-integration-test/src/main/resources/callback-state-with-timeouts-error-handler.sw.json
+++
b/quarkus/extensions/kogito-quarkus-serverless-workflow-extension/kogito-quarkus-serverless-workflow-integration-test/src/main/resources/callback-state-with-timeouts-error-handler.sw.json
@@ -37,7 +37,7 @@
{
"name": "publishTimeoutExpired",
"type": "asyncapi",
- "operation": "specs/callbackResults.yaml#sendTimeoutExpired"
+ "operation":
"specs/callbackResults.yaml#sendTimeoutExpiredForCallbackError"
},
{
"name": "publishFailure",
diff --git
a/quarkus/extensions/kogito-quarkus-serverless-workflow-extension/kogito-quarkus-serverless-workflow-integration-test/src/main/resources/eventWithError.sw.json
b/quarkus/extensions/kogito-quarkus-serverless-workflow-extension/kogito-quarkus-serverless-workflow-integration-test/src/main/resources/eventWithError.sw.json
index b9e84b6d97..c854ebb8a4 100644
---
a/quarkus/extensions/kogito-quarkus-serverless-workflow-extension/kogito-quarkus-serverless-workflow-integration-test/src/main/resources/eventWithError.sw.json
+++
b/quarkus/extensions/kogito-quarkus-serverless-workflow-extension/kogito-quarkus-serverless-workflow-integration-test/src/main/resources/eventWithError.sw.json
@@ -27,7 +27,7 @@
{
"name": "publishTimeoutExpired",
"type": "asyncapi",
- "operation": "specs/callbackResults.yaml#sendTimeoutExpired"
+ "operation": "specs/callbackResults.yaml#sendTimeoutExpiredError"
}
]
,
diff --git
a/quarkus/extensions/kogito-quarkus-serverless-workflow-extension/kogito-quarkus-serverless-workflow-integration-test/src/main/resources/specs/callbackResults.yaml
b/quarkus/extensions/kogito-quarkus-serverless-workflow-extension/kogito-quarkus-serverless-workflow-integration-test/src/main/resources/specs/callbackResults.yaml
index d5b962c7c7..a50a2bd9ed 100644
---
a/quarkus/extensions/kogito-quarkus-serverless-workflow-extension/kogito-quarkus-serverless-workflow-integration-test/src/main/resources/specs/callbackResults.yaml
+++
b/quarkus/extensions/kogito-quarkus-serverless-workflow-extension/kogito-quarkus-serverless-workflow-integration-test/src/main/resources/specs/callbackResults.yaml
@@ -21,10 +21,17 @@ channels:
summary: Success
message:
$ref: '#/components/messages/message'
- timeout:
- description: A message channel for expired timeouts
+ timeoutCallbackError:
+ description: A message channel for callback timeout error
publish:
- operationId: sendTimeoutExpired
+ operationId: sendTimeoutExpiredForCallbackError
+ summary: Timeout Expired
+ message:
+ $ref: '#/components/messages/message'
+ timeoutError:
+ description: A message channel for timeout error
+ publish:
+ operationId: sendTimeoutExpiredError
summary: Timeout Expired
message:
$ref: '#/components/messages/message'
diff --git
a/quarkus/extensions/kogito-quarkus-serverless-workflow-extension/kogito-quarkus-serverless-workflow-integration-test/src/test/java/org/kie/kogito/quarkus/workflows/CallbackStateTimeoutsIT.java
b/quarkus/extensions/kogito-quarkus-serverless-workflow-extension/kogito-quarkus-serverless-workflow-integration-test/src/test/java/org/kie/kogito/quarkus/workflows/CallbackStateTimeoutsIT.java
index c4187221b0..1b43ae637d 100644
---
a/quarkus/extensions/kogito-quarkus-serverless-workflow-extension/kogito-quarkus-serverless-workflow-integration-test/src/test/java/org/kie/kogito/quarkus/workflows/CallbackStateTimeoutsIT.java
+++
b/quarkus/extensions/kogito-quarkus-serverless-workflow-extension/kogito-quarkus-serverless-workflow-integration-test/src/test/java/org/kie/kogito/quarkus/workflows/CallbackStateTimeoutsIT.java
@@ -18,7 +18,6 @@
*/
package org.kie.kogito.quarkus.workflows;
-import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.Test;
import org.kie.kogito.testcontainers.quarkus.KafkaQuarkusTestResource;
@@ -50,7 +49,6 @@ class CallbackStateTimeoutsIT extends AbstractCallbackStateIT
{
CALLBACK_STATE_TIMEOUTS_TOPIC);
}
-
@Disabled("https://github.com/apache/incubator-kie-kogito-runtimes/issues/3320";)
@Test
void callbackStateTimeoutsExceeded() {
// start a new process instance by sending a query and collect the
process instance id.
diff --git
a/quarkus/extensions/kogito-quarkus-serverless-workflow-extension/kogito-quarkus-serverless-workflow-integration-test/src/test/java/org/kie/kogito/quarkus/workflows/CallbackStateWithTimeoutsErrorHandlerIT.java
b/quarkus/extensions/kogito-quarkus-serverless-workflow-extension/kogito-quarkus-serverless-workflow-integration-test/src/test/java/org/kie/kogito/quarkus/workflows/CallbackStateWithTimeoutsErrorHandlerIT.java
index d18376c291..658e2b8ac5 100644
---
a/quarkus/extensions/kogito-quarkus-serverless-workflow-extension/kogito-quarkus-serverless-workflow-integration-test/src/test/java/org/kie/kogito/quarkus/workflows/CallbackStateWithTimeoutsErrorHandlerIT.java
+++
b/quarkus/extensions/kogito-quarkus-serverless-workflow-extension/kogito-quarkus-serverless-workflow-integration-test/src/test/java/org/kie/kogito/quarkus/workflows/CallbackStateWithTimeoutsErrorHandlerIT.java
@@ -23,7 +23,6 @@ import java.util.Map;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.TimeUnit;
-import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.Test;
import org.kie.kogito.event.Converter;
import org.kie.kogito.event.cloudevents.CloudEventExtensionConstants;
@@ -64,7 +63,6 @@ class CallbackStateWithTimeoutsErrorHandlerIT extends
AbstractCallbackStateIT {
waitForFinalizedEvent(processInstanceId, "success");
}
-
@Disabled("https://github.com/apache/incubator-kie-kogito-runtimes/issues/3320";)
@Test
void callbackStateTimeoutsExceeded() throws Exception {
String processInput = buildProcessInput(SUCCESSFUL_QUERY);
@@ -72,7 +70,7 @@ class CallbackStateWithTimeoutsErrorHandlerIT extends
AbstractCallbackStateIT {
assertProcessInstanceExists(CALLBACK_STATE_TIMEOUTS_GET_BY_ID_URL,
processInstanceId);
assertProcessInstanceHasFinished(CALLBACK_STATE_TIMEOUTS_GET_BY_ID_URL,
processInstanceId, 1, 10);
- waitForFinalizedEvent(processInstanceId, "timeout");
+ waitForFinalizedEvent(processInstanceId, "timeoutCallbackError");
}
@Test
diff --git
a/quarkus/extensions/kogito-quarkus-serverless-workflow-extension/kogito-quarkus-serverless-workflow-integration-test/src/test/java/org/kie/kogito/quarkus/workflows/EventTimedoutIT.java
b/quarkus/extensions/kogito-quarkus-serverless-workflow-extension/kogito-quarkus-serverless-workflow-integration-test/src/test/java/org/kie/kogito/quarkus/workflows/EventTimedoutIT.java
index 882fe8638b..544b016549 100644
---
a/quarkus/extensions/kogito-quarkus-serverless-workflow-extension/kogito-quarkus-serverless-workflow-integration-test/src/test/java/org/kie/kogito/quarkus/workflows/EventTimedoutIT.java
+++
b/quarkus/extensions/kogito-quarkus-serverless-workflow-extension/kogito-quarkus-serverless-workflow-integration-test/src/test/java/org/kie/kogito/quarkus/workflows/EventTimedoutIT.java
@@ -27,7 +27,6 @@ import
org.apache.kafka.common.serialization.ByteArrayDeserializer;
import org.apache.kafka.common.serialization.ByteArraySerializer;
import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.BeforeEach;
-import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.Test;
import org.kie.kogito.event.Converter;
import org.kie.kogito.event.cloudevents.CloudEventExtensionConstants;
@@ -76,13 +75,12 @@ public class EventTimedoutIT {
}
}
-
@Disabled("https://github.com/apache/incubator-kie-kogito-runtimes/issues/3320";)
@Test
void testTimedout() throws InterruptedException {
String id = startProcess("eventTimedout");
Converter<byte[], CloudEvent> converter = new
ByteArrayCloudEventUnmarshallerFactory(objectMapper).unmarshaller(Map.class).cloudEvent();
final CountDownLatch countDownLatch = new CountDownLatch(1);
- kafkaClient.consume("timeout", v -> {
+ kafkaClient.consume("timeoutError", v -> {
try {
CloudEvent event = converter.convert(v);
if
(id.equals(event.getExtension(CloudEventExtensionConstants.PROCESS_INSTANCE_ID)))
{
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
