File tree Expand file tree Collapse file tree 3 files changed +10
-5
lines changed
src/main/java/com/uber/cadence/samples/hello Expand file tree Collapse file tree 3 files changed +10
-5
lines changed Original file line number Diff line number Diff line change @@ -35,7 +35,7 @@ repositories {
35
35
dependencies {
36
36
errorproneJavac(" com.google.errorprone:javac:9+181-r4173-1" )
37
37
errorprone(" com.google.errorprone:error_prone_core:2.3.1" )
38
- compile group : ' com.uber.cadence' , name : ' cadence-client' , version : ' 3.1 .0'
38
+ compile group : ' com.uber.cadence' , name : ' cadence-client' , version : ' 3.3 .0'
39
39
compile group : ' commons-configuration' , name : ' commons-configuration' , version : ' 1.9'
40
40
compile group : ' ch.qos.logback' , name : ' logback-classic' , version : ' 1.2.3'
41
41
compile group : ' com.uber.m3' , name : ' tally-core' , version : ' 0.10.0'
Original file line number Diff line number Diff line change 19
19
20
20
import static com .uber .cadence .samples .common .SampleConstants .DOMAIN ;
21
21
22
+ import com .uber .cadence .FeatureFlags ;
22
23
import com .uber .cadence .client .WorkflowClient ;
23
24
import com .uber .cadence .client .WorkflowClientOptions ;
24
25
import com .uber .cadence .client .WorkflowOptions ;
@@ -97,7 +98,11 @@ public static void main(String[] args) throws Exception {
97
98
// ClientOptions.newBuilder().setRpcTimeout(5 * 1000).build();
98
99
WorkflowClient workflowClient =
99
100
WorkflowClient .newInstance (
100
- new WorkflowServiceTChannel (ClientOptions .defaultInstance ()),
101
+ new WorkflowServiceTChannel (
102
+ ClientOptions .newBuilder ()
103
+ .setFeatureFlags (
104
+ new FeatureFlags ().setWorkflowExecutionAlreadyCompletedErrorEnabled (true ))
105
+ .build ()),
101
106
WorkflowClientOptions .newBuilder ().setDomain (DOMAIN ).build ());
102
107
// Get worker to poll the task list.
103
108
WorkerFactory factory = WorkerFactory .newInstance (workflowClient );
Original file line number Diff line number Diff line change 50
50
import org .apache .commons .lang .RandomStringUtils ;
51
51
52
52
/**
53
- * Demonstrates signalling a workflow, and wait until it's applied and get a
54
- * response. This should be much performant(lower latency) than using signal+query approach.
55
- * Requires a Cadence server to be running.
53
+ * Demonstrates signalling a workflow, and wait until it's applied and get a response. This should
54
+ * be much performant(lower latency) than using signal+query approach. Requires a Cadence server to
55
+ * be running.
56
56
*/
57
57
@ SuppressWarnings ("ALL" )
58
58
public class HelloSignalAndResponse {
You can’t perform that action at this time.
0 commit comments