Package org.chenile.owiz.impl.splitaggregate

Class SplitterAggregator

java.lang.Object

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

org.chenile.owiz.impl.splitaggregate.SplitterAggregator

All Implemented Interfaces:

AttachableCommand<SplitterContext>, BypassableCommand<SplitterContext>, Command<SplitterContext>, OrchestrationAware<SplitterContext>

public class SplitterAggregator
extends CommandBase<SplitterContext>
implements AttachableCommand<SplitterContext>

Implements a split aggregate functionality. The context must implement the SplitterContext interface.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private class	SplitterAggregator.CallableAdapter	An adapter between Command and the Callable interface mandated by the methods of java.util.concurrent.

Field Summary

Fields

Modifier and Type	Field	Description
private CommandDescriptor<?>	command
private ExecutorService	executorService
static final String	TIMEOUT_ERR
private int	timeoutInMilliSeconds

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

commandDescriptor, orchConfigurator

Constructor Summary

Constructors

Constructor	Description
SplitterAggregator(ExecutorService executorService)
SplitterAggregator(ExecutorService executorService, int timeoutInMilliSeconds)

Method Summary

Modifier and Type	Method	Description
void	attachCommand(AttachmentDescriptor<SplitterContext> attachmentDescriptor, CommandDescriptor<SplitterContext> command)
protected void	doExecute(SplitterContext splitContext)

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

command

private CommandDescriptor<?> command

executorService

private ExecutorService executorService

timeoutInMilliSeconds

private int timeoutInMilliSeconds

TIMEOUT_ERR

public static final String TIMEOUT_ERR

See Also:

• Constant Field Values

Constructor Details

SplitterAggregator

public SplitterAggregator(ExecutorService executorService)

SplitterAggregator

public SplitterAggregator(ExecutorService executorService,
 int timeoutInMilliSeconds)

Method Details

attachCommand

public void attachCommand(AttachmentDescriptor<SplitterContext> attachmentDescriptor,
 CommandDescriptor<SplitterContext> command)

Specified by:

attachCommand in interface AttachableCommand<SplitterContext>

doExecute

protected void doExecute(SplitterContext splitContext)
                  throws Exception

Specified by:

doExecute in class CommandBase<SplitterContext>

Throws:

Exception