formatting and fixing couple of samples.

mindaugasbarcauskas · mindaugasbarcauskas · commit 270c3f7d02d0 · 2022-09-07T13:11:56.000+03:00
diff --git a/src/main/java/com/uber/cadence/samples/hello/HelloActivity.java b/src/main/java/com/uber/cadence/samples/hello/HelloActivity.java
@@ -24,12 +24,10 @@
 import com.uber.cadence.client.WorkflowClientOptions;
 import com.uber.cadence.internal.compatibility.Thrift2ProtoAdapter;
 import com.uber.cadence.internal.compatibility.proto.serviceclient.IGrpcServiceStubs;
-import com.uber.cadence.serviceclient.ClientOptions;
 import com.uber.cadence.worker.Worker;
 import com.uber.cadence.worker.WorkerFactory;
 import com.uber.cadence.workflow.Workflow;
 import com.uber.cadence.workflow.WorkflowMethod;
-import io.grpc.ManagedChannelBuilder;
 
 /**
  * Hello World Cadence workflow that executes a single activity. Requires a local instance the
diff --git a/src/main/java/com/uber/cadence/samples/hello/HelloActivityRetry.java b/src/main/java/com/uber/cadence/samples/hello/HelloActivityRetry.java
@@ -26,8 +26,6 @@
 import com.uber.cadence.common.RetryOptions;
 import com.uber.cadence.internal.compatibility.Thrift2ProtoAdapter;
 import com.uber.cadence.internal.compatibility.proto.serviceclient.IGrpcServiceStubs;
-import com.uber.cadence.serviceclient.ClientOptions;
-import com.uber.cadence.serviceclient.WorkflowServiceTChannel;
 import com.uber.cadence.worker.Worker;
 import com.uber.cadence.worker.WorkerFactory;
 import com.uber.cadence.workflow.Functions;
diff --git a/src/main/java/com/uber/cadence/samples/hello/HelloAsync.java b/src/main/java/com/uber/cadence/samples/hello/HelloAsync.java
@@ -24,8 +24,6 @@
 import com.uber.cadence.client.WorkflowClientOptions;
 import com.uber.cadence.internal.compatibility.Thrift2ProtoAdapter;
 import com.uber.cadence.internal.compatibility.proto.serviceclient.IGrpcServiceStubs;
-import com.uber.cadence.serviceclient.ClientOptions;
-import com.uber.cadence.serviceclient.WorkflowServiceTChannel;
 import com.uber.cadence.worker.Worker;
 import com.uber.cadence.worker.WorkerFactory;
 import com.uber.cadence.workflow.Async;
diff --git a/src/main/java/com/uber/cadence/samples/hello/HelloAsyncActivityCompletion.java b/src/main/java/com/uber/cadence/samples/hello/HelloAsyncActivityCompletion.java
@@ -26,8 +26,6 @@
 import com.uber.cadence.client.WorkflowClientOptions;
 import com.uber.cadence.internal.compatibility.Thrift2ProtoAdapter;
 import com.uber.cadence.internal.compatibility.proto.serviceclient.IGrpcServiceStubs;
-import com.uber.cadence.serviceclient.ClientOptions;
-import com.uber.cadence.serviceclient.WorkflowServiceTChannel;
 import com.uber.cadence.worker.Worker;
 import com.uber.cadence.worker.WorkerFactory;
 import com.uber.cadence.workflow.Workflow;
diff --git a/src/main/java/com/uber/cadence/samples/hello/HelloAsyncLambda.java b/src/main/java/com/uber/cadence/samples/hello/HelloAsyncLambda.java
@@ -25,8 +25,6 @@
 import com.uber.cadence.client.WorkflowOptions;
 import com.uber.cadence.internal.compatibility.Thrift2ProtoAdapter;
 import com.uber.cadence.internal.compatibility.proto.serviceclient.IGrpcServiceStubs;
-import com.uber.cadence.serviceclient.ClientOptions;
-import com.uber.cadence.serviceclient.WorkflowServiceTChannel;
 import com.uber.cadence.worker.Worker;
 import com.uber.cadence.worker.WorkerFactory;
 import com.uber.cadence.workflow.Async;
diff --git a/src/main/java/com/uber/cadence/samples/hello/HelloCancellation.java b/src/main/java/com/uber/cadence/samples/hello/HelloCancellation.java
@@ -26,8 +26,6 @@
 import com.uber.cadence.client.WorkflowStub;
 import com.uber.cadence.internal.compatibility.Thrift2ProtoAdapter;
 import com.uber.cadence.internal.compatibility.proto.serviceclient.IGrpcServiceStubs;
-import com.uber.cadence.serviceclient.ClientOptions;
-import com.uber.cadence.serviceclient.WorkflowServiceTChannel;
 import com.uber.cadence.worker.Worker;
 import com.uber.cadence.worker.WorkerFactory;
 import com.uber.cadence.workflow.CancellationScope;
diff --git a/src/main/java/com/uber/cadence/samples/hello/HelloChild.java b/src/main/java/com/uber/cadence/samples/hello/HelloChild.java
@@ -24,8 +24,6 @@
 import com.uber.cadence.client.WorkflowClientOptions;
 import com.uber.cadence.internal.compatibility.Thrift2ProtoAdapter;
 import com.uber.cadence.internal.compatibility.proto.serviceclient.IGrpcServiceStubs;
-import com.uber.cadence.serviceclient.ClientOptions;
-import com.uber.cadence.serviceclient.WorkflowServiceTChannel;
 import com.uber.cadence.worker.Worker;
 import com.uber.cadence.worker.WorkerFactory;
 import com.uber.cadence.workflow.Async;
diff --git a/src/main/java/com/uber/cadence/samples/hello/HelloConsistentQuery.java b/src/main/java/com/uber/cadence/samples/hello/HelloConsistentQuery.java
@@ -28,8 +28,6 @@
 import com.uber.cadence.client.WorkflowStub;
 import com.uber.cadence.internal.compatibility.Thrift2ProtoAdapter;
 import com.uber.cadence.internal.compatibility.proto.serviceclient.IGrpcServiceStubs;
-import com.uber.cadence.serviceclient.ClientOptions;
-import com.uber.cadence.serviceclient.WorkflowServiceTChannel;
 import com.uber.cadence.worker.Worker;
 import com.uber.cadence.worker.WorkerFactory;
 import com.uber.cadence.workflow.QueryMethod;
diff --git a/src/main/java/com/uber/cadence/samples/hello/HelloCron.java b/src/main/java/com/uber/cadence/samples/hello/HelloCron.java
@@ -29,8 +29,6 @@
 import com.uber.cadence.common.CronSchedule;
 import com.uber.cadence.internal.compatibility.Thrift2ProtoAdapter;
 import com.uber.cadence.internal.compatibility.proto.serviceclient.IGrpcServiceStubs;
-import com.uber.cadence.serviceclient.ClientOptions;
-import com.uber.cadence.serviceclient.WorkflowServiceTChannel;
 import com.uber.cadence.worker.Worker;
 import com.uber.cadence.worker.WorkerFactory;
 import com.uber.cadence.workflow.Workflow;
@@ -88,7 +86,7 @@ public void greet(String greeting) {
 
   public static void main(String[] args) throws InterruptedException {
     final Thrift2ProtoAdapter cadenceService =
-            new Thrift2ProtoAdapter(IGrpcServiceStubs.newInstance());
+        new Thrift2ProtoAdapter(IGrpcServiceStubs.newInstance());
     // 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/HelloDataConverter.java b/src/main/java/com/uber/cadence/samples/hello/HelloDataConverter.java
@@ -27,8 +27,6 @@
 import com.uber.cadence.converter.JsonDataConverter;
 import com.uber.cadence.internal.compatibility.Thrift2ProtoAdapter;
 import com.uber.cadence.internal.compatibility.proto.serviceclient.IGrpcServiceStubs;
-import com.uber.cadence.serviceclient.ClientOptions;
-import com.uber.cadence.serviceclient.WorkflowServiceTChannel;
 import com.uber.cadence.worker.Worker;
 import com.uber.cadence.worker.WorkerFactory;
 import com.uber.cadence.workflow.Workflow;
diff --git a/src/main/java/com/uber/cadence/samples/hello/HelloException.java b/src/main/java/com/uber/cadence/samples/hello/HelloException.java
@@ -27,8 +27,6 @@
 import com.uber.cadence.client.WorkflowOptions;
 import com.uber.cadence.internal.compatibility.Thrift2ProtoAdapter;
 import com.uber.cadence.internal.compatibility.proto.serviceclient.IGrpcServiceStubs;
-import com.uber.cadence.serviceclient.ClientOptions;
-import com.uber.cadence.serviceclient.WorkflowServiceTChannel;
 import com.uber.cadence.worker.Worker;
 import com.uber.cadence.worker.WorkerFactory;
 import com.uber.cadence.workflow.Workflow;
diff --git a/src/main/java/com/uber/cadence/samples/hello/HelloLocalActivity.java b/src/main/java/com/uber/cadence/samples/hello/HelloLocalActivity.java
@@ -24,8 +24,6 @@
 import com.uber.cadence.client.WorkflowClientOptions;
 import com.uber.cadence.internal.compatibility.Thrift2ProtoAdapter;
 import com.uber.cadence.internal.compatibility.proto.serviceclient.IGrpcServiceStubs;
-import com.uber.cadence.serviceclient.ClientOptions;
-import com.uber.cadence.serviceclient.WorkflowServiceTChannel;
 import com.uber.cadence.worker.Worker;
 import com.uber.cadence.worker.WorkerFactory;
 import com.uber.cadence.workflow.Workflow;
diff --git a/src/main/java/com/uber/cadence/samples/hello/HelloMetric.java b/src/main/java/com/uber/cadence/samples/hello/HelloMetric.java
@@ -26,7 +26,6 @@
 import com.uber.cadence.internal.compatibility.proto.serviceclient.IGrpcServiceStubs;
 import com.uber.cadence.serviceclient.ClientOptions;
 import com.uber.cadence.serviceclient.IWorkflowService;
-import com.uber.cadence.serviceclient.WorkflowServiceTChannel;
 import com.uber.cadence.worker.Worker;
 import com.uber.cadence.worker.WorkerFactory;
 import com.uber.cadence.worker.WorkerOptions;
@@ -97,11 +96,13 @@ public String composeGreeting(String greeting, String name) {
     }
   }
 
+  // Doesn't work
   public static void main(String[] args) throws IOException {
     final ClientOptions clientOptions =
-        ClientOptions.newBuilder().setMetricsScope(createMetricScope()).build();
+        ClientOptions.newBuilder().setMetricsScope(createMetricScope()).setPort(7833).build();
     //    final ClientOptions clientOptions = ClientOptions.newBuilder().build();
-    IWorkflowService service = new Thrift2ProtoAdapter(IGrpcServiceStubs.newInstance(clientOptions));
+    IWorkflowService service =
+        new Thrift2ProtoAdapter(IGrpcServiceStubs.newInstance(clientOptions));
     final WorkflowClient workflowClient =
         WorkflowClient.newInstance(
             service, WorkflowClientOptions.newBuilder().setDomain(DOMAIN).build());
diff --git a/src/main/java/com/uber/cadence/samples/hello/HelloPeriodic.java b/src/main/java/com/uber/cadence/samples/hello/HelloPeriodic.java
@@ -31,8 +31,6 @@
 import com.uber.cadence.client.WorkflowStub;
 import com.uber.cadence.internal.compatibility.Thrift2ProtoAdapter;
 import com.uber.cadence.internal.compatibility.proto.serviceclient.IGrpcServiceStubs;
-import com.uber.cadence.serviceclient.ClientOptions;
-import com.uber.cadence.serviceclient.WorkflowServiceTChannel;
 import com.uber.cadence.worker.Worker;
 import com.uber.cadence.worker.WorkerFactory;
 import com.uber.cadence.workflow.Workflow;
@@ -128,7 +126,7 @@ public static void main(String[] args) throws InterruptedException {
     // ClientOptions.newBuilder().setRpcTimeout(5 * 1000).build();
     WorkflowClient workflowClient =
         WorkflowClient.newInstance(
-                new Thrift2ProtoAdapter(IGrpcServiceStubs.newInstance()),
+            new Thrift2ProtoAdapter(IGrpcServiceStubs.newInstance()),
             WorkflowClientOptions.newBuilder().setDomain(DOMAIN).build());
     // Get worker to poll the task list.
     WorkerFactory factory = WorkerFactory.newInstance(workflowClient);
diff --git a/src/main/java/com/uber/cadence/samples/hello/HelloQuery.java b/src/main/java/com/uber/cadence/samples/hello/HelloQuery.java
@@ -24,8 +24,6 @@
 import com.uber.cadence.client.WorkflowOptions;
 import com.uber.cadence.internal.compatibility.Thrift2ProtoAdapter;
 import com.uber.cadence.internal.compatibility.proto.serviceclient.IGrpcServiceStubs;
-import com.uber.cadence.serviceclient.ClientOptions;
-import com.uber.cadence.serviceclient.WorkflowServiceTChannel;
 import com.uber.cadence.worker.Worker;
 import com.uber.cadence.worker.WorkerFactory;
 import com.uber.cadence.workflow.QueryMethod;
diff --git a/src/main/java/com/uber/cadence/samples/hello/HelloSaga.java b/src/main/java/com/uber/cadence/samples/hello/HelloSaga.java
@@ -25,8 +25,6 @@
 import com.uber.cadence.client.WorkflowOptions;
 import com.uber.cadence.internal.compatibility.Thrift2ProtoAdapter;
 import com.uber.cadence.internal.compatibility.proto.serviceclient.IGrpcServiceStubs;
-import com.uber.cadence.serviceclient.ClientOptions;
-import com.uber.cadence.serviceclient.WorkflowServiceTChannel;
 import com.uber.cadence.worker.Worker;
 import com.uber.cadence.worker.WorkerFactory;
 import com.uber.cadence.workflow.Async;
diff --git a/src/main/java/com/uber/cadence/samples/hello/HelloSearchAttributes.java b/src/main/java/com/uber/cadence/samples/hello/HelloSearchAttributes.java
@@ -29,8 +29,6 @@
 import com.uber.cadence.client.WorkflowOptions;
 import com.uber.cadence.internal.compatibility.Thrift2ProtoAdapter;
 import com.uber.cadence.internal.compatibility.proto.serviceclient.IGrpcServiceStubs;
-import com.uber.cadence.serviceclient.ClientOptions;
-import com.uber.cadence.serviceclient.WorkflowServiceTChannel;
 import com.uber.cadence.worker.Worker;
 import com.uber.cadence.worker.WorkerFactory;
 import com.uber.cadence.workflow.Workflow;
@@ -131,7 +129,7 @@ public String composeGreeting(String greeting, String name) {
 
   public static void main(String[] args) {
     final Thrift2ProtoAdapter cadenceService =
-            new Thrift2ProtoAdapter(IGrpcServiceStubs.newInstance());
+        new Thrift2ProtoAdapter(IGrpcServiceStubs.newInstance());
     // 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
@@ -23,8 +23,6 @@
 import com.uber.cadence.client.WorkflowClientOptions;
 import com.uber.cadence.internal.compatibility.Thrift2ProtoAdapter;
 import com.uber.cadence.internal.compatibility.proto.serviceclient.IGrpcServiceStubs;
-import com.uber.cadence.serviceclient.ClientOptions;
-import com.uber.cadence.serviceclient.WorkflowServiceTChannel;
 import com.uber.cadence.worker.Worker;
 import com.uber.cadence.worker.WorkerFactory;
 import com.uber.cadence.workflow.QueryMethod;
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,7 +26,6 @@
 import com.uber.cadence.internal.compatibility.Thrift2ProtoAdapter;
 import com.uber.cadence.internal.compatibility.proto.serviceclient.IGrpcServiceStubs;
 import com.uber.cadence.serviceclient.ClientOptions;
-import com.uber.cadence.serviceclient.WorkflowServiceTChannel;
 import com.uber.cadence.worker.Worker;
 import com.uber.cadence.worker.WorkerFactory;
 import com.uber.cadence.workflow.SignalMethod;
@@ -100,9 +99,13 @@ public static void main(String[] args) throws Exception {
     // ClientOptions.newBuilder().setRpcTimeout(5 * 1000).build();
     WorkflowClient workflowClient =
         WorkflowClient.newInstance(
-                new Thrift2ProtoAdapter(IGrpcServiceStubs.newInstance(ClientOptions.newBuilder()
+            new Thrift2ProtoAdapter(
+                IGrpcServiceStubs.newInstance(
+                    ClientOptions.newBuilder()
                         .setFeatureFlags(
-                                new FeatureFlags().setWorkflowExecutionAlreadyCompletedErrorEnabled(true))
+                            new FeatureFlags()
+                                .setWorkflowExecutionAlreadyCompletedErrorEnabled(true))
+                        .setPort(7833)
                         .build())),
             WorkflowClientOptions.newBuilder().setDomain(DOMAIN).build());
     // Get worker to poll the task list.
diff --git a/src/main/java/com/uber/cadence/samples/hello/HelloSignalAndResponse.java b/src/main/java/com/uber/cadence/samples/hello/HelloSignalAndResponse.java
@@ -34,8 +34,6 @@
 import com.uber.cadence.converter.JsonDataConverter;
 import com.uber.cadence.internal.compatibility.Thrift2ProtoAdapter;
 import com.uber.cadence.internal.compatibility.proto.serviceclient.IGrpcServiceStubs;
-import com.uber.cadence.serviceclient.ClientOptions;
-import com.uber.cadence.serviceclient.WorkflowServiceTChannel;
 import com.uber.cadence.worker.Worker;
 import com.uber.cadence.worker.WorkerFactory;
 import com.uber.cadence.workflow.SignalMethod;
diff --git a/src/main/java/com/uber/cadence/samples/hello/HelloWorkerSetup.java b/src/main/java/com/uber/cadence/samples/hello/HelloWorkerSetup.java
@@ -24,8 +24,6 @@
 import com.uber.cadence.client.WorkflowClientOptions;
 import com.uber.cadence.internal.compatibility.Thrift2ProtoAdapter;
 import com.uber.cadence.internal.compatibility.proto.serviceclient.IGrpcServiceStubs;
-import com.uber.cadence.serviceclient.ClientOptions;
-import com.uber.cadence.serviceclient.WorkflowServiceTChannel;
 import com.uber.cadence.worker.Worker;
 import com.uber.cadence.worker.WorkerFactory;
 import com.uber.cadence.worker.WorkerFactoryOptions;
