Merge pull request #26 from quarkiverse/start_workers

add config to start workers

extension/deployment/src/main/java/io/quarkiverse/temporal/deployment/TemporalProcessor.java

@@ -248,9 +248,9 @@ SyntheticBeanBuildItem produceWorkerFactorySyntheticBean(
                 .done();
     }
 
-    @BuildStep
+    @BuildStep(onlyIf = StartWorkers.class)
     @Record(ExecutionTime.RUNTIME_INIT)
-    ServiceStartBuildItem startService(
+    ServiceStartBuildItem startWorkers(
             InitializedWorkerFactoryBuildItem workerFactoryBuildItem,
             WorkerFactoryRecorder workerFactoryRecorder,
             ShutdownContextBuildItem shutdownContextBuildItem) {
@@ -275,4 +275,12 @@ public boolean getAsBoolean() {
         }
     }
 
+    public static class StartWorkers implements BooleanSupplier {
+        TemporalBuildtimeConfig config;
+
+        public boolean getAsBoolean() {
+            return config.startWorkers();
+        }
+    }
+
 }

extension/deployment/src/test/java/io/quarkiverse/temporal/deployment/StartWorkersDisabledTest.java

@@ -0,0 +1,36 @@
+package io.quarkiverse.temporal.deployment;
+
+import java.util.List;
+
+import jakarta.inject.Inject;
+
+import org.jboss.shrinkwrap.api.ShrinkWrap;
+import org.jboss.shrinkwrap.api.asset.StringAsset;
+import org.jboss.shrinkwrap.api.spec.JavaArchive;
+import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.extension.RegisterExtension;
+
+import io.quarkus.maven.dependency.Dependency;
+import io.quarkus.test.QuarkusUnitTest;
+import io.temporal.worker.WorkerFactory;
+
+class StartWorkersDisabledTest {
+
+    @RegisterExtension
+    static final QuarkusUnitTest unitTest = new QuarkusUnitTest()
+            .setForcedDependencies(List.of(Dependency.of("io.quarkiverse.temporal", "quarkus-temporal-test", "999-SNAPSHOT")))
+            .setArchiveProducer(() -> ShrinkWrap.create(JavaArchive.class)
+                    .addAsResource(
+                            new StringAsset("quarkus.temporal.enable-mock: true\nquarkus.temporal.start-workers: false\n"),
+                            "application.properties"));
+
+    @Inject
+    WorkerFactory factory;
+
+    @Test
+    public void testStartWorkersDisabled() {
+        Assertions.assertFalse(factory.isStarted());
+    }
+
+}

extension/deployment/src/test/java/io/quarkiverse/temporal/deployment/StartWorkersEnabledTest.java

@@ -0,0 +1,34 @@
+package io.quarkiverse.temporal.deployment;
+
+import java.util.List;
+
+import jakarta.inject.Inject;
+
+import org.jboss.shrinkwrap.api.ShrinkWrap;
+import org.jboss.shrinkwrap.api.asset.StringAsset;
+import org.jboss.shrinkwrap.api.spec.JavaArchive;
+import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.extension.RegisterExtension;
+
+import io.quarkus.maven.dependency.Dependency;
+import io.quarkus.test.QuarkusUnitTest;
+import io.temporal.worker.WorkerFactory;
+
+class StartWorkersEnabledTest {
+
+    @RegisterExtension
+    static final QuarkusUnitTest unitTest = new QuarkusUnitTest()
+            .setForcedDependencies(List.of(Dependency.of("io.quarkiverse.temporal", "quarkus-temporal-test", "999-SNAPSHOT")))
+            .setArchiveProducer(() -> ShrinkWrap.create(JavaArchive.class)
+                    .addAsResource(new StringAsset("quarkus.temporal.enable-mock: true\n"), "application.properties"));
+
+    @Inject
+    WorkerFactory factory;
+
+    @Test
+    public void testStartWorker() {
+        Assertions.assertTrue(factory.isStarted());
+    }
+
+}

extension/runtime/src/main/java/io/quarkiverse/temporal/config/TemporalBuildtimeConfig.java

@@ -14,4 +14,10 @@ public interface TemporalBuildtimeConfig {
      */
     @WithDefault("false")
     Boolean enableMock();
+
+    /**
+     * enable mock for testing
+     */
+    @WithDefault("true")
+    Boolean startWorkers();
 }