More code formatting

Author: psevestre

saas-modules/temporal/src/test/java/com/baeldung/temporal/HelloWorkerUnitTest.java

@@ -39,15 +39,6 @@ public void startWorker() {
         HelloWorkflowRegistrar.newInstance().register(worker);
         client = testEnv.getWorkflowClient();
 
-//        var serviceStubs = WorkflowServiceStubs.newServiceStubs(WorkflowServiceStubsOptions
-//          .newBuilder()
-//            .setTarget("localhost:7233")
-//            .setEnableKeepAlive(true)
-//            .setEnableHttps(false)
-//          .build());
-//
-//        client = WorkflowClient.newInstance(serviceStubs);
-
         testEnv.start();
     }
 

saas-modules/temporal/src/test/java/com/baeldung/temporal/HelloWorkflowIntegrationTest.java

@@ -2,20 +2,19 @@
 
 import com.baeldung.temporal.workflows.hello.HelloWorkflow;
 import com.baeldung.temporal.workflows.hello.HelloWorkflowRegistrar;
-import com.baeldung.temporal.workflows.hellov2.HelloWorkflowV2;
 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.worker.WorkerOptions;
 import org.junit.jupiter.api.AfterEach;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 import java.util.UUID;
+import java.util.concurrent.ExecutionException;
 
 import static org.junit.jupiter.api.Assertions.assertEquals;
 
@@ -52,8 +51,8 @@ public void stopWorker() {
     @Test
     void givenPerson_whenSayHello_thenSuccess() {
 
-        WorkflowServiceStubs service = WorkflowServiceStubs.newLocalServiceStubs();
-        WorkflowClient client = WorkflowClient.newInstance(service);
+        var service = WorkflowServiceStubs.newLocalServiceStubs();
+        var client = WorkflowClient.newInstance(service);
 
         var wfid = UUID.randomUUID().toString();
 
@@ -68,9 +67,35 @@ void givenPerson_whenSayHello_thenSuccess() {
         // Run the workflow synchronously
         var result = workflow.hello("Baeldung");
         assertEquals("Hello, Baeldung", result);
-
     }
 
+    @Test
+    void givenPerson_whenSayHelloAsync_thenSuccess() throws ExecutionException, InterruptedException {
+
+        var service = WorkflowServiceStubs.newLocalServiceStubs();
+        var client = WorkflowClient.newInstance(service);
+
+        var wfid = UUID.randomUUID().toString();
+
+        var workflow = client.newWorkflowStub(
+          HelloWorkflow.class,
+          WorkflowOptions.newBuilder()
+            .setTaskQueue(QUEUE_NAME)
+            .setWorkflowId(wfid)
+            .build()
+        );
+
+        var execution = WorkflowClient.start(workflow::hello,"Baeldung");
+
+        var workflowStub = client.newUntypedWorkflowStub(execution.getWorkflowId());
 
+        // Retrieve a CompletableFuture we can use to wait for the result.
+        var future = workflowStub.getResultAsync(String.class);
+        log.info("Waiting for workflow to complete...");
+        var result = future.get();
+        log.info("Workflow completed with result: {}", result);
+        assertEquals("Hello, Baeldung", result);
+
+    }
 
 }