Class TestWorkflowService

java.lang.Object
io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceImplBase
io.temporal.internal.testservice.TestWorkflowService
All Implemented Interfaces:
io.grpc.BindableService, Closeable, AutoCloseable
public final class TestWorkflowService extends io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceImplBase implements Closeable
In memory implementation of the Workflow Service. To be used for testing purposes only.

Do not use directly, instead use io.temporal.testing.TestWorkflowEnvironment.

  • Constructor Summary

    Constructors
    Constructor
    Description
    TestWorkflowService()
    Deprecated.
    use TestServer.createServer(boolean) instead and pass lockTimeSkipping=false to emulate the behavior of this method
    TestWorkflowService(boolean lockTimeSkipping)
    Deprecated.
    use TestServer.createServer(boolean) instead
    TestWorkflowService(long initialTimeMillis)
    Deprecated.
    use TestServer.createServer(boolean, long) instead and pass lockTimeSkipping=false to emulate the behavior of this method

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    close()
     
    void
    completeNexusOperation(NexusOperationRef ref, String operationID, io.temporal.api.nexus.v1.Link startLink, io.temporal.api.history.v1.HistoryEvent completionEvent)
     
    String
    continueAsNew(io.temporal.api.workflowservice.v1.StartWorkflowExecutionRequest previousRunStartRequest, io.temporal.api.command.v1.ContinueAsNewWorkflowExecutionCommandAttributes ca, io.temporal.api.history.v1.WorkflowExecutionContinuedAsNewEventAttributes ea, Optional<io.temporal.internal.testservice.TestServiceRetryState> retryState, String identity, ExecutionId continuedExecutionId, String firstExecutionRunId, io.temporal.internal.testservice.TestWorkflowMutableState previousExecutionState, Optional<io.temporal.internal.testservice.TestWorkflowMutableState> parent, OptionalLong parentChildInitiatedEventId)
    Creates next run of a workflow execution
    static TestWorkflowService
    createServerOnly(int port)
    Deprecated.
    use TestServer.createPortBoundServer(int, boolean) instead and pass lockTimeSkipping=false to emulate the behavior of this method
    static TestWorkflowService
    createWithNoGrpcServer()
    Deprecated.
    use TestServicesStarter to create just the services with gRPC server
    long
    currentTimeMillis()
    Deprecated.
    use TestServiceStubs and TestServiceGrpc.TestServiceBlockingStub.getCurrentTime(Empty)
    void
    deleteWorkerDeployment(io.temporal.api.workflowservice.v1.DeleteWorkerDeploymentRequest request, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.DeleteWorkerDeploymentResponse> responseObserver)
     
    void
    deleteWorkerDeploymentVersion(io.temporal.api.workflowservice.v1.DeleteWorkerDeploymentVersionRequest request, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.DeleteWorkerDeploymentVersionResponse> responseObserver)
     
    void
    describeDeployment(io.temporal.api.workflowservice.v1.DescribeDeploymentRequest request, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.DescribeDeploymentResponse> responseObserver)
     
    void
    describeNamespace(io.temporal.api.workflowservice.v1.DescribeNamespaceRequest request, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.DescribeNamespaceResponse> responseObserver)
    This method doesn't make much sense for test server, it accepts all namespaces as existent and registered.
    void
    describeWorkerDeployment(io.temporal.api.workflowservice.v1.DescribeWorkerDeploymentRequest request, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.DescribeWorkerDeploymentResponse> responseObserver)
     
    void
    describeWorkerDeploymentVersion(io.temporal.api.workflowservice.v1.DescribeWorkerDeploymentVersionRequest request, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.DescribeWorkerDeploymentVersionResponse> responseObserver)
     
    void
    describeWorkflowExecution(io.temporal.api.workflowservice.v1.DescribeWorkflowExecutionRequest request, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.DescribeWorkflowExecutionResponse> responseObserver)
     
    void
    executeMultiOperation(io.temporal.api.workflowservice.v1.ExecuteMultiOperationRequest request, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.ExecuteMultiOperationResponse> responseObserver)
     
    void
    getCurrentDeployment(io.temporal.api.workflowservice.v1.GetCurrentDeploymentRequest request, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.GetCurrentDeploymentResponse> responseObserver)
     
    void
    getDeploymentReachability(io.temporal.api.workflowservice.v1.GetDeploymentReachabilityRequest request, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.GetDeploymentReachabilityResponse> responseObserver)
     
    void
    getDiagnostics(StringBuilder result)
    Adds diagnostic data about internal service state to the provided StringBuilder.
    void
    getSystemInfo(io.temporal.api.workflowservice.v1.GetSystemInfoRequest request, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.GetSystemInfoResponse> responseObserver)
     
    void
    getWorkflowExecutionHistory(io.temporal.api.workflowservice.v1.GetWorkflowExecutionHistoryRequest getRequest, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.GetWorkflowExecutionHistoryResponse> responseObserver)
     
    void
    listClosedWorkflowExecutions(io.temporal.api.workflowservice.v1.ListClosedWorkflowExecutionsRequest listRequest, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.ListClosedWorkflowExecutionsResponse> responseObserver)
     
    void
    listDeployments(io.temporal.api.workflowservice.v1.ListDeploymentsRequest request, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.ListDeploymentsResponse> responseObserver)
     
    void
    listOpenWorkflowExecutions(io.temporal.api.workflowservice.v1.ListOpenWorkflowExecutionsRequest listRequest, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.ListOpenWorkflowExecutionsResponse> responseObserver)
     
    void
    listWorkerDeployments(io.temporal.api.workflowservice.v1.ListWorkerDeploymentsRequest request, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.ListWorkerDeploymentsResponse> responseObserver)
     
    void
    lockTimeSkipping(String caller)
    Deprecated.
    use TestServiceStubs and TestServiceGrpc.TestServiceBlockingStub.lockTimeSkipping(LockTimeSkippingRequest)
    io.temporal.serviceclient.WorkflowServiceStubs
    newClientStub()
    Deprecated.
    void
    pollActivityTaskQueue(io.temporal.api.workflowservice.v1.PollActivityTaskQueueRequest pollRequest, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.PollActivityTaskQueueResponse> responseObserver)
     
    void
    pollNexusTaskQueue(io.temporal.api.workflowservice.v1.PollNexusTaskQueueRequest request, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.PollNexusTaskQueueResponse> responseObserver)
     
    void
    pollWorkflowExecutionUpdate(io.temporal.api.workflowservice.v1.PollWorkflowExecutionUpdateRequest request, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.PollWorkflowExecutionUpdateResponse> responseObserver)
     
    void
    pollWorkflowTaskQueue(io.temporal.api.workflowservice.v1.PollWorkflowTaskQueueRequest pollRequest, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.PollWorkflowTaskQueueResponse> responseObserver)
     
    void
    queryWorkflow(io.temporal.api.workflowservice.v1.QueryWorkflowRequest queryRequest, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.QueryWorkflowResponse> responseObserver)
     
    void
    recordActivityTaskHeartbeat(io.temporal.api.workflowservice.v1.RecordActivityTaskHeartbeatRequest heartbeatRequest, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.RecordActivityTaskHeartbeatResponse> responseObserver)
     
    void
    recordActivityTaskHeartbeatById(io.temporal.api.workflowservice.v1.RecordActivityTaskHeartbeatByIdRequest heartbeatRequest, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.RecordActivityTaskHeartbeatByIdResponse> responseObserver)
     
    void
    registerDelayedCallback(Duration delay, Runnable r)
    Invokes callback after the specified delay according to internal service clock.
    void
    requestCancelWorkflowExecution(io.temporal.api.workflowservice.v1.RequestCancelWorkflowExecutionRequest cancelRequest, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.RequestCancelWorkflowExecutionResponse> responseObserver)
     
    void
    respondActivityTaskCanceled(io.temporal.api.workflowservice.v1.RespondActivityTaskCanceledRequest canceledRequest, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.RespondActivityTaskCanceledResponse> responseObserver)
     
    void
    respondActivityTaskCanceledById(io.temporal.api.workflowservice.v1.RespondActivityTaskCanceledByIdRequest canceledRequest, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.RespondActivityTaskCanceledByIdResponse> responseObserver)
     
    void
    respondActivityTaskCompleted(io.temporal.api.workflowservice.v1.RespondActivityTaskCompletedRequest completeRequest, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.RespondActivityTaskCompletedResponse> responseObserver)
     
    void
    respondActivityTaskCompletedById(io.temporal.api.workflowservice.v1.RespondActivityTaskCompletedByIdRequest completeRequest, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.RespondActivityTaskCompletedByIdResponse> responseObserver)
     
    void
    respondActivityTaskFailed(io.temporal.api.workflowservice.v1.RespondActivityTaskFailedRequest failRequest, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.RespondActivityTaskFailedResponse> responseObserver)
     
    void
    respondActivityTaskFailedById(io.temporal.api.workflowservice.v1.RespondActivityTaskFailedByIdRequest failRequest, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.RespondActivityTaskFailedByIdResponse> responseObserver)
     
    void
    respondNexusTaskCompleted(io.temporal.api.workflowservice.v1.RespondNexusTaskCompletedRequest request, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.RespondNexusTaskCompletedResponse> responseObserver)
     
    void
    respondNexusTaskFailed(io.temporal.api.workflowservice.v1.RespondNexusTaskFailedRequest request, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.RespondNexusTaskFailedResponse> responseObserver)
     
    void
    respondQueryTaskCompleted(io.temporal.api.workflowservice.v1.RespondQueryTaskCompletedRequest completeRequest, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.RespondQueryTaskCompletedResponse> responseObserver)
     
    void
    respondWorkflowTaskCompleted(io.temporal.api.workflowservice.v1.RespondWorkflowTaskCompletedRequest request, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.RespondWorkflowTaskCompletedResponse> responseObserver)
     
    void
    respondWorkflowTaskFailed(io.temporal.api.workflowservice.v1.RespondWorkflowTaskFailedRequest failedRequest, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.RespondWorkflowTaskFailedResponse> responseObserver)
     
    void
    setCurrentDeployment(io.temporal.api.workflowservice.v1.SetCurrentDeploymentRequest request, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.SetCurrentDeploymentResponse> responseObserver)
     
    void
    setWorkerDeploymentCurrentVersion(io.temporal.api.workflowservice.v1.SetWorkerDeploymentCurrentVersionRequest request, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.SetWorkerDeploymentCurrentVersionResponse> responseObserver)
     
    void
    setWorkerDeploymentRampingVersion(io.temporal.api.workflowservice.v1.SetWorkerDeploymentRampingVersionRequest request, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.SetWorkerDeploymentRampingVersionResponse> responseObserver)
     
    void
    shutdownWorker(io.temporal.api.workflowservice.v1.ShutdownWorkerRequest request, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.ShutdownWorkerResponse> responseObserver)
     
    void
    signalExternalWorkflowExecution(String signalId, io.temporal.api.command.v1.SignalExternalWorkflowExecutionCommandAttributes commandAttributes, io.temporal.internal.testservice.TestWorkflowMutableState source)
     
    void
    signalWithStartWorkflowExecution(io.temporal.api.workflowservice.v1.SignalWithStartWorkflowExecutionRequest r, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.SignalWithStartWorkflowExecutionResponse> responseObserver)
     
    void
    signalWorkflowExecution(io.temporal.api.workflowservice.v1.SignalWorkflowExecutionRequest signalRequest, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.SignalWorkflowExecutionResponse> responseObserver)
     
    void
    sleep(Duration duration)
    Deprecated.
    use TestServiceStubs and TestServiceGrpc.TestServiceBlockingStub.unlockTimeSkippingWithSleep(SleepRequest)
    void
    startWorkflowExecution(io.temporal.api.workflowservice.v1.StartWorkflowExecutionRequest request, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.StartWorkflowExecutionResponse> responseObserver)
     
    void
    terminateWorkflowExecution(io.temporal.api.workflowservice.v1.TerminateWorkflowExecutionRequest request, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.TerminateWorkflowExecutionResponse> responseObserver)
     
    void
    unlockTimeSkipping(String caller)
    Deprecated.
    use TestServiceStubs and TestServiceGrpc.TestServiceBlockingStub.unlockTimeSkipping(UnlockTimeSkippingRequest)
    void
    updateWorkerDeploymentVersionMetadata(io.temporal.api.workflowservice.v1.UpdateWorkerDeploymentVersionMetadataRequest request, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.UpdateWorkerDeploymentVersionMetadataResponse> responseObserver)
     
    void
    updateWorkflowExecution(io.temporal.api.workflowservice.v1.UpdateWorkflowExecutionRequest request, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.UpdateWorkflowExecutionResponse> responseObserver)
     

    Methods inherited from class io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceImplBase

    bindService, countActivityExecutions, countNexusOperationExecutions, countSchedules, countWorkers, countWorkflowExecutions, createSchedule, createWorkerDeployment, createWorkerDeploymentVersion, createWorkflowRule, deleteActivityExecution, deleteNexusOperationExecution, deleteSchedule, deleteWorkflowExecution, deleteWorkflowRule, deprecateNamespace, describeActivityExecution, describeBatchOperation, describeNexusOperationExecution, describeSchedule, describeTaskQueue, describeWorker, describeWorkflowRule, fetchWorkerConfig, getClusterInfo, getSearchAttributes, getWorkerBuildIdCompatibility, getWorkerTaskReachability, getWorkerVersioningRules, getWorkflowExecutionHistoryReverse, listActivityExecutions, listArchivedWorkflowExecutions, listBatchOperations, listNamespaces, listNexusOperationExecutions, listScheduleMatchingTimes, listSchedules, listTaskQueuePartitions, listWorkers, listWorkflowExecutions, listWorkflowRules, patchSchedule, pauseActivity, pauseActivityExecution, pauseWorkflowExecution, pollActivityExecution, pollNexusOperationExecution, recordWorkerHeartbeat, registerNamespace, requestCancelActivityExecution, requestCancelNexusOperationExecution, resetActivity, resetActivityExecution, resetStickyTaskQueue, resetWorkflowExecution, scanWorkflowExecutions, setWorkerDeploymentManager, startActivityExecution, startBatchOperation, startNexusOperationExecution, stopBatchOperation, terminateActivityExecution, terminateNexusOperationExecution, triggerWorkflowRule, unpauseActivity, unpauseActivityExecution, unpauseWorkflowExecution, updateActivityExecutionOptions, updateActivityOptions, updateNamespace, updateSchedule, updateTaskQueueConfig, updateWorkerBuildIdCompatibility, updateWorkerConfig, updateWorkerDeploymentVersionComputeConfig, updateWorkerVersioningRules, updateWorkflowExecutionOptions, validateWorkerDeploymentVersionComputeConfig

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • TestWorkflowService

      @Deprecated public TestWorkflowService()
      Deprecated.
      use TestServer.createServer(boolean) instead and pass lockTimeSkipping=false to emulate the behavior of this method
      Creates an in-memory service along with client stubs for use in Java code. See also createServerOnly and createWithNoGrpcServer.

    • TestWorkflowService

      @Deprecated public TestWorkflowService(long initialTimeMillis)
      Deprecated.
      use TestServer.createServer(boolean, long) instead and pass lockTimeSkipping=false to emulate the behavior of this method
      Creates an in-memory service along with client stubs for use in Java code. See also createServerOnly and createWithNoGrpcServer.

    • TestWorkflowService

      @Deprecated public TestWorkflowService(boolean lockTimeSkipping)
      Deprecated.
      use TestServer.createServer(boolean) instead
      Creates an in-memory service along with client stubs for use in Java code. See also createServerOnly and createWithNoGrpcServer.

  • Method Details

    • close

      public void close()
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface Closeable

    • startWorkflowExecution

      public void startWorkflowExecution(io.temporal.api.workflowservice.v1.StartWorkflowExecutionRequest request, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.StartWorkflowExecutionResponse> responseObserver)
      Overrides:
      startWorkflowExecution in class io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceImplBase

    • getWorkflowExecutionHistory

      public void getWorkflowExecutionHistory(io.temporal.api.workflowservice.v1.GetWorkflowExecutionHistoryRequest getRequest, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.GetWorkflowExecutionHistoryResponse> responseObserver)
      Overrides:
      getWorkflowExecutionHistory in class io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceImplBase

    • pollWorkflowTaskQueue

      public void pollWorkflowTaskQueue(io.temporal.api.workflowservice.v1.PollWorkflowTaskQueueRequest pollRequest, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.PollWorkflowTaskQueueResponse> responseObserver)
      Overrides:
      pollWorkflowTaskQueue in class io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceImplBase

    • respondWorkflowTaskCompleted

      public void respondWorkflowTaskCompleted(io.temporal.api.workflowservice.v1.RespondWorkflowTaskCompletedRequest request, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.RespondWorkflowTaskCompletedResponse> responseObserver)
      Overrides:
      respondWorkflowTaskCompleted in class io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceImplBase

    • respondWorkflowTaskFailed

      public void respondWorkflowTaskFailed(io.temporal.api.workflowservice.v1.RespondWorkflowTaskFailedRequest failedRequest, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.RespondWorkflowTaskFailedResponse> responseObserver)
      Overrides:
      respondWorkflowTaskFailed in class io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceImplBase

    • getSystemInfo

      public void getSystemInfo(io.temporal.api.workflowservice.v1.GetSystemInfoRequest request, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.GetSystemInfoResponse> responseObserver)
      Overrides:
      getSystemInfo in class io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceImplBase

    • shutdownWorker

      public void shutdownWorker(io.temporal.api.workflowservice.v1.ShutdownWorkerRequest request, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.ShutdownWorkerResponse> responseObserver)
      Overrides:
      shutdownWorker in class io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceImplBase

    • pollActivityTaskQueue

      public void pollActivityTaskQueue(io.temporal.api.workflowservice.v1.PollActivityTaskQueueRequest pollRequest, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.PollActivityTaskQueueResponse> responseObserver)
      Overrides:
      pollActivityTaskQueue in class io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceImplBase

    • recordActivityTaskHeartbeat

      public void recordActivityTaskHeartbeat(io.temporal.api.workflowservice.v1.RecordActivityTaskHeartbeatRequest heartbeatRequest, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.RecordActivityTaskHeartbeatResponse> responseObserver)
      Overrides:
      recordActivityTaskHeartbeat in class io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceImplBase

    • recordActivityTaskHeartbeatById

      public void recordActivityTaskHeartbeatById(io.temporal.api.workflowservice.v1.RecordActivityTaskHeartbeatByIdRequest heartbeatRequest, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.RecordActivityTaskHeartbeatByIdResponse> responseObserver)
      Overrides:
      recordActivityTaskHeartbeatById in class io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceImplBase

    • respondActivityTaskCompleted

      public void respondActivityTaskCompleted(io.temporal.api.workflowservice.v1.RespondActivityTaskCompletedRequest completeRequest, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.RespondActivityTaskCompletedResponse> responseObserver)
      Overrides:
      respondActivityTaskCompleted in class io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceImplBase

    • respondActivityTaskCompletedById

      public void respondActivityTaskCompletedById(io.temporal.api.workflowservice.v1.RespondActivityTaskCompletedByIdRequest completeRequest, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.RespondActivityTaskCompletedByIdResponse> responseObserver)
      Overrides:
      respondActivityTaskCompletedById in class io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceImplBase

    • respondActivityTaskFailed

      public void respondActivityTaskFailed(io.temporal.api.workflowservice.v1.RespondActivityTaskFailedRequest failRequest, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.RespondActivityTaskFailedResponse> responseObserver)
      Overrides:
      respondActivityTaskFailed in class io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceImplBase

    • respondActivityTaskFailedById

      public void respondActivityTaskFailedById(io.temporal.api.workflowservice.v1.RespondActivityTaskFailedByIdRequest failRequest, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.RespondActivityTaskFailedByIdResponse> responseObserver)
      Overrides:
      respondActivityTaskFailedById in class io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceImplBase

    • respondActivityTaskCanceled

      public void respondActivityTaskCanceled(io.temporal.api.workflowservice.v1.RespondActivityTaskCanceledRequest canceledRequest, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.RespondActivityTaskCanceledResponse> responseObserver)
      Overrides:
      respondActivityTaskCanceled in class io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceImplBase

    • respondActivityTaskCanceledById

      public void respondActivityTaskCanceledById(io.temporal.api.workflowservice.v1.RespondActivityTaskCanceledByIdRequest canceledRequest, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.RespondActivityTaskCanceledByIdResponse> responseObserver)
      Overrides:
      respondActivityTaskCanceledById in class io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceImplBase

    • pollNexusTaskQueue

      public void pollNexusTaskQueue(io.temporal.api.workflowservice.v1.PollNexusTaskQueueRequest request, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.PollNexusTaskQueueResponse> responseObserver)
      Overrides:
      pollNexusTaskQueue in class io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceImplBase

    • respondNexusTaskCompleted

      public void respondNexusTaskCompleted(io.temporal.api.workflowservice.v1.RespondNexusTaskCompletedRequest request, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.RespondNexusTaskCompletedResponse> responseObserver)
      Overrides:
      respondNexusTaskCompleted in class io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceImplBase

    • respondNexusTaskFailed

      public void respondNexusTaskFailed(io.temporal.api.workflowservice.v1.RespondNexusTaskFailedRequest request, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.RespondNexusTaskFailedResponse> responseObserver)
      Overrides:
      respondNexusTaskFailed in class io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceImplBase

    • completeNexusOperation

      public void completeNexusOperation(NexusOperationRef ref, String operationID, io.temporal.api.nexus.v1.Link startLink, io.temporal.api.history.v1.HistoryEvent completionEvent)

    • requestCancelWorkflowExecution

      public void requestCancelWorkflowExecution(io.temporal.api.workflowservice.v1.RequestCancelWorkflowExecutionRequest cancelRequest, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.RequestCancelWorkflowExecutionResponse> responseObserver)
      Overrides:
      requestCancelWorkflowExecution in class io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceImplBase

    • terminateWorkflowExecution

      public void terminateWorkflowExecution(io.temporal.api.workflowservice.v1.TerminateWorkflowExecutionRequest request, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.TerminateWorkflowExecutionResponse> responseObserver)
      Overrides:
      terminateWorkflowExecution in class io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceImplBase

    • signalWorkflowExecution

      public void signalWorkflowExecution(io.temporal.api.workflowservice.v1.SignalWorkflowExecutionRequest signalRequest, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.SignalWorkflowExecutionResponse> responseObserver)
      Overrides:
      signalWorkflowExecution in class io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceImplBase

    • updateWorkflowExecution

      public void updateWorkflowExecution(io.temporal.api.workflowservice.v1.UpdateWorkflowExecutionRequest request, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.UpdateWorkflowExecutionResponse> responseObserver)
      Overrides:
      updateWorkflowExecution in class io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceImplBase

    • pollWorkflowExecutionUpdate

      public void pollWorkflowExecutionUpdate(io.temporal.api.workflowservice.v1.PollWorkflowExecutionUpdateRequest request, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.PollWorkflowExecutionUpdateResponse> responseObserver)
      Overrides:
      pollWorkflowExecutionUpdate in class io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceImplBase

    • executeMultiOperation

      public void executeMultiOperation(io.temporal.api.workflowservice.v1.ExecuteMultiOperationRequest request, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.ExecuteMultiOperationResponse> responseObserver)
      Overrides:
      executeMultiOperation in class io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceImplBase

    • signalWithStartWorkflowExecution

      public void signalWithStartWorkflowExecution(io.temporal.api.workflowservice.v1.SignalWithStartWorkflowExecutionRequest r, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.SignalWithStartWorkflowExecutionResponse> responseObserver)
      Overrides:
      signalWithStartWorkflowExecution in class io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceImplBase

    • signalExternalWorkflowExecution

      public void signalExternalWorkflowExecution(String signalId, io.temporal.api.command.v1.SignalExternalWorkflowExecutionCommandAttributes commandAttributes, io.temporal.internal.testservice.TestWorkflowMutableState source)

    • continueAsNew

      public String continueAsNew(io.temporal.api.workflowservice.v1.StartWorkflowExecutionRequest previousRunStartRequest, io.temporal.api.command.v1.ContinueAsNewWorkflowExecutionCommandAttributes ca, io.temporal.api.history.v1.WorkflowExecutionContinuedAsNewEventAttributes ea, Optional<io.temporal.internal.testservice.TestServiceRetryState> retryState, String identity, ExecutionId continuedExecutionId, String firstExecutionRunId, io.temporal.internal.testservice.TestWorkflowMutableState previousExecutionState, Optional<io.temporal.internal.testservice.TestWorkflowMutableState> parent, OptionalLong parentChildInitiatedEventId)
      Creates next run of a workflow execution
      Returns:
      RunId

    • listOpenWorkflowExecutions

      public void listOpenWorkflowExecutions(io.temporal.api.workflowservice.v1.ListOpenWorkflowExecutionsRequest listRequest, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.ListOpenWorkflowExecutionsResponse> responseObserver)
      Overrides:
      listOpenWorkflowExecutions in class io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceImplBase

    • listClosedWorkflowExecutions

      public void listClosedWorkflowExecutions(io.temporal.api.workflowservice.v1.ListClosedWorkflowExecutionsRequest listRequest, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.ListClosedWorkflowExecutionsResponse> responseObserver)
      Overrides:
      listClosedWorkflowExecutions in class io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceImplBase

    • respondQueryTaskCompleted

      public void respondQueryTaskCompleted(io.temporal.api.workflowservice.v1.RespondQueryTaskCompletedRequest completeRequest, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.RespondQueryTaskCompletedResponse> responseObserver)
      Overrides:
      respondQueryTaskCompleted in class io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceImplBase

    • queryWorkflow

      public void queryWorkflow(io.temporal.api.workflowservice.v1.QueryWorkflowRequest queryRequest, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.QueryWorkflowResponse> responseObserver)
      Overrides:
      queryWorkflow in class io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceImplBase

    • describeWorkflowExecution

      public void describeWorkflowExecution(io.temporal.api.workflowservice.v1.DescribeWorkflowExecutionRequest request, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.DescribeWorkflowExecutionResponse> responseObserver)
      Overrides:
      describeWorkflowExecution in class io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceImplBase

    • describeNamespace

      public void describeNamespace(io.temporal.api.workflowservice.v1.DescribeNamespaceRequest request, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.DescribeNamespaceResponse> responseObserver)
      This method doesn't make much sense for test server, it accepts all namespaces as existent and registered. so, it's a trivial implementation just returning an info that a namespace is registered irrespectively of the input
      Overrides:
      describeNamespace in class io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceImplBase

    • describeDeployment

      public void describeDeployment(io.temporal.api.workflowservice.v1.DescribeDeploymentRequest request, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.DescribeDeploymentResponse> responseObserver)
      Overrides:
      describeDeployment in class io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceImplBase

    • describeWorkerDeploymentVersion

      public void describeWorkerDeploymentVersion(io.temporal.api.workflowservice.v1.DescribeWorkerDeploymentVersionRequest request, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.DescribeWorkerDeploymentVersionResponse> responseObserver)
      Overrides:
      describeWorkerDeploymentVersion in class io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceImplBase

    • describeWorkerDeployment

      public void describeWorkerDeployment(io.temporal.api.workflowservice.v1.DescribeWorkerDeploymentRequest request, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.DescribeWorkerDeploymentResponse> responseObserver)
      Overrides:
      describeWorkerDeployment in class io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceImplBase

    • deleteWorkerDeployment

      public void deleteWorkerDeployment(io.temporal.api.workflowservice.v1.DeleteWorkerDeploymentRequest request, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.DeleteWorkerDeploymentResponse> responseObserver)
      Overrides:
      deleteWorkerDeployment in class io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceImplBase

    • deleteWorkerDeploymentVersion

      public void deleteWorkerDeploymentVersion(io.temporal.api.workflowservice.v1.DeleteWorkerDeploymentVersionRequest request, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.DeleteWorkerDeploymentVersionResponse> responseObserver)
      Overrides:
      deleteWorkerDeploymentVersion in class io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceImplBase

    • setWorkerDeploymentCurrentVersion

      public void setWorkerDeploymentCurrentVersion(io.temporal.api.workflowservice.v1.SetWorkerDeploymentCurrentVersionRequest request, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.SetWorkerDeploymentCurrentVersionResponse> responseObserver)
      Overrides:
      setWorkerDeploymentCurrentVersion in class io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceImplBase

    • setCurrentDeployment

      public void setCurrentDeployment(io.temporal.api.workflowservice.v1.SetCurrentDeploymentRequest request, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.SetCurrentDeploymentResponse> responseObserver)
      Overrides:
      setCurrentDeployment in class io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceImplBase

    • getCurrentDeployment

      public void getCurrentDeployment(io.temporal.api.workflowservice.v1.GetCurrentDeploymentRequest request, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.GetCurrentDeploymentResponse> responseObserver)
      Overrides:
      getCurrentDeployment in class io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceImplBase

    • listDeployments

      public void listDeployments(io.temporal.api.workflowservice.v1.ListDeploymentsRequest request, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.ListDeploymentsResponse> responseObserver)
      Overrides:
      listDeployments in class io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceImplBase

    • getDeploymentReachability

      public void getDeploymentReachability(io.temporal.api.workflowservice.v1.GetDeploymentReachabilityRequest request, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.GetDeploymentReachabilityResponse> responseObserver)
      Overrides:
      getDeploymentReachability in class io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceImplBase

    • setWorkerDeploymentRampingVersion

      public void setWorkerDeploymentRampingVersion(io.temporal.api.workflowservice.v1.SetWorkerDeploymentRampingVersionRequest request, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.SetWorkerDeploymentRampingVersionResponse> responseObserver)
      Overrides:
      setWorkerDeploymentRampingVersion in class io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceImplBase

    • listWorkerDeployments

      public void listWorkerDeployments(io.temporal.api.workflowservice.v1.ListWorkerDeploymentsRequest request, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.ListWorkerDeploymentsResponse> responseObserver)
      Overrides:
      listWorkerDeployments in class io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceImplBase

    • updateWorkerDeploymentVersionMetadata

      public void updateWorkerDeploymentVersionMetadata(io.temporal.api.workflowservice.v1.UpdateWorkerDeploymentVersionMetadataRequest request, io.grpc.stub.StreamObserver<io.temporal.api.workflowservice.v1.UpdateWorkerDeploymentVersionMetadataResponse> responseObserver)
      Overrides:
      updateWorkerDeploymentVersionMetadata in class io.temporal.api.workflowservice.v1.WorkflowServiceGrpc.WorkflowServiceImplBase

    • getDiagnostics

      public void getDiagnostics(StringBuilder result)
      Adds diagnostic data about internal service state to the provided StringBuilder. Includes histories of all workflow instances stored in the service.

    • currentTimeMillis

      @Deprecated public long currentTimeMillis()
      Deprecated.
      use TestServiceStubs and TestServiceGrpc.TestServiceBlockingStub.getCurrentTime(Empty)

    • registerDelayedCallback

      public void registerDelayedCallback(Duration delay, Runnable r)
      Invokes callback after the specified delay according to internal service clock.

    • lockTimeSkipping

      @Deprecated public void lockTimeSkipping(String caller)
      Deprecated.
      use TestServiceStubs and TestServiceGrpc.TestServiceBlockingStub.lockTimeSkipping(LockTimeSkippingRequest)
      Disables time skipping. To re-enable call unlockTimeSkipping(String). These calls are counted, so calling unlock does not guarantee that time is going to be skipped immediately as another lock can be holding it.

    • unlockTimeSkipping

      @Deprecated public void unlockTimeSkipping(String caller)
      Deprecated.
      use TestServiceStubs and TestServiceGrpc.TestServiceBlockingStub.unlockTimeSkipping(UnlockTimeSkippingRequest)

    • sleep

      @Deprecated public void sleep(Duration duration)
      Deprecated.
      use TestServiceStubs and TestServiceGrpc.TestServiceBlockingStub.unlockTimeSkippingWithSleep(SleepRequest)
      Unlocks time skipping and blocks the calling thread until internal clock passes the current + duration time.
      When the time is reached, locks time skipping and returns.
      Might not block at all due to time skipping. Or might block if the time skipping lock counter was more than 1.

    • createWithNoGrpcServer

      @Deprecated public static TestWorkflowService createWithNoGrpcServer()
      Deprecated.
      use TestServicesStarter to create just the services with gRPC server
      Creates an instance of TestWorkflowService that does not manage its own gRPC server. Useful for including in an externally managed gRPC server.

    • createServerOnly

      @Deprecated public static TestWorkflowService createServerOnly(int port)
      Deprecated.
      use TestServer.createPortBoundServer(int, boolean) instead and pass lockTimeSkipping=false to emulate the behavior of this method
      Creates an out-of-process rather than in-process server, and does not set up a client. Useful, for example, if you want to use the test service from other SDKs.
      Parameters:
      port - the port to listen on

    • newClientStub

      @Deprecated public io.temporal.serviceclient.WorkflowServiceStubs newClientStub()
      Deprecated.