Fixing_ForEachRestIT (apache#3304)

* Fixing_ForEachRestIT * Formatting
tkobayas · Dec 14, 2023 · 7f1297b · 7f1297b
1 parent cec5e62
commit 7f1297b
Show file tree

Hide file tree

Showing 10 changed files with 23 additions and 23 deletions.
diff --git a/...kflow-integration-test/src/main/java/org/kie/kogito/workflows/services/GreetResource.java b/...kflow-integration-test/src/main/java/org/kie/kogito/workflows/services/GreetResource.java
@@ -20,6 +20,9 @@
 
 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.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/...ation-test/src/main/java/org/kie/kogito/workflows/services/JavaSerializationProducer.java b/...ation-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/...est/src/main/java/org/kie/kogito/workflows/services/NodeInstanceTriggerEventListener.java b/...est/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/...ration-test/src/main/java/org/kie/kogito/workflows/services/RPCCustomWorkItemHandler.java b/...ration-test/src/main/java/org/kie/kogito/workflows/services/RPCCustomWorkItemHandler.java
@@ -20,11 +20,11 @@
 
 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/...-test/src/main/java/org/kie/kogito/workflows/services/RPCCustomWorkItemHandlerConfig.java b/...-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/...rkflow-integration-test/src/test/java/org/kie/kogito/quarkus/workflows/ForEachRestIT.java b/...rkflow-integration-test/src/test/java/org/kie/kogito/quarkus/workflows/ForEachRestIT.java
@@ -56,7 +56,7 @@ void testForEachSubflow() {
         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/...-workflow-integration-test/src/test/java/org/kie/kogito/quarkus/workflows/SubFlowsIT.java b/...-workflow-integration-test/src/test/java/org/kie/kogito/quarkus/workflows/SubFlowsIT.java
@@ -21,14 +21,14 @@
 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/.../src/test/java/org/kie/kogito/quarkus/workflows/TokenPropagationExternalServicesMock.java b/.../src/test/java/org/kie/kogito/quarkus/workflows/TokenPropagationExternalServicesMock.java
@@ -21,12 +21,12 @@
 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/...w-integration-test/src/test/java/org/kie/kogito/quarkus/workflows/TokenPropagationIT.java b/...w-integration-test/src/test/java/org/kie/kogito/quarkus/workflows/TokenPropagationIT.java
@@ -21,15 +21,15 @@
 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;
 
 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/...flow-integration-test/src/test/java/org/kie/kogito/quarkus/workflows/WorkflowEventIT.java b/...flow-integration-test/src/test/java/org/kie/kogito/quarkus/workflows/WorkflowEventIT.java
@@ -87,7 +87,7 @@ void testWorkflowEvents() throws Exception {
         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();