public class AsyncDecisionTaskHandler extends DecisionTaskHandler
Constructor and Description |
---|
AsyncDecisionTaskHandler(WorkflowDefinitionFactoryFactory definitionFactoryFactory) |
Modifier and Type | Method and Description |
---|---|
List<AsyncTaskInfo> |
getAsynchronousThreadDump(Iterator<DecisionTask> decisionTaskIterator) |
String |
getAsynchronousThreadDumpAsString(Iterator<DecisionTask> decisionTaskIterator) |
RespondDecisionTaskCompletedRequest |
handleDecisionTask(Iterator<DecisionTask> decisionTaskIterator)
The implementation should be called when a polling SWF Decider receives a
new WorkflowTask.
|
WorkflowDefinition |
loadWorkflowThroughReplay(Iterator<DecisionTask> decisionTaskIterator) |
public AsyncDecisionTaskHandler(WorkflowDefinitionFactoryFactory definitionFactoryFactory)
public RespondDecisionTaskCompletedRequest handleDecisionTask(Iterator<DecisionTask> decisionTaskIterator) throws Exception
DecisionTaskHandler
#respondWorkflowTaskCompleted(String, Transition, AmazonSimpleWorkflow)
or
#respondWorkflowTaskFailed(String, int, String, Map, AmazonSimpleWorkflow)
.handleDecisionTask
in class DecisionTaskHandler
Exception
public WorkflowDefinition loadWorkflowThroughReplay(Iterator<DecisionTask> decisionTaskIterator) throws Exception
loadWorkflowThroughReplay
in class DecisionTaskHandler
Exception
public List<AsyncTaskInfo> getAsynchronousThreadDump(Iterator<DecisionTask> decisionTaskIterator) throws Exception
getAsynchronousThreadDump
in class DecisionTaskHandler
Exception
public String getAsynchronousThreadDumpAsString(Iterator<DecisionTask> decisionTaskIterator) throws Exception
getAsynchronousThreadDumpAsString
in class DecisionTaskHandler
Exception