Java SDK Release v1.11.0 (temporalio#290)

Spikhalskiy · web-flow · commit 708324ffd159 · 2022-05-02T18:08:54.000-04:00
diff --git a/build.gradle b/build.gradle
@@ -28,8 +28,8 @@ dependencies {
     implementation(platform("io.micrometer:micrometer-bom:1.8.5"))
     implementation(platform("org.junit:junit-bom:5.8.2"))
 
-    implementation group: 'io.temporal', name: 'temporal-sdk', version: '1.10.0'
-    implementation group: 'io.temporal', name: 'temporal-opentracing', version: '1.10.0'
+    implementation group: 'io.temporal', name: 'temporal-sdk', version: '1.11.0'
+    implementation group: 'io.temporal', name: 'temporal-opentracing', version: '1.11.0'
 
     implementation "com.fasterxml.jackson.core:jackson-databind"
     implementation group: 'ch.qos.logback', name: 'logback-classic', version: '1.2.11'
@@ -54,20 +54,12 @@ dependencies {
     implementation 'io.opentelemetry:opentelemetry-opentracing-shim:1.13.0-alpha'
     implementation 'io.opentelemetry:opentelemetry-semconv:1.13.0-alpha'
 
+    // we don't update it to 2.1.0 because 2.1.0 requires Java 11
     implementation 'com.codingrodent:jackson-json-crypto:1.1.0'
 
-    testImplementation("io.temporal:temporal-testing:1.10.0")
-    testImplementation ("io.temporal:temporal-testing") {
-        capabilities {
-            requireCapability("io.temporal:temporal-testing-junit4")
-        }
-    }
-    testImplementation ("io.temporal:temporal-testing") {
-        capabilities {
-            requireCapability("io.temporal:temporal-testing-junit5")
-        }
-    }
+    testImplementation("io.temporal:temporal-testing:1.11.0")
 
+    testImplementation "junit:junit:4.13.2"
     testImplementation group: 'org.mockito', name: 'mockito-core', version: '4.5.1'
     testImplementation group: 'org.powermock', name: 'powermock-api-mockito2', version: '2.0.9'
 
diff --git a/gradle/wrapper/gradle-wrapper.properties b/gradle/wrapper/gradle-wrapper.properties
@@ -1,5 +1,5 @@
 distributionBase=GRADLE_USER_HOME
 distributionPath=wrapper/dists
-distributionUrl=https\://services.gradle.org/distributions/gradle-7.1.1-bin.zip
+distributionUrl=https\://services.gradle.org/distributions/gradle-7.4.2-bin.zip
 zipStoreBase=GRADLE_USER_HOME
 zipStorePath=wrapper/dists
diff --git a/src/main/java/io/temporal/samples/asyncchild/Starter.java b/src/main/java/io/temporal/samples/asyncchild/Starter.java
@@ -33,7 +33,7 @@
 public class Starter {
 
   public static final String TASK_QUEUE = "asyncChildTaskQueue";
-  private static final WorkflowServiceStubs service = WorkflowServiceStubs.newInstance();
+  private static final WorkflowServiceStubs service = WorkflowServiceStubs.newLocalServiceStubs();
   private static final WorkflowClient client = WorkflowClient.newInstance(service);
   private static final WorkerFactory factory = WorkerFactory.newInstance(client);
 
diff --git a/src/main/java/io/temporal/samples/bookingsaga/TripBookingSaga.java b/src/main/java/io/temporal/samples/bookingsaga/TripBookingSaga.java
@@ -33,7 +33,7 @@ public class TripBookingSaga {
   @SuppressWarnings("CatchAndPrintStackTrace")
   public static void main(String[] args) {
     // gRPC stubs wrapper that talks to the local docker instance of temporal service.
-    WorkflowServiceStubs service = WorkflowServiceStubs.newInstance();
+    WorkflowServiceStubs service = WorkflowServiceStubs.newLocalServiceStubs();
     // client that can be used to start and signal workflows
     WorkflowClient client = WorkflowClient.newInstance(service);
 
diff --git a/src/main/java/io/temporal/samples/common/QueryWorkflowExecution.java b/src/main/java/io/temporal/samples/common/QueryWorkflowExecution.java
@@ -46,7 +46,7 @@ public static void main(String[] args) {
     String runId = args.length == 3 ? args[2] : "";
 
     // gRPC stubs wrapper that talks to the local docker instance of temporal service.
-    WorkflowServiceStubs service = WorkflowServiceStubs.newInstance();
+    WorkflowServiceStubs service = WorkflowServiceStubs.newLocalServiceStubs();
 
     WorkflowClient client = WorkflowClient.newInstance(service);
 
diff --git a/src/main/java/io/temporal/samples/dsl/Starter.java b/src/main/java/io/temporal/samples/dsl/Starter.java
@@ -37,7 +37,7 @@
 
 public class Starter {
 
-  public static final WorkflowServiceStubs service = WorkflowServiceStubs.newInstance();
+  public static final WorkflowServiceStubs service = WorkflowServiceStubs.newLocalServiceStubs();
   public static final WorkflowClient client = WorkflowClient.newInstance(service);
   public static final WorkerFactory factory = WorkerFactory.newInstance(client);
 
diff --git a/src/main/java/io/temporal/samples/dsl/Worker.java b/src/main/java/io/temporal/samples/dsl/Worker.java
@@ -24,7 +24,7 @@
 import io.temporal.worker.WorkerFactory;
 
 public class Worker {
-  private static final WorkflowServiceStubs service = WorkflowServiceStubs.newInstance();
+  private static final WorkflowServiceStubs service = WorkflowServiceStubs.newLocalServiceStubs();
   private static final WorkflowClient client = WorkflowClient.newInstance(service);
   private static final WorkerFactory factory = WorkerFactory.newInstance(client);
   public static final String DEFAULT_TASK_QUEUE_NAME = "dsltaskqueue";
diff --git a/src/main/java/io/temporal/samples/encryptedpayloads/EncryptedPayloadsActivity.java b/src/main/java/io/temporal/samples/encryptedpayloads/EncryptedPayloadsActivity.java
@@ -85,7 +85,7 @@ public String composeGreeting(String greeting, String name) {
 
   public static void main(String[] args) {
     // gRPC stubs wrapper that talks to the local docker instance of temporal service.
-    WorkflowServiceStubs service = WorkflowServiceStubs.newInstance();
+    WorkflowServiceStubs service = WorkflowServiceStubs.newLocalServiceStubs();
     // client that can be used to start and signal workflows
     WorkflowClient client =
         WorkflowClient.newInstance(
diff --git a/src/main/java/io/temporal/samples/fileprocessing/FileProcessingStarter.java b/src/main/java/io/temporal/samples/fileprocessing/FileProcessingStarter.java
@@ -31,7 +31,7 @@ public class FileProcessingStarter {
 
   public static void main(String[] args) throws Exception {
     // gRPC stubs wrapper that talks to the local docker instance of temporal service.
-    WorkflowServiceStubs service = WorkflowServiceStubs.newInstance();
+    WorkflowServiceStubs service = WorkflowServiceStubs.newLocalServiceStubs();
     // client that can be used to start and signal workflows
     WorkflowClient client = WorkflowClient.newInstance(service);
     FileProcessingWorkflow workflow =
diff --git a/src/main/java/io/temporal/samples/fileprocessing/FileProcessingWorker.java b/src/main/java/io/temporal/samples/fileprocessing/FileProcessingWorker.java
@@ -41,7 +41,7 @@ public static void main(String[] args) {
     String hostSpecifiTaskQueue = ManagementFactory.getRuntimeMXBean().getName();
 
     // gRPC stubs wrapper that talks to the local docker instance of temporal service.
-    WorkflowServiceStubs service = WorkflowServiceStubs.newInstance();
+    WorkflowServiceStubs service = WorkflowServiceStubs.newLocalServiceStubs();
     // client that can be used to start and signal workflows
     WorkflowClient client = WorkflowClient.newInstance(service);
 
diff --git a/src/main/java/io/temporal/samples/getresultsasync/Worker.java b/src/main/java/io/temporal/samples/getresultsasync/Worker.java
@@ -24,7 +24,7 @@
 import io.temporal.worker.WorkerFactory;
 
 public class Worker {
-  public static final WorkflowServiceStubs service = WorkflowServiceStubs.newInstance();
+  public static final WorkflowServiceStubs service = WorkflowServiceStubs.newLocalServiceStubs();
   public static final WorkflowClient client = WorkflowClient.newInstance(service);
   public static final WorkerFactory factory = WorkerFactory.newInstance(client);
   public static final String TASK_QUEUE_NAME = "asyncstartqueue";
diff --git a/src/main/java/io/temporal/samples/hello/HelloActivity.java b/src/main/java/io/temporal/samples/hello/HelloActivity.java
@@ -120,7 +120,7 @@ public String composeGreeting(String greeting, String name) {
   public static void main(String[] args) {
 
     // Get a Workflow service stub.
-    WorkflowServiceStubs service = WorkflowServiceStubs.newInstance();
+    WorkflowServiceStubs service = WorkflowServiceStubs.newLocalServiceStubs();
 
     /*
      * Get a Workflow service client which can be used to start, Signal, and Query Workflow Executions.
diff --git a/src/main/java/io/temporal/samples/hello/HelloActivityExclusiveChoice.java b/src/main/java/io/temporal/samples/hello/HelloActivityExclusiveChoice.java
@@ -184,7 +184,7 @@ public static void main(String[] args) {
      * Define the workflow service. It is a gRPC stubs wrapper which talks to the docker instance of
      * our locally running Temporal service.
      */
-    WorkflowServiceStubs service = WorkflowServiceStubs.newInstance();
+    WorkflowServiceStubs service = WorkflowServiceStubs.newLocalServiceStubs();
 
     /*
      * Get a Workflow service client which can be used to start, Signal, and Query Workflow Executions.
diff --git a/src/main/java/io/temporal/samples/hello/HelloActivityRetry.java b/src/main/java/io/temporal/samples/hello/HelloActivityRetry.java
@@ -160,7 +160,7 @@ public synchronized String composeGreeting(String greeting, String name) {
   public static void main(String[] args) {
 
     // Get a Workflow service stub.
-    WorkflowServiceStubs service = WorkflowServiceStubs.newInstance();
+    WorkflowServiceStubs service = WorkflowServiceStubs.newLocalServiceStubs();
 
     /*
      * Get a Workflow service client which can be used to start, Signal, and Query Workflow Executions.
diff --git a/src/main/java/io/temporal/samples/hello/HelloAsync.java b/src/main/java/io/temporal/samples/hello/HelloAsync.java
@@ -130,7 +130,7 @@ public String composeGreeting(String greeting, String name) {
   public static void main(String[] args) {
 
     // Get a Workflow service stub.
-    WorkflowServiceStubs service = WorkflowServiceStubs.newInstance();
+    WorkflowServiceStubs service = WorkflowServiceStubs.newLocalServiceStubs();
 
     /*
      * Get a Workflow service client which can be used to start, Signal, and Query Workflow Executions.
diff --git a/src/main/java/io/temporal/samples/hello/HelloAsyncActivityCompletion.java b/src/main/java/io/temporal/samples/hello/HelloAsyncActivityCompletion.java
@@ -163,7 +163,7 @@ private void composeGreetingAsync(byte[] taskToken, String greeting, String name
   public static void main(String[] args) throws ExecutionException, InterruptedException {
 
     // Get a Workflow service stub.
-    WorkflowServiceStubs service = WorkflowServiceStubs.newInstance();
+    WorkflowServiceStubs service = WorkflowServiceStubs.newLocalServiceStubs();
 
     /**
      * Get a Workflow service client which can be used to start, Signal, and Query Workflow
diff --git a/src/main/java/io/temporal/samples/hello/HelloAsyncLambda.java b/src/main/java/io/temporal/samples/hello/HelloAsyncLambda.java
@@ -148,7 +148,7 @@ public String composeGreeting(String greeting, String name) {
   public static void main(String[] args) {
 
     // Get a Workflow service stub.
-    WorkflowServiceStubs service = WorkflowServiceStubs.newInstance();
+    WorkflowServiceStubs service = WorkflowServiceStubs.newLocalServiceStubs();
 
     /*
      * Get a Workflow service client which can be used to start, Signal, and Query Workflow Executions.
diff --git a/src/main/java/io/temporal/samples/hello/HelloCancellationScope.java b/src/main/java/io/temporal/samples/hello/HelloCancellationScope.java
@@ -246,7 +246,7 @@ private void sleep(int seconds) {
   public static void main(String[] args) {
 
     // Get a Workflow service stub.
-    WorkflowServiceStubs service = WorkflowServiceStubs.newInstance();
+    WorkflowServiceStubs service = WorkflowServiceStubs.newLocalServiceStubs();
 
     /*
      * Get a Workflow service client which can be used to start, Signal, and Query Workflow Executions.
diff --git a/src/main/java/io/temporal/samples/hello/HelloChild.java b/src/main/java/io/temporal/samples/hello/HelloChild.java
@@ -125,7 +125,7 @@ public String composeGreeting(String greeting, String name) {
   public static void main(String[] args) {
 
     // Get a Workflow service stub.
-    WorkflowServiceStubs service = WorkflowServiceStubs.newInstance();
+    WorkflowServiceStubs service = WorkflowServiceStubs.newLocalServiceStubs();
 
     /*
      * Get a Workflow service client which can be used to start, Signal, and Query Workflow Executions.
diff --git a/src/main/java/io/temporal/samples/hello/HelloCron.java b/src/main/java/io/temporal/samples/hello/HelloCron.java
@@ -128,7 +128,7 @@ public void greet(String greeting) {
   public static void main(String[] args) {
 
     // Get a Workflow service stub.
-    WorkflowServiceStubs service = WorkflowServiceStubs.newInstance();
+    WorkflowServiceStubs service = WorkflowServiceStubs.newLocalServiceStubs();
 
     /*
      * Get a Workflow service client which can be used to start, Signal, and Query Workflow Executions.
diff --git a/src/main/java/io/temporal/samples/hello/HelloDetachedCancellationScope.java b/src/main/java/io/temporal/samples/hello/HelloDetachedCancellationScope.java
@@ -151,7 +151,7 @@ public String queryGreeting() {
   public static void main(String[] args) throws InterruptedException {
 
     // Get a Workflow service stub.
-    WorkflowServiceStubs service = WorkflowServiceStubs.newInstance();
+    WorkflowServiceStubs service = WorkflowServiceStubs.newLocalServiceStubs();
 
     /**
      * Get a Workflow service client which can be used to start, Signal, and Query Workflow
diff --git a/src/main/java/io/temporal/samples/hello/HelloDynamic.java b/src/main/java/io/temporal/samples/hello/HelloDynamic.java
@@ -91,7 +91,7 @@ public Object execute(EncodedValues args) {
   public static void main(String[] arg) {
 
     // Get a Workflow service stub.
-    WorkflowServiceStubs service = WorkflowServiceStubs.newInstance();
+    WorkflowServiceStubs service = WorkflowServiceStubs.newLocalServiceStubs();
 
     /**
      * Get a Workflow service client which can be used to start, Signal, and Query Workflow
diff --git a/src/main/java/io/temporal/samples/hello/HelloException.java b/src/main/java/io/temporal/samples/hello/HelloException.java
@@ -172,7 +172,7 @@ public String composeGreeting(String greeting, String name) {
   public static void main(String[] args) {
 
     // Define the workflow service.
-    WorkflowServiceStubs service = WorkflowServiceStubs.newInstance();
+    WorkflowServiceStubs service = WorkflowServiceStubs.newLocalServiceStubs();
 
     /*
      * Get a Workflow service client which can be used to start, Signal, and Query Workflow Executions.
diff --git a/src/main/java/io/temporal/samples/hello/HelloLocalActivity.java b/src/main/java/io/temporal/samples/hello/HelloLocalActivity.java
@@ -110,7 +110,7 @@ public String composeGreeting(String greeting, String name) {
 
   public static void main(String[] args) {
     // gRPC stubs wrapper that talks to the local docker instance of temporal service.
-    WorkflowServiceStubs service = WorkflowServiceStubs.newInstance();
+    WorkflowServiceStubs service = WorkflowServiceStubs.newLocalServiceStubs();
     // client that can be used to start and signal workflows
     WorkflowClient client = WorkflowClient.newInstance(service);
 
diff --git a/src/main/java/io/temporal/samples/hello/HelloParallelActivity.java b/src/main/java/io/temporal/samples/hello/HelloParallelActivity.java
@@ -136,7 +136,7 @@ public List<String> getGreetings(List<String> names) {
   public static void main(String[] args) {
 
     // Define the workflow service.
-    WorkflowServiceStubs service = WorkflowServiceStubs.newInstance();
+    WorkflowServiceStubs service = WorkflowServiceStubs.newLocalServiceStubs();
 
     /*
      * Get a Workflow service client which can be used to start, Signal, and Query Workflow Executions.
diff --git a/src/main/java/io/temporal/samples/hello/HelloPeriodic.java b/src/main/java/io/temporal/samples/hello/HelloPeriodic.java
@@ -203,7 +203,7 @@ public void greet(String greeting) {
   public static void main(String[] args) throws InterruptedException {
 
     // Define the workflow service.
-    WorkflowServiceStubs service = WorkflowServiceStubs.newInstance();
+    WorkflowServiceStubs service = WorkflowServiceStubs.newLocalServiceStubs();
 
     /*
      * Get a Workflow service client which can be used to start, Signal, and Query Workflow Executions.
diff --git a/src/main/java/io/temporal/samples/hello/HelloPolymorphicActivity.java b/src/main/java/io/temporal/samples/hello/HelloPolymorphicActivity.java
@@ -170,7 +170,7 @@ public String composeGreeting(String name) {
   public static void main(String[] args) {
 
     // Define the workflow service.
-    WorkflowServiceStubs service = WorkflowServiceStubs.newInstance();
+    WorkflowServiceStubs service = WorkflowServiceStubs.newLocalServiceStubs();
 
     /*
      * Get a Workflow service client which can be used to start, Signal, and Query Workflow Executions.
diff --git a/src/main/java/io/temporal/samples/hello/HelloQuery.java b/src/main/java/io/temporal/samples/hello/HelloQuery.java
@@ -98,7 +98,7 @@ public String queryGreeting() {
   public static void main(String[] args) throws InterruptedException {
 
     // Define the workflow service.
-    WorkflowServiceStubs service = WorkflowServiceStubs.newInstance();
+    WorkflowServiceStubs service = WorkflowServiceStubs.newLocalServiceStubs();
 
     /*
      * Get a Workflow service client which can be used to start, Signal, and Query Workflow Executions.
diff --git a/src/main/java/io/temporal/samples/hello/HelloSaga.java b/src/main/java/io/temporal/samples/hello/HelloSaga.java
@@ -278,7 +278,7 @@ public void execute() {
   public static void main(String[] args) {
 
     // Define the workflow service.
-    WorkflowServiceStubs service = WorkflowServiceStubs.newInstance();
+    WorkflowServiceStubs service = WorkflowServiceStubs.newLocalServiceStubs();
 
     /*
      * Get a Workflow service client which can be used to start, Signal, and Query Workflow Executions.
diff --git a/src/main/java/io/temporal/samples/hello/HelloSearchAttributes.java b/src/main/java/io/temporal/samples/hello/HelloSearchAttributes.java
@@ -132,7 +132,7 @@ public String composeGreeting(String greeting, String name) {
   public static void main(String[] args) {
 
     // Define the workflow service.
-    WorkflowServiceStubs service = WorkflowServiceStubs.newInstance();
+    WorkflowServiceStubs service = WorkflowServiceStubs.newLocalServiceStubs();
 
     /*
      * Get a Workflow service client which can be used to start, Signal, and Query Workflow Executions.
diff --git a/src/main/java/io/temporal/samples/hello/HelloSideEffect.java b/src/main/java/io/temporal/samples/hello/HelloSideEffect.java
@@ -179,7 +179,7 @@ public String sayGoodBye(String greeting) {
   public static void main(String[] args) {
 
     // Define the workflow service.
-    WorkflowServiceStubs service = WorkflowServiceStubs.newInstance();
+    WorkflowServiceStubs service = WorkflowServiceStubs.newLocalServiceStubs();
 
     /**
      * Get a Workflow service client which can be used to start, Signal, and Query Workflow
diff --git a/src/main/java/io/temporal/samples/hello/HelloSignal.java b/src/main/java/io/temporal/samples/hello/HelloSignal.java
@@ -114,7 +114,7 @@ public void exit() {
   public static void main(String[] args) throws Exception {
 
     // Get a Workflow service stub.
-    WorkflowServiceStubs service = WorkflowServiceStubs.newInstance();
+    WorkflowServiceStubs service = WorkflowServiceStubs.newLocalServiceStubs();
 
     /*
      * Get a Workflow service client which can be used to start, Signal, and Query Workflow Executions.
diff --git a/src/main/java/io/temporal/samples/interceptor/InterceptorStarter.java b/src/main/java/io/temporal/samples/interceptor/InterceptorStarter.java
@@ -42,7 +42,7 @@ public class InterceptorStarter {
   private static final Logger logger = LoggerFactory.getLogger(SimpleCountWorkerInterceptor.class);
 
   public static void main(String[] args) {
-    WorkflowServiceStubs service = WorkflowServiceStubs.newInstance();
+    WorkflowServiceStubs service = WorkflowServiceStubs.newLocalServiceStubs();
     WorkflowClient client = WorkflowClient.newInstance(service);
 
     WorkerFactoryOptions wfo =
diff --git a/src/main/java/io/temporal/samples/listworkflows/Starter.java b/src/main/java/io/temporal/samples/listworkflows/Starter.java
@@ -35,7 +35,7 @@
 
 public class Starter {
   public static final String TASK_QUEUE = "customerTaskQueue";
-  private static final WorkflowServiceStubs service = WorkflowServiceStubs.newInstance();
+  private static final WorkflowServiceStubs service = WorkflowServiceStubs.newLocalServiceStubs();
   private static final WorkflowClient client = WorkflowClient.newInstance(service);
   private static final WorkerFactory factory = WorkerFactory.newInstance(client);
 
diff --git a/src/main/java/io/temporal/samples/moneybatch/AccountActivityWorker.java b/src/main/java/io/temporal/samples/moneybatch/AccountActivityWorker.java
@@ -30,7 +30,7 @@ public class AccountActivityWorker {
 
   @SuppressWarnings("CatchAndPrintStackTrace")
   public static void main(String[] args) {
-    WorkflowServiceStubs service = WorkflowServiceStubs.newInstance();
+    WorkflowServiceStubs service = WorkflowServiceStubs.newLocalServiceStubs();
     WorkflowClient client = WorkflowClient.newInstance(service);
 
     WorkerFactory factory = WorkerFactory.newInstance(client);
diff --git a/src/main/java/io/temporal/samples/moneybatch/AccountTransferWorker.java b/src/main/java/io/temporal/samples/moneybatch/AccountTransferWorker.java
@@ -28,7 +28,7 @@ public class AccountTransferWorker {
 
   @SuppressWarnings("CatchAndPrintStackTrace")
   public static void main(String[] args) {
-    WorkflowServiceStubs service = WorkflowServiceStubs.newInstance();
+    WorkflowServiceStubs service = WorkflowServiceStubs.newLocalServiceStubs();
     WorkflowClient client = WorkflowClient.newInstance(service);
     WorkerFactory factory = WorkerFactory.newInstance(client);
 
diff --git a/src/main/java/io/temporal/samples/moneybatch/TransferRequester.java b/src/main/java/io/temporal/samples/moneybatch/TransferRequester.java
@@ -35,7 +35,7 @@ public class TransferRequester {
   public static void main(String[] args) {
     String reference = UUID.randomUUID().toString();
     int amountCents = (new Random().nextInt(5) + 1) * 25;
-    WorkflowServiceStubs service = WorkflowServiceStubs.newInstance();
+    WorkflowServiceStubs service = WorkflowServiceStubs.newLocalServiceStubs();
     WorkflowClient workflowClient = WorkflowClient.newInstance(service);
 
     String from = "account1";
diff --git a/src/main/java/io/temporal/samples/moneytransfer/AccountActivityWorker.java b/src/main/java/io/temporal/samples/moneytransfer/AccountActivityWorker.java
@@ -31,7 +31,7 @@ public class AccountActivityWorker {
   @SuppressWarnings("CatchAndPrintStackTrace")
   public static void main(String[] args) {
     // gRPC stubs wrapper that talks to the local docker instance of temporal service.
-    WorkflowServiceStubs service = WorkflowServiceStubs.newInstance();
+    WorkflowServiceStubs service = WorkflowServiceStubs.newLocalServiceStubs();
     // client that can be used to start and signal workflows
     WorkflowClient client = WorkflowClient.newInstance(service);
 
diff --git a/src/main/java/io/temporal/samples/moneytransfer/AccountTransferWorker.java b/src/main/java/io/temporal/samples/moneytransfer/AccountTransferWorker.java
@@ -32,7 +32,7 @@ public class AccountTransferWorker {
   public static void main(String[] args) {
     // Get worker to poll the common task queue.
     // gRPC stubs wrapper that talks to the local docker instance of temporal service.
-    WorkflowServiceStubs service = WorkflowServiceStubs.newInstance();
+    WorkflowServiceStubs service = WorkflowServiceStubs.newLocalServiceStubs();
     // client that can be used to start and signal workflows
     WorkflowClient client = WorkflowClient.newInstance(service);
 
diff --git a/src/main/java/io/temporal/samples/moneytransfer/TransferRequester.java b/src/main/java/io/temporal/samples/moneytransfer/TransferRequester.java
@@ -40,7 +40,7 @@ public static void main(String[] args) {
       reference = args[0];
       amountCents = Integer.parseInt(args[1]);
     }
-    WorkflowServiceStubs service = WorkflowServiceStubs.newInstance();
+    WorkflowServiceStubs service = WorkflowServiceStubs.newLocalServiceStubs();
     // client that can be used to start and signal workflows
     WorkflowClient workflowClient = WorkflowClient.newInstance(service);
 
diff --git a/src/main/java/io/temporal/samples/payloadconverter/cloudevents/Starter.java b/src/main/java/io/temporal/samples/payloadconverter/cloudevents/Starter.java
@@ -39,7 +39,7 @@ public class Starter {
   private static final String TASK_QUEUE = "CloudEventsConverterQueue";
 
   public static void main(String[] args) {
-    WorkflowServiceStubs service = WorkflowServiceStubs.newInstance();
+    WorkflowServiceStubs service = WorkflowServiceStubs.newLocalServiceStubs();
 
     // Add CloudEventsPayloadConverter
     // It has the same encoding type as JacksonJsonPayloadConverter
diff --git a/src/main/java/io/temporal/samples/payloadconverter/crypto/Starter.java b/src/main/java/io/temporal/samples/payloadconverter/crypto/Starter.java
diff --git a/src/main/java/io/temporal/samples/peractivityoptions/Starter.java b/src/main/java/io/temporal/samples/peractivityoptions/Starter.java
diff --git a/src/main/java/io/temporal/samples/polling/frequent/FrequentPollingActivityImpl.java b/src/main/java/io/temporal/samples/polling/frequent/FrequentPollingActivityImpl.java
diff --git a/src/main/java/io/temporal/samples/polling/frequent/FrequentPollingStarter.java b/src/main/java/io/temporal/samples/polling/frequent/FrequentPollingStarter.java
diff --git a/src/main/java/io/temporal/samples/polling/infrequent/InfrequentPollingStarter.java b/src/main/java/io/temporal/samples/polling/infrequent/InfrequentPollingStarter.java
diff --git a/src/main/java/io/temporal/samples/polling/periodicsequence/PeriodicPollingStarter.java b/src/main/java/io/temporal/samples/polling/periodicsequence/PeriodicPollingStarter.java
diff --git a/src/main/java/io/temporal/samples/terminateworkflow/Starter.java b/src/main/java/io/temporal/samples/terminateworkflow/Starter.java
diff --git a/src/main/java/io/temporal/samples/tracing/Starter.java b/src/main/java/io/temporal/samples/tracing/Starter.java
diff --git a/src/main/java/io/temporal/samples/tracing/TracingWorker.java b/src/main/java/io/temporal/samples/tracing/TracingWorker.java
diff --git a/src/main/java/io/temporal/samples/updatabletimer/DynamicSleepWorkflowStarter.java b/src/main/java/io/temporal/samples/updatabletimer/DynamicSleepWorkflowStarter.java
diff --git a/src/main/java/io/temporal/samples/updatabletimer/DynamicSleepWorkflowWorker.java b/src/main/java/io/temporal/samples/updatabletimer/DynamicSleepWorkflowWorker.java
diff --git a/src/main/java/io/temporal/samples/updatabletimer/WakeUpTimeUpdater.java b/src/main/java/io/temporal/samples/updatabletimer/WakeUpTimeUpdater.java
