From be43282475d03fea7f487868c97ed555a0ed2f19 Mon Sep 17 00:00:00 2001 From: Francisco Javier Tirado Sarti <65240126+fjtirado@users.noreply.github.com> Date: Mon, 17 Feb 2025 15:32:35 +0100 Subject: [PATCH] Fix format issue (#2192) --- .../org/kie/kogito/it/jobs/KafkaBaseSwitchStateTimeoutsIT.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/apps-integration-tests/integration-tests-jobs-service/integration-tests-jobs-service-quarkus/integration-tests-jobs-service-common-quarkus/src/test/java/org/kie/kogito/it/jobs/KafkaBaseSwitchStateTimeoutsIT.java b/apps-integration-tests/integration-tests-jobs-service/integration-tests-jobs-service-quarkus/integration-tests-jobs-service-common-quarkus/src/test/java/org/kie/kogito/it/jobs/KafkaBaseSwitchStateTimeoutsIT.java index b9303dd3a0..e6876eee6b 100644 --- a/apps-integration-tests/integration-tests-jobs-service/integration-tests-jobs-service-quarkus/integration-tests-jobs-service-common-quarkus/src/test/java/org/kie/kogito/it/jobs/KafkaBaseSwitchStateTimeoutsIT.java +++ b/apps-integration-tests/integration-tests-jobs-service/integration-tests-jobs-service-quarkus/integration-tests-jobs-service-common-quarkus/src/test/java/org/kie/kogito/it/jobs/KafkaBaseSwitchStateTimeoutsIT.java @@ -46,7 +46,7 @@ void cleanUp() { } private static JsonPath waitForEvent(KafkaTestClient kafkaClient, String topic, long seconds) throws Exception { - CompletableFuture cloudEvent = new CompletableFuture<>(); + CompletableFuture cloudEvent = new CompletableFuture<>(); kafkaClient.consume(topic, cloudEvent::complete); return new JsonPath(cloudEvent.orTimeout(seconds, TimeUnit.SECONDS).get()); }