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

Class SyntheticWorkflowRunnerImpl

java.lang.Object

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

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

All Implemented Interfaces:

BulkWorkflowRunner

@Service
public class SyntheticWorkflowRunnerImpl
extends AbstractWorkflowRunner
implements BulkWorkflowRunner

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
SyntheticWorkflowRunnerImpl()

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)
void	run(Workspace workspace, Payload payload)	Processes a payload under the Workspace.

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

complete, fail, initialize, initialize, 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, start, stop, stop, stopping, stopWithError

Constructor Detail

SyntheticWorkflowRunnerImpl

public SyntheticWorkflowRunnerImpl()

Method Detail

getRunnable

public final 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;

forceTerminate

public void forceTerminate(Workspace workspace,
                           Payload payload)
                    throws org.apache.sling.api.resource.PersistenceException

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:

org.apache.sling.api.resource.PersistenceException

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

run

public void run(Workspace workspace,
                Payload payload)

Description copied from interface: BulkWorkflowRunner

Processes a payload under the Workspace.

Specified by:

run in interface BulkWorkflowRunner

Overrides:

run in class AbstractWorkflowRunner

Parameters:

workspace - the Workspace

payload - the Payload to process