File tree Expand file tree Collapse file tree 3 files changed +27
-11
lines changed
src/main/java/com/uber/cadence/migration Expand file tree Collapse file tree 3 files changed +27
-11
lines changed Original file line number Diff line number Diff line change 19
19
20
20
import com .uber .cadence .RequestCancelWorkflowExecutionRequest ;
21
21
import com .uber .cadence .StartWorkflowExecutionRequest ;
22
- import com .uber .cadence .StartWorkflowExecutionResponse ;
23
22
import com .uber .cadence .activity .ActivityMethod ;
24
23
25
24
public interface MigrationActivities {
Original file line number Diff line number Diff line change 19
19
20
20
import com .uber .cadence .RequestCancelWorkflowExecutionRequest ;
21
21
import com .uber .cadence .StartWorkflowExecutionRequest ;
22
- import com .uber .cadence .StartWorkflowExecutionResponse ;
23
22
import com .uber .cadence .WorkflowExecutionAlreadyStartedError ;
24
23
import com .uber .cadence .client .WorkflowClient ;
25
24
import com .uber .cadence .workflow .Workflow ;
@@ -37,9 +36,11 @@ public MigrationActivitiesImpl(
37
36
public StartWorkflowInNewResponse startWorkflowInNewDomain (
38
37
StartWorkflowExecutionRequest request ) {
39
38
try {
40
- return new StartWorkflowInNewResponse (clientInNewDomain .getService ().StartWorkflowExecution (request ),"New workflow starting successful" );
39
+ return new StartWorkflowInNewResponse (
40
+ clientInNewDomain .getService ().StartWorkflowExecution (request ),
41
+ "New workflow starting successful" );
41
42
} catch (WorkflowExecutionAlreadyStartedError e ) {
42
- return new StartWorkflowInNewResponse (null ,"Workflow already started" );
43
+ return new StartWorkflowInNewResponse (null , "Workflow already started" );
43
44
} catch (Exception e ) {
44
45
throw Workflow .wrap (e );
45
46
}
Original file line number Diff line number Diff line change
1
+ /*
2
+ * Copyright 2012-2016 Amazon.com, Inc. or its affiliates. All Rights Reserved.
3
+ *
4
+ * Modifications copyright (C) 2017 Uber Technologies, Inc.
5
+ *
6
+ * Licensed under the Apache License, Version 2.0 (the "License"). You may not
7
+ * use this file except in compliance with the License. A copy of the License is
8
+ * located at
9
+ *
10
+ * http://aws.amazon.com/apache2.0
11
+ *
12
+ * or in the "license" file accompanying this file. This file is distributed on
13
+ * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either
14
+ * express or implied. See the License for the specific language governing
15
+ * permissions and limitations under the License.
16
+ */
17
+
1
18
package com .uber .cadence .migration ;
2
19
3
20
import com .uber .cadence .StartWorkflowExecutionResponse ;
4
21
5
22
public class StartWorkflowInNewResponse {
6
- StartWorkflowExecutionResponse startWorkflowExecutionResponse ;
7
- String message ;
8
-
9
- StartWorkflowInNewResponse (StartWorkflowExecutionResponse startWorkflowResponse , String msg ){
10
- startWorkflowExecutionResponse = startWorkflowResponse ;
11
- message = msg ;
12
- }
23
+ StartWorkflowExecutionResponse startWorkflowExecutionResponse ;
24
+ String message ;
13
25
26
+ StartWorkflowInNewResponse (StartWorkflowExecutionResponse startWorkflowResponse , String msg ) {
27
+ startWorkflowExecutionResponse = startWorkflowResponse ;
28
+ message = msg ;
29
+ }
14
30
}
You can’t perform that action at this time.
0 commit comments