From a054838328a6329928474e3b267b7acbc56f3b00 Mon Sep 17 00:00:00 2001 From: Quanzheng Long Date: Mon, 10 May 2021 11:53:28 -0700 Subject: [PATCH] Fix domain for samples --- README.md | 18 ++++++++++++------ .../samples/bookingsaga/TripBookingSaga.java | 7 ++++++- .../samples/common/QueryWorkflowExecution.java | 7 ++++++- .../samples/common/SampleConstants.java | 2 +- .../fileprocessing/FileProcessingStarter.java | 7 ++++++- .../fileprocessing/FileProcessingWorker.java | 7 ++++++- .../cadence/samples/hello/HelloActivity.java | 7 ++++++- .../samples/hello/HelloActivityRetry.java | 7 ++++++- .../uber/cadence/samples/hello/HelloAsync.java | 7 ++++++- .../hello/HelloAsyncActivityCompletion.java | 7 ++++++- .../samples/hello/HelloAsyncLambda.java | 7 ++++++- .../uber/cadence/samples/hello/HelloChild.java | 7 ++++++- .../uber/cadence/samples/hello/HelloCron.java | 5 ++++- .../cadence/samples/hello/HelloException.java | 7 ++++++- .../samples/hello/HelloLocalActivity.java | 7 ++++++- .../cadence/samples/hello/HelloMetric.java | 7 ++++++- .../cadence/samples/hello/HelloPeriodic.java | 7 ++++++- .../uber/cadence/samples/hello/HelloQuery.java | 7 ++++++- .../uber/cadence/samples/hello/HelloSaga.java | 7 ++++++- .../samples/hello/HelloSearchAttributes.java | 5 ++++- .../cadence/samples/hello/HelloSideEffect.java | 7 ++++++- .../cadence/samples/hello/HelloSignal.java | 7 ++++++- .../samples/hello/HelloWorkerSetup.java | 7 ++++++- 23 files changed, 135 insertions(+), 28 deletions(-) diff --git a/README.md b/README.md index d54b00320..40fb6bfab 100644 --- a/README.md +++ b/README.md @@ -52,26 +52,32 @@ Run Cadence Server using Docker Compose: curl -O https://raw.githubusercontent.com/uber/cadence/master/docker/docker-compose.yml docker-compose up -If this does not work, see the instructions for running Cadence Server at https://github.com/uber/cadence/blob/master/README.md. +If this does not work, see the instructions for running Cadence Server +at https://github.com/uber/cadence/blob/master/README.md. ## Register the Domain -To register the *sample* domain, run the following command once before running any samples: +To register the *samples-domain* domain, run the following command once before running any samples: ./gradlew -q execute -PmainClass=com.uber.cadence.samples.common.RegisterDomain +Or using Cadence CLI: + +``` +cadence --domain samples-domain domain register +``` + ## See Cadence UI The Cadence Server running in a docker container includes a Web UI. Connect to [http://localhost:8088](http://localhost:8088). -Enter the *sample* domain. You'll see a "No Results" page. After running any sample, change the -filter in the +Enter the *samples-domain* domain. You'll see a "No Results" page. After running any sample, change the filter in the top right corner from "Open" to "Closed" to see the list of the completed workflows. -Click on a *RUN ID* of a workflow to see more details about it. Try different view formats to get a different level -of details about the execution history. +Click on a *RUN ID* of a workflow to see more details about it. Try different view formats to get a different level of +details about the execution history. ## Install Cadence CLI diff --git a/src/main/java/com/uber/cadence/samples/bookingsaga/TripBookingSaga.java b/src/main/java/com/uber/cadence/samples/bookingsaga/TripBookingSaga.java index 00a764b92..086379856 100644 --- a/src/main/java/com/uber/cadence/samples/bookingsaga/TripBookingSaga.java +++ b/src/main/java/com/uber/cadence/samples/bookingsaga/TripBookingSaga.java @@ -17,7 +17,10 @@ package com.uber.cadence.samples.bookingsaga; +import static com.uber.cadence.samples.common.SampleConstants.DOMAIN; + import com.uber.cadence.client.WorkflowClient; +import com.uber.cadence.client.WorkflowClientOptions; import com.uber.cadence.client.WorkflowException; import com.uber.cadence.serviceclient.ClientOptions; import com.uber.cadence.serviceclient.WorkflowServiceTChannel; @@ -32,7 +35,9 @@ public class TripBookingSaga { public static void main(String[] args) { // Get a new client WorkflowClient workflowClient = - WorkflowClient.newInstance(new WorkflowServiceTChannel(ClientOptions.defaultInstance())); + WorkflowClient.newInstance( + new WorkflowServiceTChannel(ClientOptions.defaultInstance()), + WorkflowClientOptions.newBuilder().setDomain(DOMAIN).build()); // Get worker to poll the common task list. WorkerFactory factory = WorkerFactory.newInstance(workflowClient); final Worker workerForCommonTaskList = factory.newWorker(TASK_LIST); diff --git a/src/main/java/com/uber/cadence/samples/common/QueryWorkflowExecution.java b/src/main/java/com/uber/cadence/samples/common/QueryWorkflowExecution.java index 8bc826a6b..e04f3fe2b 100644 --- a/src/main/java/com/uber/cadence/samples/common/QueryWorkflowExecution.java +++ b/src/main/java/com/uber/cadence/samples/common/QueryWorkflowExecution.java @@ -17,8 +17,11 @@ package com.uber.cadence.samples.common; +import static com.uber.cadence.samples.common.SampleConstants.DOMAIN; + import com.uber.cadence.WorkflowExecution; import com.uber.cadence.client.WorkflowClient; +import com.uber.cadence.client.WorkflowClientOptions; import com.uber.cadence.client.WorkflowStub; import com.uber.cadence.serviceclient.ClientOptions; import com.uber.cadence.serviceclient.IWorkflowService; @@ -52,7 +55,9 @@ public static void main(String[] args) throws Exception { String runId = args[1]; workflowExecution.setRunId(runId); } - WorkflowClient client = WorkflowClient.newInstance(cadenceService); + WorkflowClient client = + WorkflowClient.newInstance( + cadenceService, WorkflowClientOptions.newBuilder().setDomain(DOMAIN).build()); WorkflowStub workflow = client.newUntypedWorkflowStub(workflowExecution, Optional.empty()); String result = workflow.query(queryType, String.class); diff --git a/src/main/java/com/uber/cadence/samples/common/SampleConstants.java b/src/main/java/com/uber/cadence/samples/common/SampleConstants.java index 746f1e9d6..8f5cf8dc7 100644 --- a/src/main/java/com/uber/cadence/samples/common/SampleConstants.java +++ b/src/main/java/com/uber/cadence/samples/common/SampleConstants.java @@ -18,5 +18,5 @@ package com.uber.cadence.samples.common; public class SampleConstants { - public static final String DOMAIN = "sample"; + public static final String DOMAIN = "samples-domain"; } diff --git a/src/main/java/com/uber/cadence/samples/fileprocessing/FileProcessingStarter.java b/src/main/java/com/uber/cadence/samples/fileprocessing/FileProcessingStarter.java index e3b7c9cb7..36390e127 100644 --- a/src/main/java/com/uber/cadence/samples/fileprocessing/FileProcessingStarter.java +++ b/src/main/java/com/uber/cadence/samples/fileprocessing/FileProcessingStarter.java @@ -17,7 +17,10 @@ package com.uber.cadence.samples.fileprocessing; +import static com.uber.cadence.samples.common.SampleConstants.DOMAIN; + import com.uber.cadence.client.WorkflowClient; +import com.uber.cadence.client.WorkflowClientOptions; import com.uber.cadence.serviceclient.ClientOptions; import com.uber.cadence.serviceclient.WorkflowServiceTChannel; import java.net.URL; @@ -28,7 +31,9 @@ public class FileProcessingStarter { public static void main(String[] args) throws Exception { // Get a new client WorkflowClient workflowClient = - WorkflowClient.newInstance(new WorkflowServiceTChannel(ClientOptions.defaultInstance())); + WorkflowClient.newInstance( + new WorkflowServiceTChannel(ClientOptions.defaultInstance()), + WorkflowClientOptions.newBuilder().setDomain(DOMAIN).build()); FileProcessingWorkflow workflow = workflowClient.newWorkflowStub(FileProcessingWorkflow.class); System.out.println("Executing FileProcessingWorkflow"); diff --git a/src/main/java/com/uber/cadence/samples/fileprocessing/FileProcessingWorker.java b/src/main/java/com/uber/cadence/samples/fileprocessing/FileProcessingWorker.java index 8ab6f8e01..f7124edfc 100644 --- a/src/main/java/com/uber/cadence/samples/fileprocessing/FileProcessingWorker.java +++ b/src/main/java/com/uber/cadence/samples/fileprocessing/FileProcessingWorker.java @@ -17,7 +17,10 @@ package com.uber.cadence.samples.fileprocessing; +import static com.uber.cadence.samples.common.SampleConstants.DOMAIN; + import com.uber.cadence.client.WorkflowClient; +import com.uber.cadence.client.WorkflowClientOptions; import com.uber.cadence.serviceclient.ClientOptions; import com.uber.cadence.serviceclient.WorkflowServiceTChannel; import com.uber.cadence.worker.Worker; @@ -41,7 +44,9 @@ public static void main(String[] args) { // Get a new client WorkflowClient workflowClient = - WorkflowClient.newInstance(new WorkflowServiceTChannel(ClientOptions.defaultInstance())); + WorkflowClient.newInstance( + new WorkflowServiceTChannel(ClientOptions.defaultInstance()), + WorkflowClientOptions.newBuilder().setDomain(DOMAIN).build()); // Get worker to poll the common task list. WorkerFactory factory = WorkerFactory.newInstance(workflowClient); final Worker workerForCommonTaskList = factory.newWorker(TASK_LIST); diff --git a/src/main/java/com/uber/cadence/samples/hello/HelloActivity.java b/src/main/java/com/uber/cadence/samples/hello/HelloActivity.java index e5c37f9f5..75ada2c00 100644 --- a/src/main/java/com/uber/cadence/samples/hello/HelloActivity.java +++ b/src/main/java/com/uber/cadence/samples/hello/HelloActivity.java @@ -17,8 +17,11 @@ package com.uber.cadence.samples.hello; +import static com.uber.cadence.samples.common.SampleConstants.DOMAIN; + import com.uber.cadence.activity.ActivityMethod; import com.uber.cadence.client.WorkflowClient; +import com.uber.cadence.client.WorkflowClientOptions; import com.uber.cadence.serviceclient.ClientOptions; import com.uber.cadence.serviceclient.WorkflowServiceTChannel; import com.uber.cadence.worker.Worker; @@ -77,7 +80,9 @@ public static void main(String[] args) { // NOTE: to set a different options, you can do like this: // ClientOptions.newBuilder().setRpcTimeout(5 * 1000).build(); WorkflowClient workflowClient = - WorkflowClient.newInstance(new WorkflowServiceTChannel(ClientOptions.defaultInstance())); + WorkflowClient.newInstance( + new WorkflowServiceTChannel(ClientOptions.defaultInstance()), + WorkflowClientOptions.newBuilder().setDomain(DOMAIN).build()); // Get worker to poll the task list. WorkerFactory factory = WorkerFactory.newInstance(workflowClient); Worker worker = factory.newWorker(TASK_LIST); diff --git a/src/main/java/com/uber/cadence/samples/hello/HelloActivityRetry.java b/src/main/java/com/uber/cadence/samples/hello/HelloActivityRetry.java index 9086b459e..050a448e8 100644 --- a/src/main/java/com/uber/cadence/samples/hello/HelloActivityRetry.java +++ b/src/main/java/com/uber/cadence/samples/hello/HelloActivityRetry.java @@ -17,8 +17,11 @@ package com.uber.cadence.samples.hello; +import static com.uber.cadence.samples.common.SampleConstants.DOMAIN; + import com.uber.cadence.activity.ActivityOptions; import com.uber.cadence.client.WorkflowClient; +import com.uber.cadence.client.WorkflowClientOptions; import com.uber.cadence.client.WorkflowOptions; import com.uber.cadence.common.RetryOptions; import com.uber.cadence.serviceclient.ClientOptions; @@ -104,7 +107,9 @@ public static void main(String[] args) { // NOTE: to set a different options, you can do like this: // ClientOptions.newBuilder().setRpcTimeout(5 * 1000).build(); WorkflowClient workflowClient = - WorkflowClient.newInstance(new WorkflowServiceTChannel(ClientOptions.defaultInstance())); + WorkflowClient.newInstance( + new WorkflowServiceTChannel(ClientOptions.defaultInstance()), + WorkflowClientOptions.newBuilder().setDomain(DOMAIN).build()); // Get worker to poll the task list. WorkerFactory factory = WorkerFactory.newInstance(workflowClient); Worker worker = factory.newWorker(TASK_LIST); diff --git a/src/main/java/com/uber/cadence/samples/hello/HelloAsync.java b/src/main/java/com/uber/cadence/samples/hello/HelloAsync.java index 93cf8c72d..33786da7f 100644 --- a/src/main/java/com/uber/cadence/samples/hello/HelloAsync.java +++ b/src/main/java/com/uber/cadence/samples/hello/HelloAsync.java @@ -17,8 +17,11 @@ package com.uber.cadence.samples.hello; +import static com.uber.cadence.samples.common.SampleConstants.DOMAIN; + import com.uber.cadence.activity.ActivityMethod; import com.uber.cadence.client.WorkflowClient; +import com.uber.cadence.client.WorkflowClientOptions; import com.uber.cadence.serviceclient.ClientOptions; import com.uber.cadence.serviceclient.WorkflowServiceTChannel; import com.uber.cadence.worker.Worker; @@ -84,7 +87,9 @@ public static void main(String[] args) { // NOTE: to set a different options, you can do like this: // ClientOptions.newBuilder().setRpcTimeout(5 * 1000).build(); WorkflowClient workflowClient = - WorkflowClient.newInstance(new WorkflowServiceTChannel(ClientOptions.defaultInstance())); + WorkflowClient.newInstance( + new WorkflowServiceTChannel(ClientOptions.defaultInstance()), + WorkflowClientOptions.newBuilder().setDomain(DOMAIN).build()); // Get worker to poll the task list. WorkerFactory factory = WorkerFactory.newInstance(workflowClient); Worker worker = factory.newWorker(TASK_LIST); diff --git a/src/main/java/com/uber/cadence/samples/hello/HelloAsyncActivityCompletion.java b/src/main/java/com/uber/cadence/samples/hello/HelloAsyncActivityCompletion.java index cc3f66e1b..b048d4a97 100644 --- a/src/main/java/com/uber/cadence/samples/hello/HelloAsyncActivityCompletion.java +++ b/src/main/java/com/uber/cadence/samples/hello/HelloAsyncActivityCompletion.java @@ -17,10 +17,13 @@ package com.uber.cadence.samples.hello; +import static com.uber.cadence.samples.common.SampleConstants.DOMAIN; + import com.uber.cadence.activity.Activity; import com.uber.cadence.activity.ActivityMethod; import com.uber.cadence.client.ActivityCompletionClient; import com.uber.cadence.client.WorkflowClient; +import com.uber.cadence.client.WorkflowClientOptions; import com.uber.cadence.serviceclient.ClientOptions; import com.uber.cadence.serviceclient.WorkflowServiceTChannel; import com.uber.cadence.worker.Worker; @@ -106,7 +109,9 @@ public static void main(String[] args) throws ExecutionException, InterruptedExc // NOTE: to set a different options, you can do like this: // ClientOptions.newBuilder().setRpcTimeout(5 * 1000).build(); WorkflowClient workflowClient = - WorkflowClient.newInstance(new WorkflowServiceTChannel(ClientOptions.defaultInstance())); + WorkflowClient.newInstance( + new WorkflowServiceTChannel(ClientOptions.defaultInstance()), + WorkflowClientOptions.newBuilder().setDomain(DOMAIN).build()); // Get worker to poll the task list. WorkerFactory factory = WorkerFactory.newInstance(workflowClient); Worker worker = factory.newWorker(TASK_LIST); diff --git a/src/main/java/com/uber/cadence/samples/hello/HelloAsyncLambda.java b/src/main/java/com/uber/cadence/samples/hello/HelloAsyncLambda.java index aac3d30bf..0111eecb5 100644 --- a/src/main/java/com/uber/cadence/samples/hello/HelloAsyncLambda.java +++ b/src/main/java/com/uber/cadence/samples/hello/HelloAsyncLambda.java @@ -17,8 +17,11 @@ package com.uber.cadence.samples.hello; +import static com.uber.cadence.samples.common.SampleConstants.DOMAIN; + import com.uber.cadence.activity.ActivityOptions; import com.uber.cadence.client.WorkflowClient; +import com.uber.cadence.client.WorkflowClientOptions; import com.uber.cadence.client.WorkflowOptions; import com.uber.cadence.serviceclient.ClientOptions; import com.uber.cadence.serviceclient.WorkflowServiceTChannel; @@ -105,7 +108,9 @@ public static void main(String[] args) { // NOTE: to set a different options, you can do like this: // ClientOptions.newBuilder().setRpcTimeout(5 * 1000).build(); WorkflowClient workflowClient = - WorkflowClient.newInstance(new WorkflowServiceTChannel(ClientOptions.defaultInstance())); + WorkflowClient.newInstance( + new WorkflowServiceTChannel(ClientOptions.defaultInstance()), + WorkflowClientOptions.newBuilder().setDomain(DOMAIN).build()); // Get worker to poll the task list. WorkerFactory factory = WorkerFactory.newInstance(workflowClient); Worker worker = factory.newWorker(TASK_LIST); diff --git a/src/main/java/com/uber/cadence/samples/hello/HelloChild.java b/src/main/java/com/uber/cadence/samples/hello/HelloChild.java index 044d77911..a32ed3ac4 100644 --- a/src/main/java/com/uber/cadence/samples/hello/HelloChild.java +++ b/src/main/java/com/uber/cadence/samples/hello/HelloChild.java @@ -17,8 +17,11 @@ package com.uber.cadence.samples.hello; +import static com.uber.cadence.samples.common.SampleConstants.DOMAIN; + import com.uber.cadence.WorkflowExecution; import com.uber.cadence.client.WorkflowClient; +import com.uber.cadence.client.WorkflowClientOptions; import com.uber.cadence.serviceclient.ClientOptions; import com.uber.cadence.serviceclient.WorkflowServiceTChannel; import com.uber.cadence.worker.Worker; @@ -92,7 +95,9 @@ public static void main(String[] args) { // NOTE: to set a different options, you can do like this: // ClientOptions.newBuilder().setRpcTimeout(5 * 1000).build(); WorkflowClient workflowClient = - WorkflowClient.newInstance(new WorkflowServiceTChannel(ClientOptions.defaultInstance())); + WorkflowClient.newInstance( + new WorkflowServiceTChannel(ClientOptions.defaultInstance()), + WorkflowClientOptions.newBuilder().setDomain(DOMAIN).build()); // Get worker to poll the task list. WorkerFactory factory = WorkerFactory.newInstance(workflowClient); Worker worker = factory.newWorker(TASK_LIST); diff --git a/src/main/java/com/uber/cadence/samples/hello/HelloCron.java b/src/main/java/com/uber/cadence/samples/hello/HelloCron.java index bf89b7d65..6b5013d09 100644 --- a/src/main/java/com/uber/cadence/samples/hello/HelloCron.java +++ b/src/main/java/com/uber/cadence/samples/hello/HelloCron.java @@ -25,6 +25,7 @@ import com.uber.cadence.activity.Activity; import com.uber.cadence.activity.ActivityOptions; import com.uber.cadence.client.WorkflowClient; +import com.uber.cadence.client.WorkflowClientOptions; import com.uber.cadence.common.CronSchedule; import com.uber.cadence.serviceclient.ClientOptions; import com.uber.cadence.serviceclient.WorkflowServiceTChannel; @@ -89,7 +90,9 @@ public static void main(String[] args) throws InterruptedException { // Get a new client // NOTE: to set a different options, you can do like this: // ClientOptions.newBuilder().setRpcTimeout(5 * 1000).build(); - WorkflowClient workflowClient = WorkflowClient.newInstance(cadenceService); + WorkflowClient workflowClient = + WorkflowClient.newInstance( + cadenceService, WorkflowClientOptions.newBuilder().setDomain(DOMAIN).build()); // Get worker to poll the task list. WorkerFactory factory = WorkerFactory.newInstance(workflowClient); Worker worker = factory.newWorker(TASK_LIST); diff --git a/src/main/java/com/uber/cadence/samples/hello/HelloException.java b/src/main/java/com/uber/cadence/samples/hello/HelloException.java index 95b2b34b9..62baa5f8d 100644 --- a/src/main/java/com/uber/cadence/samples/hello/HelloException.java +++ b/src/main/java/com/uber/cadence/samples/hello/HelloException.java @@ -17,9 +17,12 @@ package com.uber.cadence.samples.hello; +import static com.uber.cadence.samples.common.SampleConstants.DOMAIN; + import com.google.common.base.Throwables; import com.uber.cadence.activity.ActivityOptions; import com.uber.cadence.client.WorkflowClient; +import com.uber.cadence.client.WorkflowClientOptions; import com.uber.cadence.client.WorkflowException; import com.uber.cadence.client.WorkflowOptions; import com.uber.cadence.serviceclient.ClientOptions; @@ -164,7 +167,9 @@ public static void main(String[] args) { // NOTE: to set a different options, you can do like this: // ClientOptions.newBuilder().setRpcTimeout(5 * 1000).build(); WorkflowClient workflowClient = - WorkflowClient.newInstance(new WorkflowServiceTChannel(ClientOptions.defaultInstance())); + WorkflowClient.newInstance( + new WorkflowServiceTChannel(ClientOptions.defaultInstance()), + WorkflowClientOptions.newBuilder().setDomain(DOMAIN).build()); // Get worker to poll the task list. WorkerFactory factory = WorkerFactory.newInstance(workflowClient); Worker worker = factory.newWorker(TASK_LIST); diff --git a/src/main/java/com/uber/cadence/samples/hello/HelloLocalActivity.java b/src/main/java/com/uber/cadence/samples/hello/HelloLocalActivity.java index fe349a6ac..33dccdbc5 100644 --- a/src/main/java/com/uber/cadence/samples/hello/HelloLocalActivity.java +++ b/src/main/java/com/uber/cadence/samples/hello/HelloLocalActivity.java @@ -17,8 +17,11 @@ package com.uber.cadence.samples.hello; +import static com.uber.cadence.samples.common.SampleConstants.DOMAIN; + import com.uber.cadence.activity.ActivityMethod; import com.uber.cadence.client.WorkflowClient; +import com.uber.cadence.client.WorkflowClientOptions; import com.uber.cadence.serviceclient.ClientOptions; import com.uber.cadence.serviceclient.WorkflowServiceTChannel; import com.uber.cadence.worker.Worker; @@ -77,7 +80,9 @@ public static void main(String[] args) { // NOTE: to set a different options, you can do like this: // ClientOptions.newBuilder().setRpcTimeout(5 * 1000).build(); WorkflowClient workflowClient = - WorkflowClient.newInstance(new WorkflowServiceTChannel(ClientOptions.defaultInstance())); + WorkflowClient.newInstance( + new WorkflowServiceTChannel(ClientOptions.defaultInstance()), + WorkflowClientOptions.newBuilder().setDomain(DOMAIN).build()); // Get worker to poll the task list. WorkerFactory factory = WorkerFactory.newInstance(workflowClient); Worker worker = factory.newWorker(TASK_LIST); diff --git a/src/main/java/com/uber/cadence/samples/hello/HelloMetric.java b/src/main/java/com/uber/cadence/samples/hello/HelloMetric.java index 257a3aa3f..81db41958 100644 --- a/src/main/java/com/uber/cadence/samples/hello/HelloMetric.java +++ b/src/main/java/com/uber/cadence/samples/hello/HelloMetric.java @@ -17,8 +17,11 @@ package com.uber.cadence.samples.hello; +import static com.uber.cadence.samples.common.SampleConstants.DOMAIN; + import com.uber.cadence.activity.ActivityMethod; import com.uber.cadence.client.WorkflowClient; +import com.uber.cadence.client.WorkflowClientOptions; import com.uber.cadence.serviceclient.ClientOptions; import com.uber.cadence.serviceclient.IWorkflowService; import com.uber.cadence.serviceclient.WorkflowServiceTChannel; @@ -97,7 +100,9 @@ public static void main(String[] args) throws IOException { ClientOptions.newBuilder().setMetricsScope(createMetricScope()).build(); // final ClientOptions clientOptions = ClientOptions.newBuilder().build(); IWorkflowService service = new WorkflowServiceTChannel(clientOptions); - final WorkflowClient workflowClient = WorkflowClient.newInstance(service); + final WorkflowClient workflowClient = + WorkflowClient.newInstance( + service, WorkflowClientOptions.newBuilder().setDomain(DOMAIN).build()); // Start a worker that hosts both workflow and activity implementations. WorkerFactory factory = WorkerFactory.newInstance(workflowClient); Worker worker = factory.newWorker(TASK_LIST, WorkerOptions.defaultInstance()); diff --git a/src/main/java/com/uber/cadence/samples/hello/HelloPeriodic.java b/src/main/java/com/uber/cadence/samples/hello/HelloPeriodic.java index 35a8bc560..e0cc348f9 100644 --- a/src/main/java/com/uber/cadence/samples/hello/HelloPeriodic.java +++ b/src/main/java/com/uber/cadence/samples/hello/HelloPeriodic.java @@ -17,6 +17,8 @@ package com.uber.cadence.samples.hello; +import static com.uber.cadence.samples.common.SampleConstants.DOMAIN; + import com.google.common.base.Throwables; import com.uber.cadence.WorkflowExecution; import com.uber.cadence.WorkflowIdReusePolicy; @@ -24,6 +26,7 @@ import com.uber.cadence.activity.ActivityOptions; import com.uber.cadence.client.DuplicateWorkflowException; import com.uber.cadence.client.WorkflowClient; +import com.uber.cadence.client.WorkflowClientOptions; import com.uber.cadence.client.WorkflowException; import com.uber.cadence.client.WorkflowStub; import com.uber.cadence.serviceclient.ClientOptions; @@ -122,7 +125,9 @@ public static void main(String[] args) throws InterruptedException { // NOTE: to set a different options, you can do like this: // ClientOptions.newBuilder().setRpcTimeout(5 * 1000).build(); WorkflowClient workflowClient = - WorkflowClient.newInstance(new WorkflowServiceTChannel(ClientOptions.defaultInstance())); + WorkflowClient.newInstance( + new WorkflowServiceTChannel(ClientOptions.defaultInstance()), + WorkflowClientOptions.newBuilder().setDomain(DOMAIN).build()); // Get worker to poll the task list. WorkerFactory factory = WorkerFactory.newInstance(workflowClient); Worker worker = factory.newWorker(TASK_LIST); diff --git a/src/main/java/com/uber/cadence/samples/hello/HelloQuery.java b/src/main/java/com/uber/cadence/samples/hello/HelloQuery.java index 766706849..a370accbe 100644 --- a/src/main/java/com/uber/cadence/samples/hello/HelloQuery.java +++ b/src/main/java/com/uber/cadence/samples/hello/HelloQuery.java @@ -17,7 +17,10 @@ package com.uber.cadence.samples.hello; +import static com.uber.cadence.samples.common.SampleConstants.DOMAIN; + import com.uber.cadence.client.WorkflowClient; +import com.uber.cadence.client.WorkflowClientOptions; import com.uber.cadence.client.WorkflowOptions; import com.uber.cadence.serviceclient.ClientOptions; import com.uber.cadence.serviceclient.WorkflowServiceTChannel; @@ -68,7 +71,9 @@ public static void main(String[] args) throws InterruptedException { // NOTE: to set a different options, you can do like this: // ClientOptions.newBuilder().setRpcTimeout(5 * 1000).build(); WorkflowClient workflowClient = - WorkflowClient.newInstance(new WorkflowServiceTChannel(ClientOptions.defaultInstance())); + WorkflowClient.newInstance( + new WorkflowServiceTChannel(ClientOptions.defaultInstance()), + WorkflowClientOptions.newBuilder().setDomain(DOMAIN).build()); // Get worker to poll the task list. WorkerFactory factory = WorkerFactory.newInstance(workflowClient); Worker worker = factory.newWorker(TASK_LIST); diff --git a/src/main/java/com/uber/cadence/samples/hello/HelloSaga.java b/src/main/java/com/uber/cadence/samples/hello/HelloSaga.java index 6f129d177..834833fc2 100644 --- a/src/main/java/com/uber/cadence/samples/hello/HelloSaga.java +++ b/src/main/java/com/uber/cadence/samples/hello/HelloSaga.java @@ -17,8 +17,11 @@ package com.uber.cadence.samples.hello; +import static com.uber.cadence.samples.common.SampleConstants.DOMAIN; + import com.uber.cadence.activity.ActivityMethod; import com.uber.cadence.client.WorkflowClient; +import com.uber.cadence.client.WorkflowClientOptions; import com.uber.cadence.client.WorkflowOptions; import com.uber.cadence.serviceclient.ClientOptions; import com.uber.cadence.serviceclient.WorkflowServiceTChannel; @@ -132,7 +135,9 @@ public static void main(String[] args) { // NOTE: to set a different options, you can do like this: // ClientOptions.newBuilder().setRpcTimeout(5 * 1000).build(); WorkflowClient workflowClient = - WorkflowClient.newInstance(new WorkflowServiceTChannel(ClientOptions.defaultInstance())); + WorkflowClient.newInstance( + new WorkflowServiceTChannel(ClientOptions.defaultInstance()), + WorkflowClientOptions.newBuilder().setDomain(DOMAIN).build()); // Get worker to poll the task list. WorkerFactory factory = WorkerFactory.newInstance(workflowClient); Worker worker = factory.newWorker(TASK_LIST); diff --git a/src/main/java/com/uber/cadence/samples/hello/HelloSearchAttributes.java b/src/main/java/com/uber/cadence/samples/hello/HelloSearchAttributes.java index fe84eea27..88c3ada00 100644 --- a/src/main/java/com/uber/cadence/samples/hello/HelloSearchAttributes.java +++ b/src/main/java/com/uber/cadence/samples/hello/HelloSearchAttributes.java @@ -25,6 +25,7 @@ import com.uber.cadence.WorkflowExecution; import com.uber.cadence.activity.ActivityMethod; import com.uber.cadence.client.WorkflowClient; +import com.uber.cadence.client.WorkflowClientOptions; import com.uber.cadence.client.WorkflowOptions; import com.uber.cadence.serviceclient.ClientOptions; import com.uber.cadence.serviceclient.WorkflowServiceTChannel; @@ -132,7 +133,9 @@ public static void main(String[] args) { // Get a new client // NOTE: to set a different options, you can do like this: // ClientOptions.newBuilder().setRpcTimeout(5 * 1000).build(); - WorkflowClient workflowClient = WorkflowClient.newInstance(cadenceService); + WorkflowClient workflowClient = + WorkflowClient.newInstance( + cadenceService, WorkflowClientOptions.newBuilder().setDomain(DOMAIN).build()); // Get worker to poll the task list. WorkerFactory factory = WorkerFactory.newInstance(workflowClient); Worker worker = factory.newWorker(TASK_LIST); diff --git a/src/main/java/com/uber/cadence/samples/hello/HelloSideEffect.java b/src/main/java/com/uber/cadence/samples/hello/HelloSideEffect.java index 8bb01bd9b..7434be600 100644 --- a/src/main/java/com/uber/cadence/samples/hello/HelloSideEffect.java +++ b/src/main/java/com/uber/cadence/samples/hello/HelloSideEffect.java @@ -17,7 +17,10 @@ package com.uber.cadence.samples.hello; +import static com.uber.cadence.samples.common.SampleConstants.DOMAIN; + import com.uber.cadence.client.WorkflowClient; +import com.uber.cadence.client.WorkflowClientOptions; import com.uber.cadence.serviceclient.ClientOptions; import com.uber.cadence.serviceclient.WorkflowServiceTChannel; import com.uber.cadence.worker.Worker; @@ -70,7 +73,9 @@ public static void main(String[] args) { // NOTE: to set a different options, you can do like this: // ClientOptions.newBuilder().setRpcTimeout(5 * 1000).build(); WorkflowClient workflowClient = - WorkflowClient.newInstance(new WorkflowServiceTChannel(ClientOptions.defaultInstance())); + WorkflowClient.newInstance( + new WorkflowServiceTChannel(ClientOptions.defaultInstance()), + WorkflowClientOptions.newBuilder().setDomain(DOMAIN).build()); // Get worker to poll the task list. WorkerFactory factory = WorkerFactory.newInstance(workflowClient); Worker worker = factory.newWorker(TASK_LIST); diff --git a/src/main/java/com/uber/cadence/samples/hello/HelloSignal.java b/src/main/java/com/uber/cadence/samples/hello/HelloSignal.java index 9da4b5644..38dfec97b 100644 --- a/src/main/java/com/uber/cadence/samples/hello/HelloSignal.java +++ b/src/main/java/com/uber/cadence/samples/hello/HelloSignal.java @@ -17,7 +17,10 @@ package com.uber.cadence.samples.hello; +import static com.uber.cadence.samples.common.SampleConstants.DOMAIN; + import com.uber.cadence.client.WorkflowClient; +import com.uber.cadence.client.WorkflowClientOptions; import com.uber.cadence.client.WorkflowOptions; import com.uber.cadence.serviceclient.ClientOptions; import com.uber.cadence.serviceclient.WorkflowServiceTChannel; @@ -93,7 +96,9 @@ public static void main(String[] args) throws Exception { // NOTE: to set a different options, you can do like this: // ClientOptions.newBuilder().setRpcTimeout(5 * 1000).build(); WorkflowClient workflowClient = - WorkflowClient.newInstance(new WorkflowServiceTChannel(ClientOptions.defaultInstance())); + WorkflowClient.newInstance( + new WorkflowServiceTChannel(ClientOptions.defaultInstance()), + WorkflowClientOptions.newBuilder().setDomain(DOMAIN).build()); // Get worker to poll the task list. WorkerFactory factory = WorkerFactory.newInstance(workflowClient); Worker worker = factory.newWorker(TASK_LIST); diff --git a/src/main/java/com/uber/cadence/samples/hello/HelloWorkerSetup.java b/src/main/java/com/uber/cadence/samples/hello/HelloWorkerSetup.java index 61049e4a9..ce786b3d9 100644 --- a/src/main/java/com/uber/cadence/samples/hello/HelloWorkerSetup.java +++ b/src/main/java/com/uber/cadence/samples/hello/HelloWorkerSetup.java @@ -17,8 +17,11 @@ package com.uber.cadence.samples.hello; +import static com.uber.cadence.samples.common.SampleConstants.DOMAIN; + import com.uber.cadence.activity.ActivityMethod; import com.uber.cadence.client.WorkflowClient; +import com.uber.cadence.client.WorkflowClientOptions; import com.uber.cadence.serviceclient.ClientOptions; import com.uber.cadence.serviceclient.WorkflowServiceTChannel; import com.uber.cadence.worker.Worker; @@ -79,7 +82,9 @@ public static void main(String[] args) { // NOTE: to set a different options, you can do like this: // ClientOptions.newBuilder().setRpcTimeout(5 * 1000).build(); WorkflowClient workflowClient = - WorkflowClient.newInstance(new WorkflowServiceTChannel(ClientOptions.defaultInstance())); + WorkflowClient.newInstance( + new WorkflowServiceTChannel(ClientOptions.defaultInstance()), + WorkflowClientOptions.newBuilder().setDomain(DOMAIN).build()); /** * If you see error "Not enough threads to execute workflows" exception it indicates that there