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 f0f45097fe Fixing_ForEachRestIT (#3304)
f0f45097fe is described below
commit f0f45097fe30069599bdd542783cc265b2443580
Author: Francisco Javier Tirado Sarti
<[email protected]>
AuthorDate: Fri Dec 1 14:27:38 2023 +0100
Fixing_ForEachRestIT (#3304)
* Fixing_ForEachRestIT
* Formatting
---
.../java/org/kie/kogito/workflows/services/GreetResource.java | 6 +++---
.../kogito/workflows/services/JavaSerializationProducer.java | 10 +++++-----
.../workflows/services/NodeInstanceTriggerEventListener.java | 4 ++--
.../kogito/workflows/services/RPCCustomWorkItemHandler.java | 4 ++--
.../workflows/services/RPCCustomWorkItemHandlerConfig.java | 6 +++---
.../java/org/kie/kogito/quarkus/workflows/ForEachRestIT.java | 2 +-
.../test/java/org/kie/kogito/quarkus/workflows/SubFlowsIT.java | 4 ++--
.../workflows/TokenPropagationExternalServicesMock.java | 4 ++--
.../org/kie/kogito/quarkus/workflows/TokenPropagationIT.java | 4 ++--
.../java/org/kie/kogito/quarkus/workflows/WorkflowEventIT.java | 2 +-
10 files changed, 23 insertions(+), 23 deletions(-)
diff --git
a/quarkus/extensions/kogito-quarkus-serverless-workflow-extension/kogito-quarkus-serverless-workflow-integration-test/src/main/java/org/kie/kogito/workflows/services/GreetResource.java
b/quarkus/extensions/kogito-quarkus-serverless-workflow-extension/kogito-quarkus-serverless-workflow-integration-test/src/main/java/org/kie/kogito/workflows/services/GreetResource.java
index 12f949e1c3..9f97d68aea 100644
---
a/quarkus/extensions/kogito-quarkus-serverless-workflow-extension/kogito-quarkus-serverless-workflow-integration-test/src/main/java/org/kie/kogito/workflows/services/GreetResource.java
+++
b/quarkus/extensions/kogito-quarkus-serverless-workflow-extension/kogito-quarkus-serverless-workflow-integration-test/src/main/java/org/kie/kogito/workflows/services/GreetResource.java
@@ -20,6 +20,9 @@ package org.kie.kogito.workflows.services;
import java.util.Map;
+import org.kie.kogito.Model;
+import org.kie.kogito.process.Process;
+
import jakarta.inject.Inject;
import jakarta.inject.Named;
import jakarta.ws.rs.GET;
@@ -28,9 +31,6 @@ import jakarta.ws.rs.Produces;
import jakarta.ws.rs.core.MediaType;
import jakarta.ws.rs.core.Response;
-import org.kie.kogito.Model;
-import org.kie.kogito.process.Process;
-
@Path("/greetdetails")
public class GreetResource {
diff --git
a/quarkus/extensions/kogito-quarkus-serverless-workflow-extension/kogito-quarkus-serverless-workflow-integration-test/src/main/java/org/kie/kogito/workflows/services/JavaSerializationProducer.java
b/quarkus/extensions/kogito-quarkus-serverless-workflow-extension/kogito-quarkus-serverless-workflow-integration-test/src/main/java/org/kie/kogito/workflows/services/JavaSerializationProducer.java
index 5e4db1e3bc..0331552e79 100644
---
a/quarkus/extensions/kogito-quarkus-serverless-workflow-extension/kogito-quarkus-serverless-workflow-integration-test/src/main/java/org/kie/kogito/workflows/services/JavaSerializationProducer.java
+++
b/quarkus/extensions/kogito-quarkus-serverless-workflow-extension/kogito-quarkus-serverless-workflow-integration-test/src/main/java/org/kie/kogito/workflows/services/JavaSerializationProducer.java
@@ -18,16 +18,16 @@
*/
package org.kie.kogito.workflows.services;
-import jakarta.enterprise.context.ApplicationScoped;
-import jakarta.enterprise.inject.Produces;
-import jakarta.inject.Inject;
-import jakarta.inject.Named;
-
import org.kie.kogito.addon.quarkus.messaging.common.ChannelFormat;
import org.kie.kogito.event.CloudEventUnmarshallerFactory;
import com.fasterxml.jackson.databind.ObjectMapper;
+import jakarta.enterprise.context.ApplicationScoped;
+import jakarta.enterprise.inject.Produces;
+import jakarta.inject.Inject;
+import jakarta.inject.Named;
+
@ApplicationScoped
public class JavaSerializationProducer {
diff --git
a/quarkus/extensions/kogito-quarkus-serverless-workflow-extension/kogito-quarkus-serverless-workflow-integration-test/src/main/java/org/kie/kogito/workflows/services/NodeInstanceTriggerEventListener.java
b/quarkus/extensions/kogito-quarkus-serverless-workflow-extension/kogito-quarkus-serverless-workflow-integration-test/src/main/java/org/kie/kogito/workflows/services/NodeInstanceTriggerEventListener.java
index 419aa07937..26e6c0e98d 100644
---
a/quarkus/extensions/kogito-quarkus-serverless-workflow-extension/kogito-quarkus-serverless-workflow-integration-test/src/main/java/org/kie/kogito/workflows/services/NodeInstanceTriggerEventListener.java
+++
b/quarkus/extensions/kogito-quarkus-serverless-workflow-extension/kogito-quarkus-serverless-workflow-integration-test/src/main/java/org/kie/kogito/workflows/services/NodeInstanceTriggerEventListener.java
@@ -18,12 +18,12 @@
*/
package org.kie.kogito.workflows.services;
-import jakarta.enterprise.context.ApplicationScoped;
-
import org.kie.api.event.process.ProcessNodeLeftEvent;
import org.kie.kogito.internal.process.event.DefaultKogitoProcessEventListener;
import org.kie.kogito.internal.process.runtime.KogitoNodeInstance;
+import jakarta.enterprise.context.ApplicationScoped;
+
import static java.lang.String.format;
@ApplicationScoped
diff --git
a/quarkus/extensions/kogito-quarkus-serverless-workflow-extension/kogito-quarkus-serverless-workflow-integration-test/src/main/java/org/kie/kogito/workflows/services/RPCCustomWorkItemHandler.java
b/quarkus/extensions/kogito-quarkus-serverless-workflow-extension/kogito-quarkus-serverless-workflow-integration-test/src/main/java/org/kie/kogito/workflows/services/RPCCustomWorkItemHandler.java
index 2851f80580..b49a276508 100644
---
a/quarkus/extensions/kogito-quarkus-serverless-workflow-extension/kogito-quarkus-serverless-workflow-integration-test/src/main/java/org/kie/kogito/workflows/services/RPCCustomWorkItemHandler.java
+++
b/quarkus/extensions/kogito-quarkus-serverless-workflow-extension/kogito-quarkus-serverless-workflow-integration-test/src/main/java/org/kie/kogito/workflows/services/RPCCustomWorkItemHandler.java
@@ -20,11 +20,11 @@ package org.kie.kogito.workflows.services;
import java.util.Map;
-import jakarta.enterprise.context.ApplicationScoped;
-
import org.kie.kogito.internal.process.runtime.KogitoWorkItem;
import org.kie.kogito.serverless.workflow.WorkflowWorkItemHandler;
+import jakarta.enterprise.context.ApplicationScoped;
+
@ApplicationScoped
public class RPCCustomWorkItemHandler extends WorkflowWorkItemHandler {
diff --git
a/quarkus/extensions/kogito-quarkus-serverless-workflow-extension/kogito-quarkus-serverless-workflow-integration-test/src/main/java/org/kie/kogito/workflows/services/RPCCustomWorkItemHandlerConfig.java
b/quarkus/extensions/kogito-quarkus-serverless-workflow-extension/kogito-quarkus-serverless-workflow-integration-test/src/main/java/org/kie/kogito/workflows/services/RPCCustomWorkItemHandlerConfig.java
index a33e0658d6..317cb16279 100644
---
a/quarkus/extensions/kogito-quarkus-serverless-workflow-extension/kogito-quarkus-serverless-workflow-integration-test/src/main/java/org/kie/kogito/workflows/services/RPCCustomWorkItemHandlerConfig.java
+++
b/quarkus/extensions/kogito-quarkus-serverless-workflow-extension/kogito-quarkus-serverless-workflow-integration-test/src/main/java/org/kie/kogito/workflows/services/RPCCustomWorkItemHandlerConfig.java
@@ -18,11 +18,11 @@
*/
package org.kie.kogito.workflows.services;
-import jakarta.enterprise.context.ApplicationScoped;
-import jakarta.inject.Inject;
+import org.kie.kogito.process.impl.CachedWorkItemHandlerConfig;
import jakarta.annotation.PostConstruct;
-import org.kie.kogito.process.impl.CachedWorkItemHandlerConfig;
+import jakarta.enterprise.context.ApplicationScoped;
+import jakarta.inject.Inject;
@ApplicationScoped
public class RPCCustomWorkItemHandlerConfig extends
CachedWorkItemHandlerConfig {
diff --git
a/quarkus/extensions/kogito-quarkus-serverless-workflow-extension/kogito-quarkus-serverless-workflow-integration-test/src/test/java/org/kie/kogito/quarkus/workflows/ForEachRestIT.java
b/quarkus/extensions/kogito-quarkus-serverless-workflow-extension/kogito-quarkus-serverless-workflow-integration-test/src/test/java/org/kie/kogito/quarkus/workflows/ForEachRestIT.java
index 71220c7bcb..03c83ac5c3 100644
---
a/quarkus/extensions/kogito-quarkus-serverless-workflow-extension/kogito-quarkus-serverless-workflow-integration-test/src/test/java/org/kie/kogito/quarkus/workflows/ForEachRestIT.java
+++
b/quarkus/extensions/kogito-quarkus-serverless-workflow-extension/kogito-quarkus-serverless-workflow-integration-test/src/test/java/org/kie/kogito/quarkus/workflows/ForEachRestIT.java
@@ -56,7 +56,7 @@ class ForEachRestIT {
given()
.contentType(ContentType.JSON)
.accept(ContentType.JSON)
- .body("{\"numbers\" : [1,2,3,4,5], \"constant\": 2}}").when()
+ .body("{\"numbers\" : [1,2,3,4,5], \"constant\": 2}").when()
.post("/foreach_parent")
.then()
.statusCode(201)
diff --git
a/quarkus/extensions/kogito-quarkus-serverless-workflow-extension/kogito-quarkus-serverless-workflow-integration-test/src/test/java/org/kie/kogito/quarkus/workflows/SubFlowsIT.java
b/quarkus/extensions/kogito-quarkus-serverless-workflow-extension/kogito-quarkus-serverless-workflow-integration-test/src/test/java/org/kie/kogito/quarkus/workflows/SubFlowsIT.java
index 8457c1846f..57ab33832d 100644
---
a/quarkus/extensions/kogito-quarkus-serverless-workflow-extension/kogito-quarkus-serverless-workflow-integration-test/src/test/java/org/kie/kogito/quarkus/workflows/SubFlowsIT.java
+++
b/quarkus/extensions/kogito-quarkus-serverless-workflow-extension/kogito-quarkus-serverless-workflow-integration-test/src/test/java/org/kie/kogito/quarkus/workflows/SubFlowsIT.java
@@ -21,14 +21,14 @@ package org.kie.kogito.quarkus.workflows;
import java.time.Duration;
import java.util.UUID;
-import jakarta.ws.rs.core.MediaType;
-
import org.junit.jupiter.api.Test;
import io.quarkus.test.junit.QuarkusIntegrationTest;
import io.restassured.RestAssured;
import io.restassured.http.ContentType;
+import jakarta.ws.rs.core.MediaType;
+
import static io.restassured.RestAssured.given;
import static org.awaitility.Awaitility.await;
import static org.hamcrest.CoreMatchers.is;
diff --git
a/quarkus/extensions/kogito-quarkus-serverless-workflow-extension/kogito-quarkus-serverless-workflow-integration-test/src/test/java/org/kie/kogito/quarkus/workflows/TokenPropagationExternalServicesMock.java
b/quarkus/extensions/kogito-quarkus-serverless-workflow-extension/kogito-quarkus-serverless-workflow-integration-test/src/test/java/org/kie/kogito/quarkus/workflows/TokenPropagationExternalServicesMock.java
index 0c42b4214a..acc2c88be5 100644
---
a/quarkus/extensions/kogito-quarkus-serverless-workflow-extension/kogito-quarkus-serverless-workflow-integration-test/src/test/java/org/kie/kogito/quarkus/workflows/TokenPropagationExternalServicesMock.java
+++
b/quarkus/extensions/kogito-quarkus-serverless-workflow-extension/kogito-quarkus-serverless-workflow-integration-test/src/test/java/org/kie/kogito/quarkus/workflows/TokenPropagationExternalServicesMock.java
@@ -21,12 +21,12 @@ package org.kie.kogito.quarkus.workflows;
import java.util.Collections;
import java.util.Map;
-import jakarta.ws.rs.core.HttpHeaders;
-
import com.github.tomakehurst.wiremock.WireMockServer;
import io.quarkus.test.common.QuarkusTestResourceLifecycleManager;
+import jakarta.ws.rs.core.HttpHeaders;
+
import static com.github.tomakehurst.wiremock.client.WireMock.aResponse;
import static com.github.tomakehurst.wiremock.client.WireMock.configureFor;
import static com.github.tomakehurst.wiremock.client.WireMock.equalTo;
diff --git
a/quarkus/extensions/kogito-quarkus-serverless-workflow-extension/kogito-quarkus-serverless-workflow-integration-test/src/test/java/org/kie/kogito/quarkus/workflows/TokenPropagationIT.java
b/quarkus/extensions/kogito-quarkus-serverless-workflow-extension/kogito-quarkus-serverless-workflow-integration-test/src/test/java/org/kie/kogito/quarkus/workflows/TokenPropagationIT.java
index d7194e46fe..174ce0c6eb 100644
---
a/quarkus/extensions/kogito-quarkus-serverless-workflow-extension/kogito-quarkus-serverless-workflow-integration-test/src/test/java/org/kie/kogito/quarkus/workflows/TokenPropagationIT.java
+++
b/quarkus/extensions/kogito-quarkus-serverless-workflow-extension/kogito-quarkus-serverless-workflow-integration-test/src/test/java/org/kie/kogito/quarkus/workflows/TokenPropagationIT.java
@@ -21,8 +21,6 @@ package org.kie.kogito.quarkus.workflows;
import java.util.HashMap;
import java.util.Map;
-import jakarta.ws.rs.core.HttpHeaders;
-
import org.assertj.core.api.Assertions;
import org.junit.jupiter.api.Test;
@@ -30,6 +28,8 @@ import io.quarkus.test.common.QuarkusTestResource;
import io.quarkus.test.junit.QuarkusIntegrationTest;
import io.restassured.path.json.JsonPath;
+import jakarta.ws.rs.core.HttpHeaders;
+
import static
org.kie.kogito.quarkus.workflows.ExternalServiceMock.SUCCESSFUL_QUERY;
import static
org.kie.kogito.quarkus.workflows.TokenPropagationExternalServicesMock.AUTHORIZATION_TOKEN;
import static
org.kie.kogito.quarkus.workflows.TokenPropagationExternalServicesMock.SERVICE3_AUTHORIZATION_TOKEN;
diff --git
a/quarkus/extensions/kogito-quarkus-serverless-workflow-extension/kogito-quarkus-serverless-workflow-integration-test/src/test/java/org/kie/kogito/quarkus/workflows/WorkflowEventIT.java
b/quarkus/extensions/kogito-quarkus-serverless-workflow-extension/kogito-quarkus-serverless-workflow-integration-test/src/test/java/org/kie/kogito/quarkus/workflows/WorkflowEventIT.java
index a21b62e08e..c11109b5d8 100644
---
a/quarkus/extensions/kogito-quarkus-serverless-workflow-extension/kogito-quarkus-serverless-workflow-integration-test/src/test/java/org/kie/kogito/quarkus/workflows/WorkflowEventIT.java
+++
b/quarkus/extensions/kogito-quarkus-serverless-workflow-extension/kogito-quarkus-serverless-workflow-integration-test/src/test/java/org/kie/kogito/quarkus/workflows/WorkflowEventIT.java
@@ -87,7 +87,7 @@ public class WorkflowEventIT {
String password = "buddy";
kafkaClient.consume(Set.of(EventPublisher.PROCESS_INSTANCES_TOPIC_NAME), s -> {
- LOGGER.info("Received from kafka: {}", s);
+ LOGGER.debug("Received from kafka: {}", s);
try {
ProcessInstanceDataEvent<?> event = mapper.readValue(s,
ProcessInstanceDataEvent.class);
Map data = (Map) event.getData();
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
