public abstract class DecisionTaskHandler extends Object
WorkflowTaskPollingExecutorService.WorkflowTaskPollingExecutorService| Constructor and Description |
|---|
DecisionTaskHandler() |
| Modifier and Type | Method and Description |
|---|---|
abstract List<AsyncTaskInfo> |
getAsynchronousThreadDump(Iterator<DecisionTask> decisionTaskIterator) |
abstract String |
getAsynchronousThreadDumpAsString(Iterator<DecisionTask> decisionTaskIterator) |
abstract RespondDecisionTaskCompletedRequest |
handleDecisionTask(Iterator<DecisionTask> decisionTaskIterator)
The implementation should be called when a polling SWF Decider receives a
new WorkflowTask.
|
abstract Object |
loadWorkflowThroughReplay(Iterator<DecisionTask> decisionTaskIterator) |
public abstract RespondDecisionTaskCompletedRequest handleDecisionTask(Iterator<DecisionTask> decisionTaskIterator) throws Exception
#respondWorkflowTaskCompleted(String, Transition, AmazonSimpleWorkflow)
or
#respondWorkflowTaskFailed(String, int, String, Map, AmazonSimpleWorkflow)
.workflowTask - The decision task to handle. The reason for more then one task
being received is pagination of the history. All tasks in the
iterator contain the same information but different pages of
the history. The tasks are loaded lazily when
Iterator.next() is called. It is expected that the
method implementation aborts decision by rethrowing any
exception from Iterator.next().Exceptionpublic abstract List<AsyncTaskInfo> getAsynchronousThreadDump(Iterator<DecisionTask> decisionTaskIterator) throws Exception
Exceptionpublic abstract String getAsynchronousThreadDumpAsString(Iterator<DecisionTask> decisionTaskIterator) throws Exception
Exceptionpublic abstract Object loadWorkflowThroughReplay(Iterator<DecisionTask> decisionTaskIterator) throws Exception
ExceptionCopyright © 2013 Amazon Web Services, Inc. All Rights Reserved.