diff --git a/src/main/java/io/takima/temporalpractice/bakery/CookieOrderer.java b/src/main/java/io/takima/temporalpractice/bakery/CookieOrderer.java index d32beb34f103d42c57a5f428cebd13b46c2198bf..3ac04712f4dc4b3703906d0dd5aba8b58ea439cb 100644 --- a/src/main/java/io/takima/temporalpractice/bakery/CookieOrderer.java +++ b/src/main/java/io/takima/temporalpractice/bakery/CookieOrderer.java @@ -5,6 +5,8 @@ import io.temporal.client.WorkflowOptions; import io.temporal.serviceclient.WorkflowServiceStubs; import io.takima.temporalpractice.bakery.cookie.CookieWorkflow; import io.takima.temporalpractice.bakery.cookie.BestCookieWorkflow; +import io.temporal.worker.Worker; +import io.temporal.worker.WorkerFactory; public class CookieOrderer { public static void main(String[] args) { @@ -18,8 +20,16 @@ public class CookieOrderer { .setWorkflowId("best-cookie") .build(); - CookieWorkflow workflow = client.newWorkflowStub(BestCookieWorkflow.class, options); + WorkerFactory factory = WorkerFactory.newInstance(client); + + Worker worker = factory.newWorker("theOneAndOnlyQueue"); + + worker.registerWorkflowImplementationTypes(BestCookieWorkflow.class); + + factory.start(); + + CookieWorkflow workflow = client.newWorkflowStub(CookieWorkflow.class, options); workflow.orderCookie(); // Start the Workflow Execution } -} \ No newline at end of file +}