Fix for a failing Kafka operator job

quarkus-qe · Oct 12, 2022 · 4f863a8 · 4f863a8
1 parent 9a42e79
commit 4f863a8
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/quarkus-test-core/src/main/java/io/quarkus/test/bootstrap/BaseService.java b/quarkus-test-core/src/main/java/io/quarkus/test/bootstrap/BaseService.java
@@ -13,6 +13,7 @@
 import java.util.List;
 import java.util.Map;
 import java.util.ServiceLoader;
+import java.util.concurrent.atomic.AtomicBoolean;
 import java.util.function.Supplier;
 import java.util.stream.Stream;
 
@@ -40,6 +41,7 @@ public class BaseService<T extends Service> implements Service {
     private final List<Action> onPostStartActions = new LinkedList<>();
     private final Map<String, String> properties = new HashMap<>();
     private final List<Runnable> futureProperties = new LinkedList<>();
+    private final AtomicBoolean isStopped = new AtomicBoolean(false); //todo workaround for https://github.com/fabric8io/kubernetes-client/issues/4491
 
     private ManagedResourceBuilder managedResourceBuilder;
     private ManagedResource managedResource;
@@ -206,7 +208,7 @@ public void start() {
      */
     @Override
     public void stop() {
-        if (!isRunning()) {
+        if (isStopped.get() || !isRunning()) {
             return;
         }
 
@@ -215,6 +217,7 @@ public void stop() {
         managedResource.stop();
 
         Log.info(this, "Service stopped (%s)", getDisplayName());
+        isStopped.set(true);
     }
 
     /**