Scratchpad

dandavison · dandavison · commit 1e2f3f2a9c28 · 2024-09-25T14:42:19.000-04:00
diff --git a/core/src/main/java/io/temporal/samples/hello/Scratchpad.java b/core/src/main/java/io/temporal/samples/hello/Scratchpad.java
@@ -0,0 +1,74 @@
+package io.temporal.samples.hello;
+
+import io.temporal.activity.ActivityInterface;
+import io.temporal.activity.ActivityOptions;
+import io.temporal.api.enums.v1.WorkflowIdReusePolicy;
+import io.temporal.client.WorkflowClient;
+import io.temporal.client.WorkflowOptions;
+import io.temporal.serviceclient.WorkflowServiceStubs;
+import io.temporal.worker.Worker;
+import io.temporal.worker.WorkerFactory;
+import io.temporal.workflow.Workflow;
+import io.temporal.workflow.WorkflowInterface;
+import io.temporal.workflow.WorkflowMethod;
+import java.time.Duration;
+
+public class Scratchpad {
+  static final String TASK_QUEUE = "ScratchpadTaskQueue";
+  static final String WORKFLOW_ID = "ScratchpadWorkflow";
+
+  @WorkflowInterface
+  public interface MyWorkflow {
+    @WorkflowMethod
+    String getGreeting(String name);
+  }
+
+  @ActivityInterface
+  public interface MyActivities {
+    String composeGreeting(String greeting, String name);
+  }
+
+  public static class MyWorkflowImpl implements MyWorkflow {
+
+    private final MyActivities activities =
+        Workflow.newActivityStub(
+            MyActivities.class,
+            ActivityOptions.newBuilder().setStartToCloseTimeout(Duration.ofSeconds(2)).build());
+
+    @Override
+    public String getGreeting(String name) {
+      return activities.composeGreeting("Hello", name);
+    }
+  }
+
+  static class MyActivitiesImpl implements MyActivities {
+    @Override
+    public String composeGreeting(String greeting, String name) {
+      return greeting + " " + name + "!";
+    }
+  }
+
+  public static void main(String[] args) {
+    WorkflowServiceStubs service = WorkflowServiceStubs.newLocalServiceStubs();
+    WorkflowClient client = WorkflowClient.newInstance(service);
+    WorkerFactory factory = WorkerFactory.newInstance(client);
+    Worker worker = factory.newWorker(TASK_QUEUE);
+    worker.registerWorkflowImplementationTypes(MyWorkflowImpl.class);
+    worker.registerActivitiesImplementations(new MyActivitiesImpl());
+    factory.start();
+    MyWorkflow workflow =
+        client.newWorkflowStub(
+            MyWorkflow.class,
+            WorkflowOptions.newBuilder()
+                .setWorkflowId(WORKFLOW_ID)
+                .setTaskQueue(TASK_QUEUE)
+                .setWorkflowIdReusePolicy(
+                    WorkflowIdReusePolicy.WORKFLOW_ID_REUSE_POLICY_TERMINATE_IF_RUNNING)
+                .build());
+
+    String greeting = workflow.getGreeting("World");
+
+    System.out.println(greeting);
+    System.exit(0);
+  }
+}
