Class TestServiceUtils

java.lang.Object

io.temporal.testing.internal.TestServiceUtils

public class TestServiceUtils
extends Object

Method Summary

Modifier and Type	Method	Description
static io.temporal.worker.WorkflowImplementationOptions	applyNexusServiceOptions(io.temporal.worker.WorkflowImplementationOptions options, Object[] nexusServiceImplementations, String endpoint)
static io.temporal.api.workflowservice.v1.PollWorkflowTaskQueueResponse	pollWorkflowTaskQueue(String namespace, io.temporal.api.taskqueue.v1.TaskQueue taskqueue, io.temporal.serviceclient.WorkflowServiceStubs service)
static void	respondWorkflowTaskCompletedWithSticky(com.google.protobuf.ByteString taskToken, io.temporal.api.taskqueue.v1.TaskQueue stickyTaskQueue, io.temporal.serviceclient.WorkflowServiceStubs service)
static void	respondWorkflowTaskCompletedWithSticky(com.google.protobuf.ByteString taskToken, io.temporal.api.taskqueue.v1.TaskQueue stickyTaskQueue, Duration startToCloseTimeout, io.temporal.serviceclient.WorkflowServiceStubs service)
static void	respondWorkflowTaskFailedWithSticky(com.google.protobuf.ByteString taskToken, io.temporal.serviceclient.WorkflowServiceStubs service)
static void	signalWorkflow(io.temporal.api.common.v1.WorkflowExecution workflowExecution, String namespace, io.temporal.serviceclient.WorkflowServiceStubs service)
static void	startWorkflowExecution(String namespace, String taskqueueName, String workflowType, io.temporal.serviceclient.WorkflowServiceStubs service)
static void	startWorkflowExecution(String namespace, String taskqueueName, String workflowType, Duration workflowRunTimeout, Duration workflowTaskTimeout, io.temporal.serviceclient.WorkflowServiceStubs service)

Methods inherited from class java.lang.Object

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

Method Details

applyNexusServiceOptions

public static io.temporal.worker.WorkflowImplementationOptions applyNexusServiceOptions(io.temporal.worker.WorkflowImplementationOptions options,
 Object[] nexusServiceImplementations,
 String endpoint)

startWorkflowExecution

public static void startWorkflowExecution(String namespace,
 String taskqueueName,
 String workflowType,
 io.temporal.serviceclient.WorkflowServiceStubs service)
                                   throws Exception

Throws:

Exception

startWorkflowExecution

public static void startWorkflowExecution(String namespace,
 String taskqueueName,
 String workflowType,
 Duration workflowRunTimeout,
 Duration workflowTaskTimeout,
 io.temporal.serviceclient.WorkflowServiceStubs service)
                                   throws Exception

Throws:

Exception

respondWorkflowTaskCompletedWithSticky

public static void respondWorkflowTaskCompletedWithSticky(com.google.protobuf.ByteString taskToken,
 io.temporal.api.taskqueue.v1.TaskQueue stickyTaskQueue,
 io.temporal.serviceclient.WorkflowServiceStubs service)
                                                   throws Exception

Throws:

Exception

respondWorkflowTaskCompletedWithSticky

public static void respondWorkflowTaskCompletedWithSticky(com.google.protobuf.ByteString taskToken,
 io.temporal.api.taskqueue.v1.TaskQueue stickyTaskQueue,
 Duration startToCloseTimeout,
 io.temporal.serviceclient.WorkflowServiceStubs service)
                                                   throws Exception

Throws:

Exception

respondWorkflowTaskFailedWithSticky

public static void respondWorkflowTaskFailedWithSticky(com.google.protobuf.ByteString taskToken,
 io.temporal.serviceclient.WorkflowServiceStubs service)
                                                throws Exception

Throws:

Exception

pollWorkflowTaskQueue

public static io.temporal.api.workflowservice.v1.PollWorkflowTaskQueueResponse pollWorkflowTaskQueue(String namespace,
 io.temporal.api.taskqueue.v1.TaskQueue taskqueue,
 io.temporal.serviceclient.WorkflowServiceStubs service)
                                                                                              throws Exception

Throws:

Exception

signalWorkflow

public static void signalWorkflow(io.temporal.api.common.v1.WorkflowExecution workflowExecution,
 String namespace,
 io.temporal.serviceclient.WorkflowServiceStubs service)
                           throws Exception

Throws:

Exception