rename runWorkerFactory -> startWorkerFactory

Author: donald-pinckney

temporal-sdk/src/main/java/io/temporal/common/plugin/WorkerPlugin.java

@@ -51,7 +51,7 @@
  *     }
  *
  *     @Override
- *     public void runWorkerFactory(WorkerFactory factory, Runnable next) throws Exception {
+ *     public void startWorkerFactory(WorkerFactory factory, Runnable next) throws Exception {
  *         registry.recordWorkerStart();
  *         try {
  *             next.run();
@@ -139,7 +139,7 @@ default void initializeWorker(@Nonnull String taskQueue, @Nonnull Worker worker)
    *
    * <pre>{@code
    * @Override
-   * public void runWorkerFactory(WorkerFactory factory, Runnable next) throws Exception {
+   * public void startWorkerFactory(WorkerFactory factory, Runnable next) throws Exception {
    *     logger.info("Starting workers...");
    *     next.run();
    *     logger.info("Workers started");
@@ -150,7 +150,7 @@ default void initializeWorker(@Nonnull String taskQueue, @Nonnull Worker worker)
    * @param next runnable that starts the next in chain (eventually starts actual workers)
    * @throws Exception if startup fails
    */
-  default void runWorkerFactory(@Nonnull WorkerFactory factory, @Nonnull Runnable next)
+  default void startWorkerFactory(@Nonnull WorkerFactory factory, @Nonnull Runnable next)
       throws Exception {
     next.run();
   }

temporal-sdk/src/main/java/io/temporal/worker/WorkerFactory.java

@@ -247,7 +247,7 @@ public synchronized void start() {
         startChain =
             () -> {
               try {
-                workerPlugin.runWorkerFactory(this, next);
+                workerPlugin.startWorkerFactory(this, next);
               } catch (RuntimeException e) {
                 throw e;
               } catch (Exception e) {

temporal-sdk/src/test/java/io/temporal/common/plugin/PluginTest.java

@@ -93,10 +93,10 @@ public String getName() {
     WorkerOptions.Builder workerBuilder = WorkerOptions.newBuilder();
     assertSame(workerBuilder, plugin.configureWorker("test-queue", workerBuilder));
 
-    // Test runWorkerFactory calls next
+    // Test startWorkerFactory calls next
     final boolean[] called = {false};
-    plugin.runWorkerFactory(null, () -> called[0] = true);
-    assertTrue("runWorkerFactory should call next", called[0]);
+    plugin.startWorkerFactory(null, () -> called[0] = true);
+    assertTrue("startWorkerFactory should call next", called[0]);
 
     // Test default initializeWorker is a no-op (doesn't throw)
     plugin.initializeWorker("test-queue", null);
@@ -150,7 +150,7 @@ public void testExecutionPhaseReverseOrder() throws Exception {
             () -> {
               order.add(workerPlugin.getName() + "-before");
               try {
-                workerPlugin.runWorkerFactory(null, next);
+                workerPlugin.startWorkerFactory(null, next);
               } catch (Exception e) {
                 throw new RuntimeException(e);
               }
@@ -192,7 +192,7 @@ public WorkflowClientOptions.Builder configureClient(WorkflowClientOptions.Build
   private PluginBase createExecutionTrackingPlugin(String name, List<String> order) {
     return new PluginBase(name) {
       @Override
-      public void runWorkerFactory(io.temporal.worker.WorkerFactory factory, Runnable next) {
+      public void startWorkerFactory(io.temporal.worker.WorkerFactory factory, Runnable next) {
         next.run();
       }
     };