From 8f5873d3e543db9177f089c81ef5096eacc1197b Mon Sep 17 00:00:00 2001 From: Francisco Javier Tirado Sarti Date: Mon, 17 Jun 2024 11:08:14 +0200 Subject: [PATCH] [Fix #2070] Synchronizing TestEventPublisher --- .../org/kie/kogito/jobs/embedded/TestEventPublisher.java | 6 ++++-- .../src/test/resources/application.properties | 1 + 2 files changed, 5 insertions(+), 2 deletions(-) create mode 100644 jobs-service/kogito-addons-jobs-service/kogito-addons-quarkus-jobs/src/test/resources/application.properties diff --git a/jobs-service/kogito-addons-jobs-service/kogito-addons-quarkus-jobs/src/test/java/org/kie/kogito/jobs/embedded/TestEventPublisher.java b/jobs-service/kogito-addons-jobs-service/kogito-addons-quarkus-jobs/src/test/java/org/kie/kogito/jobs/embedded/TestEventPublisher.java index f077205d54..f12b0687f7 100644 --- a/jobs-service/kogito-addons-jobs-service/kogito-addons-quarkus-jobs/src/test/java/org/kie/kogito/jobs/embedded/TestEventPublisher.java +++ b/jobs-service/kogito-addons-jobs-service/kogito-addons-quarkus-jobs/src/test/java/org/kie/kogito/jobs/embedded/TestEventPublisher.java @@ -20,6 +20,7 @@ import java.util.ArrayList; import java.util.Collection; +import java.util.Collections; import java.util.List; import java.util.concurrent.CountDownLatch; @@ -35,11 +36,11 @@ public class TestEventPublisher implements EventPublisher { private CountDownLatch latch; public List> getEvents() { - return events; + return Collections.unmodifiableList(events); } public TestEventPublisher() { - events = new ArrayList<>(); + events = Collections.synchronizedList(new ArrayList<>()); } @Override @@ -56,6 +57,7 @@ public void publish(Collection> events) { public void setLatch(CountDownLatch latch) { this.latch = latch; + events.clear(); } } diff --git a/jobs-service/kogito-addons-jobs-service/kogito-addons-quarkus-jobs/src/test/resources/application.properties b/jobs-service/kogito-addons-jobs-service/kogito-addons-quarkus-jobs/src/test/resources/application.properties new file mode 100644 index 0000000000..b6eb3afa2b --- /dev/null +++ b/jobs-service/kogito-addons-jobs-service/kogito-addons-quarkus-jobs/src/test/resources/application.properties @@ -0,0 +1 @@ +quarkus.devservices.enabled=false \ No newline at end of file