in src/main/java/com/amazonaws/services/simpleworkflow/flow/worker/AsyncDecider.java [182:344]
private void processEvent(HistoryEvent event, EventType eventType) throws Throwable {
switch (eventType) {
case ActivityTaskCanceled:
activityClient.handleActivityTaskCanceled(event);
break;
case ActivityTaskCompleted:
activityClient.handleActivityTaskCompleted(event);
break;
case ActivityTaskFailed:
activityClient.handleActivityTaskFailed(event);
break;
case ActivityTaskStarted:
activityClient.handleActivityTaskStarted(event.getActivityTaskStartedEventAttributes());
break;
case ActivityTaskTimedOut:
activityClient.handleActivityTaskTimedOut(event);
break;
case ExternalWorkflowExecutionCancelRequested:
workflowClient.handleChildWorkflowExecutionCancelRequested(event);
break;
case ChildWorkflowExecutionCanceled:
workflowClient.handleChildWorkflowExecutionCanceled(event);
break;
case ChildWorkflowExecutionCompleted:
workflowClient.handleChildWorkflowExecutionCompleted(event);
break;
case ChildWorkflowExecutionFailed:
workflowClient.handleChildWorkflowExecutionFailed(event);
break;
case ChildWorkflowExecutionStarted:
workflowClient.handleChildWorkflowExecutionStarted(event);
break;
case ChildWorkflowExecutionTerminated:
workflowClient.handleChildWorkflowExecutionTerminated(event);
break;
case ChildWorkflowExecutionTimedOut:
workflowClient.handleChildWorkflowExecutionTimedOut(event);
break;
case DecisionTaskCompleted:
handleDecisionTaskCompleted(event);
break;
case DecisionTaskScheduled:
// NOOP
break;
case DecisionTaskStarted:
handleDecisionTaskStarted(event);
break;
case DecisionTaskTimedOut:
// Handled in the processEvent(event)
break;
case ExternalWorkflowExecutionSignaled:
workflowClient.handleExternalWorkflowExecutionSignaled(event);
break;
case ScheduleActivityTaskFailed:
activityClient.handleScheduleActivityTaskFailed(event);
break;
case SignalExternalWorkflowExecutionFailed:
workflowClient.handleSignalExternalWorkflowExecutionFailed(event);
break;
case StartChildWorkflowExecutionFailed:
workflowClient.handleStartChildWorkflowExecutionFailed(event);
break;
case StartTimerFailed:
handleStartTimerFailed(event);
break;
case TimerFired:
handleTimerFired(event);
break;
case WorkflowExecutionCancelRequested:
handleWorkflowExecutionCancelRequested(event);
break;
case WorkflowExecutionSignaled:
handleWorkflowExecutionSignaled(event);
break;
case WorkflowExecutionStarted:
handleWorkflowExecutionStarted(event);
break;
case WorkflowExecutionTerminated:
// NOOP
break;
case WorkflowExecutionTimedOut:
// NOOP
break;
case ActivityTaskScheduled:
decisionsHelper.handleActivityTaskScheduled(event);
break;
case ActivityTaskCancelRequested:
decisionsHelper.handleActivityTaskCancelRequested(event);
break;
case RequestCancelActivityTaskFailed:
decisionsHelper.handleRequestCancelActivityTaskFailed(event);
break;
case MarkerRecorded:
break;
case RecordMarkerFailed:
break;
case WorkflowExecutionCompleted:
break;
case CompleteWorkflowExecutionFailed:
unhandledDecision = true;
decisionsHelper.handleCompleteWorkflowExecutionFailed(event);
break;
case WorkflowExecutionFailed:
break;
case FailWorkflowExecutionFailed:
unhandledDecision = true;
decisionsHelper.handleFailWorkflowExecutionFailed(event);
break;
case WorkflowExecutionCanceled:
break;
case CancelWorkflowExecutionFailed:
unhandledDecision = true;
decisionsHelper.handleCancelWorkflowExecutionFailed(event);
break;
case WorkflowExecutionContinuedAsNew:
break;
case ContinueAsNewWorkflowExecutionFailed:
unhandledDecision = true;
decisionsHelper.handleContinueAsNewWorkflowExecutionFailed(event);
break;
case TimerStarted:
handleTimerStarted(event);
break;
case TimerCanceled:
workflowClock.handleTimerCanceled(event);
break;
case LambdaFunctionScheduled:
decisionsHelper.handleLambdaFunctionScheduled(event);
break;
case LambdaFunctionStarted:
lambdaFunctionClient.handleLambdaFunctionStarted(event.getLambdaFunctionStartedEventAttributes());
break;
case LambdaFunctionCompleted:
lambdaFunctionClient.handleLambdaFunctionCompleted(event);
break;
case LambdaFunctionFailed:
lambdaFunctionClient.handleLambdaFunctionFailed(event);
break;
case LambdaFunctionTimedOut:
lambdaFunctionClient.handleLambdaFunctionTimedOut(event);
break;
case StartLambdaFunctionFailed:
lambdaFunctionClient.handleStartLambdaFunctionFailed(event);
break;
case ScheduleLambdaFunctionFailed:
lambdaFunctionClient.handleScheduleLambdaFunctionFailed(event);
break;
case SignalExternalWorkflowExecutionInitiated:
decisionsHelper.handleSignalExternalWorkflowExecutionInitiated(event);
break;
case RequestCancelExternalWorkflowExecutionInitiated:
decisionsHelper.handleRequestCancelExternalWorkflowExecutionInitiated(event);
break;
case RequestCancelExternalWorkflowExecutionFailed:
decisionsHelper.handleRequestCancelExternalWorkflowExecutionFailed(event);
break;
case StartChildWorkflowExecutionInitiated:
decisionsHelper.handleStartChildWorkflowExecutionInitiated(event);
break;
case CancelTimerFailed:
decisionsHelper.handleCancelTimerFailed(event);
}
}