diff --git a/.gitignore b/.gitignore index 723ef36..0580915 100644 --- a/.gitignore +++ b/.gitignore @@ -1 +1,3 @@ -.idea \ No newline at end of file +.idea +build +.gradle diff --git a/src/main/java/com/afterpay/ds/cadence/App.java b/src/main/java/com/afterpay/ds/cadence/App.java deleted file mode 100644 index 73077dc..0000000 --- a/src/main/java/com/afterpay/ds/cadence/App.java +++ /dev/null @@ -1,7 +0,0 @@ -package com.afterpay.ds.cadence; - -import com.uber.cadence.worker.Worker; - -public class App { - -} diff --git a/src/main/java/com/afterpay/ds/cadence/HelloCadence.java b/src/main/java/com/afterpay/ds/cadence/HelloCadence.java index 35bd2ff..8c37807 100644 --- a/src/main/java/com/afterpay/ds/cadence/HelloCadence.java +++ b/src/main/java/com/afterpay/ds/cadence/HelloCadence.java @@ -14,14 +14,14 @@ public class HelloCadence { private static Logger logger = Workflow.getLogger(HelloCadence.class); public static void main(String[] args) { - Worker.Factory factory = new Worker.Factory("localhost",7933, "test-domain-au"); - Worker worker = factory.newWorker("aaa"); + Worker.Factory factory = new Worker.Factory("192.168.0.249",7933, "domain"); + Worker worker = factory.newWorker("helloWorldTaskList"); worker.registerWorkflowImplementationTypes(HelloWorldImpl.class); factory.start(); } public interface HelloWorld { - @WorkflowMethod + @WorkflowMethod(executionStartToCloseTimeoutSeconds = 60, taskList = "helloWorldTaskList") void sayHello(String name); @SignalMethod @@ -45,7 +45,7 @@ public class HelloCadence { // } // logger.info(++count + ": " + greeting + " " + name + "!"); - Workflow.sleep(Duration.ofSeconds(30)); + Workflow.sleep(Duration.ofSeconds(10)); logger.info(++count + ": " + greeting + " " + name + "!"); } diff --git a/src/main/java/com/afterpay/ds/cadence/StartWorkflow.java b/src/main/java/com/afterpay/ds/cadence/StartWorkflow.java new file mode 100644 index 0000000..5ed0db6 --- /dev/null +++ b/src/main/java/com/afterpay/ds/cadence/StartWorkflow.java @@ -0,0 +1,25 @@ +package com.afterpay.ds.cadence; + +import com.afterpay.ds.cadence.HelloCadence.HelloWorld; +import com.uber.cadence.WorkflowExecution; +import com.uber.cadence.client.WorkflowClient; + +public class StartWorkflow { + public static void main(String[] args) throws InterruptedException { + WorkflowClient workflowClient = WorkflowClient.newInstance("192.168.0.249", 7933, "domain"); + + for (int i = 0; i < 100; i++) { + + // Create a workflow stub. + HelloWorld workflow = workflowClient.newWorkflowStub(HelloWorld.class); + + // Returns as soon as the workflow starts. + WorkflowExecution workflowExecution = WorkflowClient.start(workflow::sayHello, args[0] + i); + + System.out.println("Started process file workflow with workflowId=\"" + workflowExecution.getWorkflowId() + "\" and runId=\"" + workflowExecution.getRunId() + "\""); + } + + System.exit(0); + } + +}