Fix all build

longquanzheng · longquanzheng · commit 2c568e0cdf38 · 2021-05-05T16:10:05.000-07:00
diff --git a/src/main/java/com/uber/cadence/samples/bookingsaga/TripBookingSaga.java b/src/main/java/com/uber/cadence/samples/bookingsaga/TripBookingSaga.java
@@ -31,7 +31,8 @@ public class TripBookingSaga {
   @SuppressWarnings("CatchAndPrintStackTrace")
   public static void main(String[] args) {
     // Get a new client
-    WorkflowClient workflowClient = WorkflowClient.newInstance(new WorkflowServiceTChannel(ClientOptions.defaultInstance()));
+    WorkflowClient workflowClient =
+        WorkflowClient.newInstance(new WorkflowServiceTChannel(ClientOptions.defaultInstance()));
     // 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/fileprocessing/FileProcessingStarter.java b/src/main/java/com/uber/cadence/samples/fileprocessing/FileProcessingStarter.java
@@ -20,17 +20,15 @@
 import com.uber.cadence.client.WorkflowClient;
 import com.uber.cadence.serviceclient.ClientOptions;
 import com.uber.cadence.serviceclient.WorkflowServiceTChannel;
-
 import java.net.URL;
 
-/**
- * Starts a file processing sample workflow.
- */
+/** Starts a file processing sample workflow. */
 public class FileProcessingStarter {
 
   public static void main(String[] args) throws Exception {
     // Get a new client
-    WorkflowClient workflowClient = WorkflowClient.newInstance(new WorkflowServiceTChannel(ClientOptions.defaultInstance()));
+    WorkflowClient workflowClient =
+        WorkflowClient.newInstance(new WorkflowServiceTChannel(ClientOptions.defaultInstance()));
     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
@@ -22,7 +22,6 @@
 import com.uber.cadence.serviceclient.WorkflowServiceTChannel;
 import com.uber.cadence.worker.Worker;
 import com.uber.cadence.worker.WorkerFactory;
-
 import java.lang.management.ManagementFactory;
 
 /**
@@ -41,7 +40,8 @@ public static void main(String[] args) {
     String hostSpecifiTaskList = ManagementFactory.getRuntimeMXBean().getName();
 
     // Get a new client
-    WorkflowClient workflowClient = WorkflowClient.newInstance(new WorkflowServiceTChannel(ClientOptions.defaultInstance()));
+    WorkflowClient workflowClient =
+        WorkflowClient.newInstance(new WorkflowServiceTChannel(ClientOptions.defaultInstance()));
     // 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
@@ -76,7 +76,8 @@ 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(new WorkflowServiceTChannel(ClientOptions.defaultInstance()));
+    WorkflowClient workflowClient =
+        WorkflowClient.newInstance(new WorkflowServiceTChannel(ClientOptions.defaultInstance()));
     // 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
@@ -28,7 +28,6 @@
 import com.uber.cadence.workflow.Functions;
 import com.uber.cadence.workflow.Workflow;
 import com.uber.cadence.workflow.WorkflowMethod;
-
 import java.time.Duration;
 
 /**
@@ -104,7 +103,8 @@ 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(new WorkflowServiceTChannel(ClientOptions.defaultInstance()));
+    WorkflowClient workflowClient =
+        WorkflowClient.newInstance(new WorkflowServiceTChannel(ClientOptions.defaultInstance()));
     // 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
@@ -83,7 +83,8 @@ 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(new WorkflowServiceTChannel(ClientOptions.defaultInstance()));
+    WorkflowClient workflowClient =
+        WorkflowClient.newInstance(new WorkflowServiceTChannel(ClientOptions.defaultInstance()));
     // 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
@@ -27,7 +27,6 @@
 import com.uber.cadence.worker.WorkerFactory;
 import com.uber.cadence.workflow.Workflow;
 import com.uber.cadence.workflow.WorkflowMethod;
-
 import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.ExecutionException;
 import java.util.concurrent.ForkJoinPool;
@@ -103,10 +102,11 @@ private void composeGreetingAsync(byte[] taskToken, String greeting, String name
   }
 
   public static void main(String[] args) throws ExecutionException, InterruptedException {
-// Get a new client
+    // 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(new WorkflowServiceTChannel(ClientOptions.defaultInstance()));
+    WorkflowClient workflowClient =
+        WorkflowClient.newInstance(new WorkflowServiceTChannel(ClientOptions.defaultInstance()));
     // 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
@@ -28,7 +28,6 @@
 import com.uber.cadence.workflow.Promise;
 import com.uber.cadence.workflow.Workflow;
 import com.uber.cadence.workflow.WorkflowMethod;
-
 import java.time.Duration;
 
 /**
@@ -102,10 +101,11 @@ public String composeGreeting(String greeting, String name) {
   }
 
   public static void main(String[] args) {
-// Get a new client
+    // 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(new WorkflowServiceTChannel(ClientOptions.defaultInstance()));
+    WorkflowClient workflowClient =
+        WorkflowClient.newInstance(new WorkflowServiceTChannel(ClientOptions.defaultInstance()));
     // 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
@@ -91,7 +91,8 @@ 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(new WorkflowServiceTChannel(ClientOptions.defaultInstance()));
+    WorkflowClient workflowClient =
+        WorkflowClient.newInstance(new WorkflowServiceTChannel(ClientOptions.defaultInstance()));
     // 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
@@ -17,6 +17,8 @@
 
 package com.uber.cadence.samples.hello;
 
+import static com.uber.cadence.samples.common.SampleConstants.DOMAIN;
+
 import com.uber.cadence.TerminateWorkflowExecutionRequest;
 import com.uber.cadence.WorkflowExecution;
 import com.uber.cadence.WorkflowIdReusePolicy;
@@ -30,11 +32,8 @@
 import com.uber.cadence.worker.WorkerFactory;
 import com.uber.cadence.workflow.Workflow;
 import com.uber.cadence.workflow.WorkflowMethod;
-
 import java.time.Duration;
 
-import static com.uber.cadence.samples.common.SampleConstants.DOMAIN;
-
 /**
  * Demonstrates a cron workflow that executes activity periodically. Requires a local instance of
  * Cadence server to be running.
@@ -85,7 +84,8 @@ public void greet(String greeting) {
   }
 
   public static void main(String[] args) throws InterruptedException {
-    final WorkflowServiceTChannel cadenceService = new WorkflowServiceTChannel(ClientOptions.defaultInstance());
+    final WorkflowServiceTChannel cadenceService =
+        new WorkflowServiceTChannel(ClientOptions.defaultInstance());
     // Get a new client
     // NOTE: to set a different options, you can do like this:
     // ClientOptions.newBuilder().setRpcTimeout(5 * 1000).build();
diff --git a/src/main/java/com/uber/cadence/samples/hello/HelloException.java b/src/main/java/com/uber/cadence/samples/hello/HelloException.java
@@ -28,7 +28,6 @@
 import com.uber.cadence.worker.WorkerFactory;
 import com.uber.cadence.workflow.Workflow;
 import com.uber.cadence.workflow.WorkflowMethod;
-
 import java.io.IOException;
 import java.time.Duration;
 
@@ -164,7 +163,8 @@ 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(new WorkflowServiceTChannel(ClientOptions.defaultInstance()));
+    WorkflowClient workflowClient =
+        WorkflowClient.newInstance(new WorkflowServiceTChannel(ClientOptions.defaultInstance()));
     // Get worker to poll the task list.
     WorkerFactory factory = WorkerFactory.newInstance(workflowClient);
     Worker worker = factory.newWorker(TASK_LIST);
@@ -173,10 +173,10 @@ public static void main(String[] args) {
     factory.start();
 
     WorkflowOptions workflowOptions =
-            new WorkflowOptions.Builder()
-                    .setTaskList(TASK_LIST)
-                    .setExecutionStartToCloseTimeout(Duration.ofSeconds(30))
-                    .build();
+        new WorkflowOptions.Builder()
+            .setTaskList(TASK_LIST)
+            .setExecutionStartToCloseTimeout(Duration.ofSeconds(30))
+            .build();
     GreetingWorkflow workflow =
         workflowClient.newWorkflowStub(GreetingWorkflow.class, workflowOptions);
     try {
diff --git a/src/main/java/com/uber/cadence/samples/hello/HelloLocalActivity.java b/src/main/java/com/uber/cadence/samples/hello/HelloLocalActivity.java
@@ -76,7 +76,8 @@ 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(new WorkflowServiceTChannel(ClientOptions.defaultInstance()));
+    WorkflowClient workflowClient =
+        WorkflowClient.newInstance(new WorkflowServiceTChannel(ClientOptions.defaultInstance()));
     // 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/HelloPeriodic.java b/src/main/java/com/uber/cadence/samples/hello/HelloPeriodic.java
@@ -32,7 +32,6 @@
 import com.uber.cadence.worker.WorkerFactory;
 import com.uber.cadence.workflow.Workflow;
 import com.uber.cadence.workflow.WorkflowMethod;
-
 import java.time.Duration;
 import java.util.Optional;
 
@@ -122,7 +121,8 @@ 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(new WorkflowServiceTChannel(ClientOptions.defaultInstance()));
+    WorkflowClient workflowClient =
+        WorkflowClient.newInstance(new WorkflowServiceTChannel(ClientOptions.defaultInstance()));
     // 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
@@ -26,7 +26,6 @@
 import com.uber.cadence.workflow.QueryMethod;
 import com.uber.cadence.workflow.Workflow;
 import com.uber.cadence.workflow.WorkflowMethod;
-
 import java.time.Duration;
 
 /** Demonstrates query capability. Requires a local instance of Cadence server to be running. */
@@ -68,7 +67,8 @@ 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(new WorkflowServiceTChannel(ClientOptions.defaultInstance()));
+    WorkflowClient workflowClient =
+        WorkflowClient.newInstance(new WorkflowServiceTChannel(ClientOptions.defaultInstance()));
     // Get worker to poll the task list.
     WorkerFactory factory = WorkerFactory.newInstance(workflowClient);
     Worker worker = factory.newWorker(TASK_LIST);
@@ -78,9 +78,9 @@ public static void main(String[] args) throws InterruptedException {
     // Start a workflow execution. Usually this is done from another program.
     // Get a workflow stub using the same task list the worker uses.
     WorkflowOptions workflowOptions =
-            new WorkflowOptions.Builder()
-                    .setTaskList(TASK_LIST)
-                    .setExecutionStartToCloseTimeout(Duration.ofSeconds(30))
+        new WorkflowOptions.Builder()
+            .setTaskList(TASK_LIST)
+            .setExecutionStartToCloseTimeout(Duration.ofSeconds(30))
             .build();
     GreetingWorkflow workflow =
         workflowClient.newWorkflowStub(GreetingWorkflow.class, workflowOptions);
diff --git a/src/main/java/com/uber/cadence/samples/hello/HelloSaga.java b/src/main/java/com/uber/cadence/samples/hello/HelloSaga.java
@@ -29,7 +29,6 @@
 import com.uber.cadence.workflow.Saga;
 import com.uber.cadence.workflow.Workflow;
 import com.uber.cadence.workflow.WorkflowMethod;
-
 import java.time.Duration;
 
 /** Demonstrates implementing saga transaction and compensation logic using Cadence. */
@@ -132,14 +131,15 @@ 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(new WorkflowServiceTChannel(ClientOptions.defaultInstance()));
+    WorkflowClient workflowClient =
+        WorkflowClient.newInstance(new WorkflowServiceTChannel(ClientOptions.defaultInstance()));
     // Get worker to poll the task list.
     WorkerFactory factory = WorkerFactory.newInstance(workflowClient);
     Worker worker = factory.newWorker(TASK_LIST);
     worker.registerWorkflowImplementationTypes(
-            HelloSaga.SagaWorkflowImpl.class,
-            HelloSaga.ChildWorkflowOperationImpl.class,
-            HelloSaga.ChildWorkflowCompensationImpl.class);
+        HelloSaga.SagaWorkflowImpl.class,
+        HelloSaga.ChildWorkflowOperationImpl.class,
+        HelloSaga.ChildWorkflowCompensationImpl.class);
     worker.registerActivitiesImplementations(new ActivityOperationImpl());
     factory.start();
 
diff --git a/src/main/java/com/uber/cadence/samples/hello/HelloSearchAttributes.java b/src/main/java/com/uber/cadence/samples/hello/HelloSearchAttributes.java
@@ -17,6 +17,8 @@
 
 package com.uber.cadence.samples.hello;
 
+import static com.uber.cadence.samples.common.SampleConstants.DOMAIN;
+
 import com.uber.cadence.DescribeWorkflowExecutionRequest;
 import com.uber.cadence.DescribeWorkflowExecutionResponse;
 import com.uber.cadence.SearchAttributes;
@@ -31,22 +33,17 @@
 import com.uber.cadence.workflow.Workflow;
 import com.uber.cadence.workflow.WorkflowMethod;
 import com.uber.cadence.workflow.WorkflowUtils;
-
 import java.time.ZonedDateTime;
 import java.time.format.DateTimeFormatter;
 import java.util.HashMap;
 import java.util.Map;
 import java.util.UUID;
 
-import static com.uber.cadence.samples.common.SampleConstants.DOMAIN;
-
 public class HelloSearchAttributes {
 
   static final String TASK_LIST = "HelloSearchAttributes";
 
-  /**
-   * Workflow interface has to have at least one method annotated with @WorkflowMethod.
-   */
+  /** Workflow interface has to have at least one method annotated with @WorkflowMethod. */
   public interface GreetingWorkflow {
     /** @return greeting string */
     @WorkflowMethod(executionStartToCloseTimeoutSeconds = 10, taskList = TASK_LIST)
@@ -130,7 +127,8 @@ public String composeGreeting(String greeting, String name) {
   }
 
   public static void main(String[] args) {
-    final WorkflowServiceTChannel cadenceService = new WorkflowServiceTChannel(ClientOptions.defaultInstance());
+    final WorkflowServiceTChannel cadenceService =
+        new WorkflowServiceTChannel(ClientOptions.defaultInstance());
     // Get a new client
     // NOTE: to set a different options, you can do like this:
     // ClientOptions.newBuilder().setRpcTimeout(5 * 1000).build();
diff --git a/src/main/java/com/uber/cadence/samples/hello/HelloSideEffect.java b/src/main/java/com/uber/cadence/samples/hello/HelloSideEffect.java
@@ -25,7 +25,6 @@
 import com.uber.cadence.workflow.QueryMethod;
 import com.uber.cadence.workflow.Workflow;
 import com.uber.cadence.workflow.WorkflowMethod;
-
 import java.util.UUID;
 
 /**
@@ -70,7 +69,8 @@ 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(new WorkflowServiceTChannel(ClientOptions.defaultInstance()));
+    WorkflowClient workflowClient =
+        WorkflowClient.newInstance(new WorkflowServiceTChannel(ClientOptions.defaultInstance()));
     // 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
@@ -26,11 +26,10 @@
 import com.uber.cadence.workflow.SignalMethod;
 import com.uber.cadence.workflow.Workflow;
 import com.uber.cadence.workflow.WorkflowMethod;
-import org.apache.commons.lang.RandomStringUtils;
-
 import java.time.Duration;
 import java.util.ArrayList;
 import java.util.List;
+import org.apache.commons.lang.RandomStringUtils;
 
 /**
  * Demonstrates asynchronous signalling of a workflow. Requires a local instance of Cadence server
@@ -93,7 +92,8 @@ public static void main(String[] args) throws Exception {
     // 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(new WorkflowServiceTChannel(ClientOptions.defaultInstance()));
+    WorkflowClient workflowClient =
+        WorkflowClient.newInstance(new WorkflowServiceTChannel(ClientOptions.defaultInstance()));
     // 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
