com.amazonaws.services.simpleworkflow.flow.junit

クラス WorkflowTestBase

java.lang.Object

com.amazonaws.services.simpleworkflow.flow.junit.WorkflowTestBase

すべての実装されたインタフェース:

org.junit.rules.MethodRule

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

GenericWorkflowTest, SpringWorkflowTest, WorkflowTest

public abstract class WorkflowTestBase
extends java.lang.Object
implements org.junit.rules.MethodRule

フィールドの概要

フィールド

修飾子とタイプ	フィールドと説明
protected DecisionContext	decisionContext
protected java.lang.String	defaultActivitiesTaskListToPoll
protected TestWorkflowClock	workflowClock
protected TestWorkflowContext	workflowContext

コンストラクタの概要

コンストラクタ

コンストラクタと説明
WorkflowTestBase(DecisionContext decisionContext)

メソッドの概要

メソッド

修飾子とタイプ	メソッドと説明
protected void	afterEvaluate()
org.junit.runners.model.Statement	apply(org.junit.runners.model.Statement base, org.junit.runners.model.FrameworkMethod method, java.lang.Object target)
protected void	beforeEvaluate(DecisionContext decisionContext)
void	clockAdvanceSeconds(long seconds)
void	clockAdvanceSeconds(long seconds, Promise<?>... waitFor)
double	getClockAcceleration()
DecisionContext	getDecisionContext()
java.lang.String	getDefaultActivitiesTaskListToPoll()
WorkflowExecution	getWorkflowExecution()
WorkflowType	getWorkflowType()
boolean	isDisableOutstandingTasksCheck()
void	setClockAccelerationCoefficient(double clockAcceleration) Accelerate workflow clock according the coefficient.
void	setClockCurrentTimeMillis(long timeMillis)
void	setDefaultActivitiesTaskListToPoll(java.lang.String defaultActivitiesTaskListToPoll)
void	setDisableOutstandingTasksCheck(boolean disableOutstandingTasksCheck) When set to true it is considered a test failure to have outstanding tasks that are blocked on non external events or timers.
void	setExpectedException(java.lang.Class<? extends java.lang.Throwable> expectedException)
void	setFlowTestRunner(boolean flowTestRunner)
void	setTestTimeoutActualTimeMilliseconds(long timeout) Test timeout time.
void	setWorkflowExecution(WorkflowExecution workflowExecution)
void	setWorkflowType(WorkflowType workflowType)
Promise<java.lang.Void>	waitBlocked(Promise<?>... waitFor) Here blocked means that there are no any tasks that are ready to be executed.

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

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

フィールドの詳細

defaultActivitiesTaskListToPoll

protected java.lang.String defaultActivitiesTaskListToPoll

decisionContext

protected DecisionContext decisionContext

workflowContext

protected TestWorkflowContext workflowContext

workflowClock

protected TestWorkflowClock workflowClock

コンストラクタの詳細

WorkflowTestBase

public WorkflowTestBase(DecisionContext decisionContext)

メソッドの詳細

isDisableOutstandingTasksCheck

public boolean isDisableOutstandingTasksCheck()

setDisableOutstandingTasksCheck

public void setDisableOutstandingTasksCheck(boolean disableOutstandingTasksCheck)

When set to true it is considered a test failure to have outstanding tasks that are blocked on non external events or timers. Such blockage is usually indicates a bug that can lead to a workflow "getting stuck". Default is true.

getDecisionContext

public DecisionContext getDecisionContext()

setWorkflowExecution

public void setWorkflowExecution(WorkflowExecution workflowExecution)

setWorkflowType

public void setWorkflowType(WorkflowType workflowType)

getWorkflowExecution

public WorkflowExecution getWorkflowExecution()

getWorkflowType

public WorkflowType getWorkflowType()

getDefaultActivitiesTaskListToPoll

public java.lang.String getDefaultActivitiesTaskListToPoll()

setDefaultActivitiesTaskListToPoll

public void setDefaultActivitiesTaskListToPoll(java.lang.String defaultActivitiesTaskListToPoll)

getClockAcceleration

public double getClockAcceleration()

setClockAccelerationCoefficient

public void setClockAccelerationCoefficient(double clockAcceleration)

Accelerate workflow clock according the coefficient. Note that the clock acceleration affects time returned by WorkflowClock and timers firing only. The default is 1.0 (no acceleration).

パラメータ:

clockAcceleration - value that is larger then 1.0

apply

public org.junit.runners.model.Statement apply(org.junit.runners.model.Statement base,
                                      org.junit.runners.model.FrameworkMethod method,
                                      java.lang.Object target)

定義:

apply インタフェース内 org.junit.rules.MethodRule

waitBlocked

public Promise<java.lang.Void> waitBlocked(Promise<?>... waitFor)

Here blocked means that there are no any tasks that are ready to be executed. Usually these tasks wait for timers or some other external events.

戻り値:

Promise that becomes ready when there are not tasks to execute

setClockCurrentTimeMillis

public void setClockCurrentTimeMillis(long timeMillis)

clockAdvanceSeconds

public void clockAdvanceSeconds(long seconds)

clockAdvanceSeconds

public void clockAdvanceSeconds(long seconds,
                       Promise<?>... waitFor)

beforeEvaluate

protected void beforeEvaluate(DecisionContext decisionContext)

afterEvaluate

protected void afterEvaluate()

setTestTimeoutActualTimeMilliseconds

public void setTestTimeoutActualTimeMilliseconds(long timeout)

Test timeout time. Uses real clock that ignores acceleration (see setClockAccelerationCoefficient(double)). Instead of calling this method consider using FlowBlockJUnit4ClassRunner or FlowSpringJUnit4ClassRunner and timeout parameter of @Test annotation.

パラメータ:

timeout - time in milliseconds.

setExpectedException

public void setExpectedException(java.lang.Class<? extends java.lang.Throwable> expectedException)

setFlowTestRunner

public void setFlowTestRunner(boolean flowTestRunner)