Fix NPE

Signed-off-by: siri-varma <siri.varma@outlook.com>
Signed-off-by: sirivarma <siri.varma@outlook.com>

Author: siri-varma

examples/src/main/java/io/dapr/examples/workflows/childworkflow/DemoChildWorkerflowClient.java

@@ -16,7 +16,6 @@
 import io.dapr.workflows.client.DaprWorkflowClient;
 import io.dapr.workflows.client.WorkflowInstanceStatus;
 
-import java.time.Duration;
 import java.util.concurrent.TimeoutException;
 
 public class DemoChildWorkerflowClient {
@@ -28,20 +27,16 @@ public class DemoChildWorkerflowClient {
    */
   public static void main(String[] args) {
     try (DaprWorkflowClient client = new DaprWorkflowClient()) {
-      String instanceId = client.scheduleNewWorkflow(DemoChildWorkflow.class, "Hello Word");
+      String instanceId = client.scheduleNewWorkflow(DemoWorkflow.class);
       System.out.printf("Started a new child-workflow model workflow with instance ID: %s%n", instanceId);
+      WorkflowInstanceStatus workflowInstanceStatus =
+              client.waitForInstanceCompletion(instanceId, null, true);
 
-      while (true) {
-        try {
-          Thread.sleep(10000);
-          System.out.println(client.getInstanceState(instanceId, true).getRuntimeStatus());
-        } catch (Exception ex) {
-          System.out.println("exception");
-        }
-      }
+      String result = workflowInstanceStatus.readOutputAs(String.class);
+      System.out.printf("workflow instance with ID: %s completed with result: %s%n", instanceId, result);
 
-    } catch (InterruptedException e) {
+    } catch (TimeoutException | InterruptedException e) {
       throw new RuntimeException(e);
     }
   }
-}
+}

examples/src/main/java/io/dapr/examples/workflows/childworkflow/DemoChildWorkflow.java

@@ -38,16 +38,7 @@ public WorkflowStub create() {
       ctx.getLogger().info("ChildWorkflow received input: " + childWorkflowInput);
 
       ctx.getLogger().info("ChildWorkflow is calling Activity: " + ReverseActivity.class.getName());
-      String result = new String("");
-
-      try {
-        result = ctx.callActivity(ReverseActivity.class.getName(), childWorkflowInput, options, String.class).await();
-      } catch (OrchestratorBlockedException ex) {
-        throw ex;
-      } catch (Exception ex) {
-        System.out.println("EX:" + ex.getMessage());
-        ctx.getLogger().warn("Ex is what instance of " + (ex.getMessage()));
-      }
+      String result = ctx.callActivity(ReverseActivity.class.getName(), childWorkflowInput, options, String.class).await();
 
       ctx.getLogger().info("ChildWorkflow finished with: " + result);
       ctx.complete(result);

examples/src/main/java/io/dapr/examples/workflows/childworkflow/ReverseActivity.java

@@ -30,13 +30,6 @@ public Object run(WorkflowActivityContext ctx) {
     logger.info("Message Received from input: " + message);
     logger.info("Sending message to output: " + newMessage);
 
-    throw new RuntimeException("abcdef");
-  }
-}
-
-class MyCustomException extends RuntimeException {
-
-  public MyCustomException(String message) {
-    super(message);
+    return newMessage;
   }
 }