Changed HelloAsyncActvityCompletion to use WorkflowClient.execute (temporalio#13)

mfateev · web-flow · commit f89cd5d09d43 · 2018-03-16T10:04:47.000-07:00
diff --git a/src/main/java/com/uber/cadence/samples/hello/HelloAsyncActivityCompletion.java b/src/main/java/com/uber/cadence/samples/hello/HelloAsyncActivityCompletion.java
@@ -25,6 +25,8 @@
 import com.uber.cadence.worker.Worker;
 import com.uber.cadence.workflow.Workflow;
 import com.uber.cadence.workflow.WorkflowMethod;
+import java.util.concurrent.CompletableFuture;
+import java.util.concurrent.ExecutionException;
 import java.util.concurrent.ForkJoinPool;
 
 /**
@@ -97,7 +99,7 @@ private void composeGreetingAsync(byte[] taskToken, String greeting, String name
         }
     }
 
-    public static void main(String[] args) {
+    public static void main(String[] args) throws ExecutionException, InterruptedException {
         // Start a worker that hosts both workflow and activity implementation
         Worker worker = new Worker(DOMAIN, TASK_LIST);
         // Workflows are stateful. So need a type to create instances.
@@ -111,9 +113,12 @@ public static void main(String[] args) {
         WorkflowClient workflowClient = WorkflowClient.newInstance(DOMAIN);
         // Get a workflow stub using the same task list the worker uses.
         GreetingWorkflow workflow = workflowClient.newWorkflowStub(GreetingWorkflow.class);
-        // Execute a workflow waiting for it complete.
-        String greeting = workflow.getGreeting("World");
-        System.out.println(greeting);
+        // Execute a workflow returning a future that can be used to wait for the workflow
+        // completion.
+        CompletableFuture<String> greeting = WorkflowClient.execute(workflow::getGreeting,
+            "World");
+        // Wait for workflow completion
+        System.out.println(greeting.get());
         System.exit(0);
     }
 }
