com.amazonaws.services.simpleworkflow.flow.worker

クラス DecisionTaskHandler

java.lang.Object

com.amazonaws.services.simpleworkflow.flow.worker.DecisionTaskHandler

直系の既知のサブクラス:

AsyncDecisionTaskHandler

public abstract class DecisionTaskHandler
extends java.lang.Object

Base class for workflow task handlers. Extend this class to implement custom deciders that can be executed using a WorkflowTaskPollingExecutorService.

作成者:

fateev, suskin

関連項目:

WorkflowTaskPollingExecutorService

コンストラクタの概要

コンストラクタ

コンストラクタと説明
DecisionTaskHandler()

メソッドの概要

メソッド

修飾子とタイプ	メソッドと説明
abstract java.util.List<AsyncTaskInfo>	getAsynchronousThreadDump(java.util.Iterator<DecisionTask> decisionTaskIterator)
abstract java.lang.String	getAsynchronousThreadDumpAsString(java.util.Iterator<DecisionTask> decisionTaskIterator)
abstract RespondDecisionTaskCompletedRequest	handleDecisionTask(java.util.Iterator<DecisionTask> decisionTaskIterator) The implementation should be called when a polling SWF Decider receives a new WorkflowTask.
abstract java.lang.Object	loadWorkflowThroughReplay(java.util.Iterator<DecisionTask> decisionTaskIterator)

クラスから継承されたメソッド java.lang.Object

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

コンストラクタの詳細

DecisionTaskHandler

public DecisionTaskHandler()

メソッドの詳細

handleDecisionTask

public abstract RespondDecisionTaskCompletedRequest handleDecisionTask(java.util.Iterator<DecisionTask> decisionTaskIterator)
                                                                throws java.lang.Exception

The implementation should be called when a polling SWF Decider receives a new WorkflowTask. Later, that decider should call one of #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().

例外:

java.lang.Exception

getAsynchronousThreadDump

public abstract java.util.List<AsyncTaskInfo> getAsynchronousThreadDump(java.util.Iterator<DecisionTask> decisionTaskIterator)
                                                                 throws java.lang.Exception

例外:

java.lang.Exception

getAsynchronousThreadDumpAsString

public abstract java.lang.String getAsynchronousThreadDumpAsString(java.util.Iterator<DecisionTask> decisionTaskIterator)
                                                            throws java.lang.Exception

例外:

java.lang.Exception

loadWorkflowThroughReplay

public abstract java.lang.Object loadWorkflowThroughReplay(java.util.Iterator<DecisionTask> decisionTaskIterator)
                                                    throws java.lang.Exception

例外:

java.lang.Exception