bug fix for workflowAlreadyStarted

Author: abhishekj720

src/main/java/com/uber/cadence/migration/MigrationActivities.java

@@ -24,7 +24,7 @@
 
 public interface MigrationActivities {
   @ActivityMethod
-  StartWorkflowExecutionResponse startWorkflowInNewDomain(StartWorkflowExecutionRequest request);
+  StartWorkflowInNewResponse startWorkflowInNewDomain(StartWorkflowExecutionRequest request);
 
   @ActivityMethod
   void cancelWorkflowInCurrentDomain(RequestCancelWorkflowExecutionRequest request);

src/main/java/com/uber/cadence/migration/MigrationActivitiesImpl.java

@@ -20,6 +20,7 @@
 import com.uber.cadence.RequestCancelWorkflowExecutionRequest;
 import com.uber.cadence.StartWorkflowExecutionRequest;
 import com.uber.cadence.StartWorkflowExecutionResponse;
+import com.uber.cadence.WorkflowExecutionAlreadyStartedError;
 import com.uber.cadence.client.WorkflowClient;
 import com.uber.cadence.workflow.Workflow;
 
@@ -33,10 +34,12 @@ public MigrationActivitiesImpl(
   }
 
   @Override
-  public StartWorkflowExecutionResponse startWorkflowInNewDomain(
+  public StartWorkflowInNewResponse startWorkflowInNewDomain(
       StartWorkflowExecutionRequest request) {
     try {
-      return clientInNewDomain.getService().StartWorkflowExecution(request);
+      return new StartWorkflowInNewResponse(clientInNewDomain.getService().StartWorkflowExecution(request),"New workflow starting successful");
+    } catch (WorkflowExecutionAlreadyStartedError e) {
+      return new StartWorkflowInNewResponse(null,"Workflow already started");
     } catch (Exception e) {
       throw Workflow.wrap(e);
     }

src/main/java/com/uber/cadence/migration/StartWorkflowInNewResponse.java

@@ -0,0 +1,14 @@
+package com.uber.cadence.migration;
+
+import com.uber.cadence.StartWorkflowExecutionResponse;
+
+public class StartWorkflowInNewResponse {
+    StartWorkflowExecutionResponse startWorkflowExecutionResponse;
+    String message;
+
+    StartWorkflowInNewResponse(StartWorkflowExecutionResponse startWorkflowResponse, String msg){
+        startWorkflowExecutionResponse = startWorkflowResponse;
+        message = msg;
+    }
+
+}