From 66ce16e1b74cb30864b5d0d418038a441847c2e8 Mon Sep 17 00:00:00 2001
From: Damien MARCHAT <dmarchat@takima.fr>
Date: Thu, 13 Mar 2025 16:48:13 +0100
Subject: [PATCH] Day 1 part 1.3
---
.../temporalpractice/bakery/CookieOrderer.java | 14 ++++++++++++--
1 file changed, 12 insertions(+), 2 deletions(-)
diff --git a/src/main/java/io/takima/temporalpractice/bakery/CookieOrderer.java b/src/main/java/io/takima/temporalpractice/bakery/CookieOrderer.java
index d32beb3..3ac0471 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
+}
--
GitLab