com.marklogic.hub.flow.impl

Class FlowRunnerImpl

java.lang.Object

com.marklogic.hub.flow.impl.FlowRunnerImpl

All Implemented Interfaces:

FlowRunner

@Component
public class FlowRunnerImpl
extends java.lang.Object
implements FlowRunner

Field Summary

Fields

Modifier and Type	Field and Description
protected org.slf4j.Logger	logger

Constructor Summary

Constructors

Constructor and Description
FlowRunnerImpl()

Method Summary

Modifier and Type	Method and Description
void	awaitCompletion() Blocks until the flow execution is complete.
void	awaitCompletion(long timeout, java.util.concurrent.TimeUnit unit) Blocks until the flow execution is complete.
RunFlowResponse	getJobResponseById(java.lang.String jobId)
java.util.List<java.lang.String>	getQueuedJobIdsFromFlow(java.lang.String flowName)
Flow	getRunningFlow()
java.lang.String	getRunningStepKey()
boolean	isJobRunning()
FlowRunner	onStatusChanged(FlowStatusListener listener) Sets the status change listener on the flowrunner object
RunFlowResponse	runFlow(java.lang.String flowName) Runs the entire flow, with full defaults
RunFlowResponse	runFlow(java.lang.String flowName, java.util.List<java.lang.String> stepNums) Runs the flow, with a specific set of steps, with all defaults from step
RunFlowResponse	runFlow(java.lang.String flowName, java.util.List<java.lang.String> stepNums, java.lang.String jobId) Runs the flow, with a specific set of steps, with all custom settings
RunFlowResponse	runFlow(java.lang.String flowName, java.util.List<java.lang.String> stepNums, java.lang.String jobId, java.util.Map<java.lang.String,java.lang.Object> options) Runs the flow, with a specific set of steps, with all custom settings
RunFlowResponse	runFlow(java.lang.String flowName, java.util.List<java.lang.String> stepNums, java.lang.String jobId, java.util.Map<java.lang.String,java.lang.Object> options, java.util.Map<java.lang.String,java.lang.Object> stepConfig) Runs the flow, with a specific set of steps, with all custom settings
RunFlowResponse	runFlow(java.lang.String flowName, java.lang.String jobId) Runs the flow, with a specific set of steps, with all custom settings
RunFlowResponse	runFlow(java.lang.String flowName, java.lang.String jobId, java.util.Map<java.lang.String,java.lang.Object> options) Runs the flow, with a specific set of steps, with all custom settings
void	stopJob(java.lang.String jobId) Runs the flow.

Methods inherited from class java.lang.Object

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

Field Detail

logger

protected final org.slf4j.Logger logger

Constructor Detail

FlowRunnerImpl

public FlowRunnerImpl()

Method Detail

onStatusChanged

public FlowRunner onStatusChanged(FlowStatusListener listener)

Description copied from interface: FlowRunner

Sets the status change listener on the flowrunner object

Specified by:

onStatusChanged in interface FlowRunner

Parameters:

listener - - the listener for when the status changes

Returns:

the flow runner object

runFlow

public RunFlowResponse runFlow(java.lang.String flowName)

Description copied from interface: FlowRunner

Runs the entire flow, with full defaults

Specified by:

runFlow in interface FlowRunner

Parameters:

flowName - the flow to run

Returns:

a response object

runFlow

public RunFlowResponse runFlow(java.lang.String flowName,
                               java.util.List<java.lang.String> stepNums)

Description copied from interface: FlowRunner

Runs the flow, with a specific set of steps, with all defaults from step

Specified by:

runFlow in interface FlowRunner

Parameters:

flowName - the flow to run

stepNums - the steps in the flow to run

Returns:

a response object

runFlow

public RunFlowResponse runFlow(java.lang.String flowName,
                               java.lang.String jobId)

Description copied from interface: FlowRunner

Runs the flow, with a specific set of steps, with all custom settings

Specified by:

runFlow in interface FlowRunner

Parameters:

flowName - the flow to run

jobId - the jobid to be used for the flow

Returns:

a response object

runFlow

public RunFlowResponse runFlow(java.lang.String flowName,
                               java.util.List<java.lang.String> stepNums,
                               java.lang.String jobId)

Description copied from interface: FlowRunner

Runs the flow, with a specific set of steps, with all custom settings

Specified by:

runFlow in interface FlowRunner

Parameters:

flowName - the flow to run

stepNums - the steps in the flow to run

jobId - the jobid to be used for the flow

Returns:

a response object

runFlow

public RunFlowResponse runFlow(java.lang.String flowName,
                               java.lang.String jobId,
                               java.util.Map<java.lang.String,java.lang.Object> options)

Description copied from interface: FlowRunner

Runs the flow, with a specific set of steps, with all custom settings

Specified by:

runFlow in interface FlowRunner

Parameters:

flowName - the flow to run

jobId - the jobid to be used for the flow

options - the key/value options to be passed

Returns:

a response object

runFlow

public RunFlowResponse runFlow(java.lang.String flowName,
                               java.util.List<java.lang.String> stepNums,
                               java.lang.String jobId,
                               java.util.Map<java.lang.String,java.lang.Object> options)

Description copied from interface: FlowRunner

Runs the flow, with a specific set of steps, with all custom settings

Specified by:

runFlow in interface FlowRunner

Parameters:

flowName - the flow to run

stepNums - the steps in the flow to run

jobId - the jobid to be used for the flow

options - the key/value options to be passed

Returns:

a response object

runFlow

public RunFlowResponse runFlow(java.lang.String flowName,
                               java.util.List<java.lang.String> stepNums,
                               java.lang.String jobId,
                               java.util.Map<java.lang.String,java.lang.Object> options,
                               java.util.Map<java.lang.String,java.lang.Object> stepConfig)

Description copied from interface: FlowRunner

Runs the flow, with a specific set of steps, with all custom settings

Specified by:

runFlow in interface FlowRunner

Parameters:

flowName - the flow to run

stepNums - the steps in the flow to run

jobId - the jobid to be used for the flow

options - the key/value options to be passed

stepConfig - the key/value config to override the running of the step

Returns:

a response object

stopJob

public void stopJob(java.lang.String jobId)

Description copied from interface: FlowRunner

Runs the flow.

Specified by:

stopJob in interface FlowRunner

Parameters:

jobId - the id of the running flow

awaitCompletion

public void awaitCompletion()

Description copied from interface: FlowRunner

Blocks until the flow execution is complete.

Specified by:

awaitCompletion in interface FlowRunner

awaitCompletion

public void awaitCompletion(long timeout,
                            java.util.concurrent.TimeUnit unit)
                     throws java.lang.InterruptedException

Description copied from interface: FlowRunner

Blocks until the flow execution is complete.

Specified by:

awaitCompletion in interface FlowRunner

Parameters:

timeout - the maximum time to wait

unit - the time unit of the timeout argument

Throws:

java.lang.InterruptedException - if interrupted while waiting

getQueuedJobIdsFromFlow

public java.util.List<java.lang.String> getQueuedJobIdsFromFlow(java.lang.String flowName)

getJobResponseById

public RunFlowResponse getJobResponseById(java.lang.String jobId)

isJobRunning

public boolean isJobRunning()

getRunningStepKey

public java.lang.String getRunningStepKey()

getRunningFlow

public Flow getRunningFlow()