public class TestGenericWorkflowClient extends Object implements GenericWorkflowClient
Constructor and Description |
---|
TestGenericWorkflowClient() |
TestGenericWorkflowClient(WorkflowDefinitionFactoryFactory factoryFactory) |
TestGenericWorkflowClient(WorkflowDefinitionFactoryFactory factoryFactory,
DecisionContextProvider decisionContextProvider) |
Modifier and Type | Method and Description |
---|---|
void |
continueAsNewOnCompletion(ContinueAsNewWorkflowExecutionParameters parameters) |
String |
generateUniqueId()
Deterministic unique Id generator
|
DecisionContextProvider |
getDecisionContextProvider() |
WorkflowDefinitionFactoryFactory |
getFactoryFactory() |
String |
getWorkflowState(WorkflowExecution execution) |
void |
requestCancelWorkflowExecution(WorkflowExecution execution) |
void |
setDecisionContextProvider(DecisionContextProvider decisionContextProvider) |
void |
setFactoryFactory(WorkflowDefinitionFactoryFactory factoryFactory) |
Promise<Void> |
signalWorkflowExecution(SignalExternalWorkflowParameters signalParameters) |
Promise<StartChildWorkflowReply> |
startChildWorkflow(StartChildWorkflowExecutionParameters parameters)
Start child workflow.
|
Promise<String> |
startChildWorkflow(String workflow,
String version,
Promise<String> input) |
Promise<String> |
startChildWorkflow(String workflow,
String version,
String input) |
public TestGenericWorkflowClient(WorkflowDefinitionFactoryFactory factoryFactory, DecisionContextProvider decisionContextProvider)
public TestGenericWorkflowClient(WorkflowDefinitionFactoryFactory factoryFactory)
public TestGenericWorkflowClient()
public WorkflowDefinitionFactoryFactory getFactoryFactory()
public void setFactoryFactory(WorkflowDefinitionFactoryFactory factoryFactory)
public DecisionContextProvider getDecisionContextProvider()
public void setDecisionContextProvider(DecisionContextProvider decisionContextProvider)
public Promise<StartChildWorkflowReply> startChildWorkflow(StartChildWorkflowExecutionParameters parameters)
GenericWorkflowClient
startChildWorkflow
in interface GenericWorkflowClient
StartChildWorkflowReply.getResult()
becomes ready upon
child completion.public Promise<String> startChildWorkflow(String workflow, String version, String input)
startChildWorkflow
in interface GenericWorkflowClient
public Promise<String> startChildWorkflow(String workflow, String version, Promise<String> input)
startChildWorkflow
in interface GenericWorkflowClient
public Promise<Void> signalWorkflowExecution(SignalExternalWorkflowParameters signalParameters)
signalWorkflowExecution
in interface GenericWorkflowClient
public void requestCancelWorkflowExecution(WorkflowExecution execution)
requestCancelWorkflowExecution
in interface GenericWorkflowClient
public String getWorkflowState(WorkflowExecution execution) throws WorkflowException
WorkflowException
public void continueAsNewOnCompletion(ContinueAsNewWorkflowExecutionParameters parameters)
continueAsNewOnCompletion
in interface GenericWorkflowClient
public String generateUniqueId()
GenericWorkflowClient
generateUniqueId
in interface GenericWorkflowClient