Renamed EchoHandler to EchoClient

Author: Evanthx

…l/samples/nexus/handler/EchoHandler.java …al/samples/nexus/handler/EchoClient.javacore/src/main/java/io/temporal/samples/nexus/handler/EchoHandler.java renamed to core/src/main/java/io/temporal/samples/nexus/handler/EchoClient.java core/src/main/java/io/temporal/samples/nexus/handler/EchoHandler.java renamed to core/src/main/java/io/temporal/samples/nexus/handler/EchoClient.java

@@ -2,6 +2,6 @@
 
 import io.temporal.samples.nexus.service.NexusService;
 
-public interface EchoHandler {
+public interface EchoClient {
   NexusService.EchoOutput echo(NexusService.EchoInput input);
 }

…mples/nexus/handler/EchoHandlerImpl.java …amples/nexus/handler/EchoClientImpl.javacore/src/main/java/io/temporal/samples/nexus/handler/EchoHandlerImpl.java renamed to core/src/main/java/io/temporal/samples/nexus/handler/EchoClientImpl.java core/src/main/java/io/temporal/samples/nexus/handler/EchoHandlerImpl.java renamed to core/src/main/java/io/temporal/samples/nexus/handler/EchoClientImpl.java

@@ -4,7 +4,7 @@
 
 // Note that this is a class, not a Temporal worker. This is to demonstrate that Nexus services can
 // simply call a class instead of a worker for fast operations that don't need retry handling.
-public class EchoHandlerImpl implements EchoHandler {
+public class EchoClientImpl implements EchoClient {
   @Override
   public NexusService.EchoOutput echo(NexusService.EchoInput input) {
     return new NexusService.EchoOutput(input.getMessage());

core/src/main/java/io/temporal/samples/nexus/handler/NexusServiceImpl.java

@@ -13,22 +13,22 @@
 // return OperationHandler that correspond to the operations defined in the service interface.
 @ServiceImpl(service = NexusService.class)
 public class NexusServiceImpl {
-  private final EchoHandler echoHandler;
+  private final EchoClient echoClient;
 
-  // The injected EchoHandler makes this class unit-testable.
+  // The injected EchoClient makes this class unit-testable.
   // The no-arg constructor provides a default; the second allows tests to inject a mock.
   // If you are not using the sync call or do not need to mock a handler, then you will not
   // need this constructor pairing.
   public NexusServiceImpl() {
-    this(new EchoHandlerImpl());
+    this(new EchoClientImpl());
   }
 
-  public NexusServiceImpl(EchoHandler echoHandler) {
-    this.echoHandler = echoHandler;
+  public NexusServiceImpl(EchoClient echoClient) {
+    this.echoClient = echoClient;
   }
 
   // The Echo Nexus Service exemplifies making a synchronous call using OperationHandler.sync.
-  // In this case, it is calling the EchoHandler class - not a workflow - and simply returning the
+  // In this case, it is calling the EchoClient class - not a workflow - and simply returning the
   // result.
   @OperationImpl
   public OperationHandler<NexusService.EchoInput, NexusService.EchoOutput> echo() {
@@ -38,7 +38,7 @@ public OperationHandler<NexusService.EchoInput, NexusService.EchoOutput> echo()
         // calling
         // Nexus.getOperationContext().getWorkflowClient(ctx) to make arbitrary calls such as
         // signaling, querying, or listing workflows.
-        (ctx, details, input) -> echoHandler.echo(input));
+        (ctx, details, input) -> echoClient.echo(input));
   }
 
   @OperationImpl

core/src/test/java/io/temporal/samples/nexus/caller/CallerWorkflowJunit5MockTest.java

@@ -3,7 +3,7 @@
 import static org.junit.jupiter.api.Assertions.assertEquals;
 import static org.mockito.Mockito.*;
 
-import io.temporal.samples.nexus.handler.EchoHandler;
+import io.temporal.samples.nexus.handler.EchoClient;
 import io.temporal.samples.nexus.handler.HelloHandlerWorkflow;
 import io.temporal.samples.nexus.handler.NexusServiceImpl;
 import io.temporal.samples.nexus.service.NexusService;
@@ -20,7 +20,7 @@ public class CallerWorkflowJunit5MockTest {
 
   // Sync Nexus operations run inline in the handler thread — there is no backing workflow to
   // register a factory for. To mock one, inject a mock dependency into the service implementation.
-  private static final EchoHandler mockEchoHandler = mock(EchoHandler.class);
+  private static final EchoClient mockEchoClient = mock(EchoClient.class);
 
   @RegisterExtension
   public static final TestWorkflowExtension testWorkflowExtension =
@@ -29,7 +29,7 @@ public class CallerWorkflowJunit5MockTest {
           // the TestWorkflowExtension will, by default, automatically create a Nexus service
           // endpoint and workflows registered as part of the TestWorkflowExtension will
           // automatically inherit the endpoint if none is set.
-          .setNexusServiceImplementation(new NexusServiceImpl(mockEchoHandler))
+          .setNexusServiceImplementation(new NexusServiceImpl(mockEchoClient))
           // The Echo Nexus handler service just makes a call to a class, so no extra setup is
           // needed. But the Hello Nexus service needs a worker for both the caller and handler
           // in order to run, and the Echo Nexus caller service needs a worker.
@@ -66,8 +66,8 @@ public void testHelloWorkflow(
   public void testEchoWorkflow(
       TestWorkflowEnvironment testEnv, Worker worker, EchoCallerWorkflow workflow) {
     // Sync Nexus operations run inline in the handler thread — there is no backing workflow to
-    // register a factory for. Instead, stub the injected EchoHandler dependency directly.
-    when(mockEchoHandler.echo(any())).thenReturn(new NexusService.EchoOutput("mocked echo"));
+    // register a factory for. Instead, stub the injected EchoClient dependency directly.
+    when(mockEchoClient.echo(any())).thenReturn(new NexusService.EchoOutput("mocked echo"));
     testEnv.start();
 
     // Execute a workflow waiting for it to complete.

core/src/test/java/io/temporal/samples/nexus/caller/CallerWorkflowMockTest.java

@@ -6,7 +6,7 @@
 import static org.mockito.Mockito.when;
 
 import io.temporal.client.WorkflowOptions;
-import io.temporal.samples.nexus.handler.EchoHandler;
+import io.temporal.samples.nexus.handler.EchoClient;
 import io.temporal.samples.nexus.handler.HelloHandlerWorkflow;
 import io.temporal.samples.nexus.handler.NexusServiceImpl;
 import io.temporal.samples.nexus.service.NexusService;
@@ -19,9 +19,9 @@
 
 public class CallerWorkflowMockTest {
 
-  // Inject a mock EchoHandler so sync Nexus operations can be stubbed per test.
+  // Inject a mock EchoClient so sync Nexus operations can be stubbed per test.
   // JUnit 4 creates a new test class instance per test method, so this mock is fresh each time.
-  private final EchoHandler mockEchoHandler = mock(EchoHandler.class);
+  private final EchoClient mockEchoClient = mock(EchoClient.class);
 
   @Rule
   public TestWorkflowRule testWorkflowRule =
@@ -30,7 +30,7 @@ public class CallerWorkflowMockTest {
           // the TestWorkflowRule will, by default, automatically create a Nexus service endpoint
           // and workflows registered as part of the TestWorkflowRule
           // will automatically inherit the endpoint if none is set.
-          .setNexusServiceImplementation(new NexusServiceImpl(mockEchoHandler))
+          .setNexusServiceImplementation(new NexusServiceImpl(mockEchoClient))
           // The Echo Nexus handler service just makes a call to a class, so no extra setup is
           // needed. But the Hello Nexus service needs a worker for both the caller and handler
           // in order to run.
@@ -73,8 +73,8 @@ public void testHelloWorkflow() {
   @Test
   public void testEchoWorkflow() {
     // Sync Nexus operations run inline in the handler thread — there is no backing workflow to
-    // register a factory for. Instead, stub the injected EchoHandler dependency directly.
-    when(mockEchoHandler.echo(any())).thenReturn(new NexusService.EchoOutput("mocked echo"));
+    // register a factory for. Instead, stub the injected EchoCient dependency directly.
+    when(mockEchoClient.echo(any())).thenReturn(new NexusService.EchoOutput("mocked echo"));
     testWorkflowRule.getTestEnvironment().start();
 
     EchoCallerWorkflow workflow =