Package org.chenile.owiz.impl

Class ParallelChain<InputType>

java.lang.Object

org.chenile.owiz.impl.CommandBase<InputType>

org.chenile.owiz.impl.Chain<InputType>

org.chenile.owiz.impl.ParallelChain<InputType>

Type Parameters:

InputType -
Extends normal chain functionality and handles parallel processing. Individual commands are assumed to be thread safe i.e. they mutate context (the InputType) in different threads in a concurrent way. It is also assumed that the context is WarningAware so that all the errors are captured as warnings. Exception processing:

1. Commands are expected to throw ErrorNumException in case of errors. These errors are logged in the context as warnings
2. Framework throws ErrorNumException (error code 903). This error will not be logged as a warning (because the sub command has already been logged and this will be redundant)

All Implemented Interfaces:

AttachableCommand<InputType>, BypassableCommand<InputType>, Command<InputType>, OrchestrationAware<InputType>

public class ParallelChain<InputType>
extends Chain<InputType>

Author:

Raja Shankar Kolluru

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	ParallelChain.ChainExecutor<InputType>

Field Summary

Fields

Modifier and Type	Field	Description
private ExecutorService	executorService
private long	timeoutInMillis

Fields inherited from class org.chenile.owiz.impl.Chain

commandDescSet, currentIndex, INDEX

Fields inherited from class org.chenile.owiz.impl.CommandBase

commandDescriptor, orchConfigurator

Constructor Summary

Constructors

Constructor	Description
ParallelChain()
ParallelChain(ExecutorService service, int timeoutInMillis)

Method Summary

Modifier and Type	Method	Description
protected boolean	commandCanBeBypassed(Command<InputType> cmd, InputType context)
protected void	doExecute(InputType context)
protected ErrorNumException	generateOverallException(String message)
protected void	handleErrors(InputType context, Throwable cause)
protected ResponseMessage	handleNonErrorNumExceptions(InputType context, Throwable cause)
void	setExecutorService(ExecutorService service)
void	setTimeoutInMillis(long timeoutInMillis)

Methods inherited from class org.chenile.owiz.impl.Chain

attachCommand, obtainExecutionCommands, shouldStopChain

Methods inherited from class org.chenile.owiz.impl.CommandBase

bypass, execute, getConfigValue, getId, getParentId, obtainCommand, postprocess, preprocess, setCommandDescriptor, setOrchConfigurator

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.chenile.owiz.Command

execute

Field Details

executorService

private ExecutorService executorService

timeoutInMillis

private long timeoutInMillis

Constructor Details

ParallelChain

public ParallelChain()

ParallelChain

public ParallelChain(ExecutorService service,
 int timeoutInMillis)

Method Details

setTimeoutInMillis

public void setTimeoutInMillis(long timeoutInMillis)

setExecutorService

public void setExecutorService(ExecutorService service)

doExecute

protected void doExecute(InputType context)
                  throws Exception

Overrides:

doExecute in class Chain<InputType>

Throws:

Exception

commandCanBeBypassed

protected boolean commandCanBeBypassed(Command<InputType> cmd,
 InputType context)

generateOverallException

protected ErrorNumException generateOverallException(String message)

handleErrors

protected void handleErrors(InputType context,
 Throwable cause)

handleNonErrorNumExceptions

protected ResponseMessage handleNonErrorNumExceptions(InputType context,
 Throwable cause)