Package com.adobe.acs.commons.workflow.bulk.execution.impl.runners

Class AEMWorkflowRunnerImpl

java.lang.Object

com.adobe.acs.commons.workflow.bulk.execution.impl.runners.AbstractWorkflowRunner

com.adobe.acs.commons.workflow.bulk.execution.impl.runners.AbstractAEMWorkflowRunner

com.adobe.acs.commons.workflow.bulk.execution.impl.runners.AEMWorkflowRunnerImpl

All Implemented Interfaces:

BulkWorkflowRunner

@Service
public class AEMWorkflowRunnerImpl
extends AbstractAEMWorkflowRunner
implements BulkWorkflowRunner

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	AEMWorkflowRunnerImpl.AEMWorkflowRunnable	Runner's Runnable

Field Summary

Fields inherited from class com.adobe.acs.commons.workflow.bulk.execution.impl.runners.AbstractWorkflowRunner

AUTH_INFO, SERVICE_NAME

Constructor Summary

Constructors

Constructor	Description
AEMWorkflowRunnerImpl()

Method Summary

Modifier and Type	Method	Description
void	complete(Workspace workspace, Payload payload)	Marks a payload as being completed.
void	forceTerminate(Workspace workspace, Payload payload)	Marks a payload being force terminated.
org.apache.sling.commons.scheduler.ScheduleOptions	getOptions(Config config)	If a non-null value is returned, the result of run(..) will be scheduled to run w these options.
Runnable	getRunnable(Config config)

Methods inherited from class com.adobe.acs.commons.workflow.bulk.execution.impl.runners.AbstractAEMWorkflowRunner

cleanupActivePayloadGroups, onboardNextPayload, onboardNextPayloadGroup, unscheduleJob

Methods inherited from class com.adobe.acs.commons.workflow.bulk.execution.impl.runners.AbstractWorkflowRunner

complete, fail, initialize, initialize, run, start, stop, stop, stopping, stopWithError

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.adobe.acs.commons.workflow.bulk.execution.BulkWorkflowRunner

complete, initialize, initialize, run, start, stop, stop, stopping, stopWithError

Constructor Detail

AEMWorkflowRunnerImpl

public AEMWorkflowRunnerImpl()

Method Detail

getRunnable

public Runnable getRunnable(Config config)

Specified by:

getRunnable in interface BulkWorkflowRunner

Parameters:

config - the Config

Returns:

the runnable object that will be used to perform the work.

getOptions

public org.apache.sling.commons.scheduler.ScheduleOptions getOptions(Config config)

Description copied from interface: BulkWorkflowRunner

If a non-null value is returned, the result of run(..) will be scheduled to run w these options. If null the job will be immediately run in the same thread.

Specified by:

getOptions in interface BulkWorkflowRunner

Parameters:

config - the Config

Returns:

The Sling Scheduler options or null;

complete

public void complete(Workspace workspace,
                     Payload payload)
              throws Exception

Description copied from interface: BulkWorkflowRunner

Marks a payload as being completed.

Specified by:

complete in interface BulkWorkflowRunner

Overrides:

complete in class AbstractWorkflowRunner

Parameters:

workspace - the Workspace

payload - the completed Payload

Throws:

Exception

forceTerminate

public void forceTerminate(Workspace workspace,
                           Payload payload)
                    throws Exception

Description copied from interface: BulkWorkflowRunner

Marks a payload being force terminated.

Specified by:

forceTerminate in interface BulkWorkflowRunner

Specified by:

forceTerminate in class AbstractWorkflowRunner

Parameters:

workspace - the Workspace

payload - the completed Payload

Throws:

Exception