org.camunda.bpm.engine.impl.jobexecutor

Class AsyncContinuationJobHandler

java.lang.Object

org.camunda.bpm.engine.impl.jobexecutor.AsyncContinuationJobHandler

All Implemented Interfaces:

JobHandler<AsyncContinuationJobHandler.AsyncContinuationConfiguration>

public class AsyncContinuationJobHandler
extends Object
implements JobHandler<AsyncContinuationJobHandler.AsyncContinuationConfiguration>

Author:

Daniel Meyer, Thorben Lindhauer

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AsyncContinuationJobHandler.AsyncContinuationConfiguration

Field Summary

Fields

Modifier and Type	Field and Description
static String	TYPE

Constructor Summary

Constructors

Constructor and Description
AsyncContinuationJobHandler()

Method Summary

Methods

Modifier and Type	Method and Description
void	execute(AsyncContinuationJobHandler.AsyncContinuationConfiguration configuration, ExecutionEntity execution, CommandContext commandContext, String tenantId)
PvmAtomicOperation	findMatchingAtomicOperation(String operationName)
String	getType()
protected boolean	isSupported(PvmAtomicOperation atomicOperation)
AsyncContinuationJobHandler.AsyncContinuationConfiguration	newConfiguration(String canonicalString)
void	onDelete(AsyncContinuationJobHandler.AsyncContinuationConfiguration configuration, JobEntity jobEntity) Clean up before job is deleted.
protected String[]	tokenizeJobConfiguration(String jobConfiguration)

Methods inherited from class java.lang.Object

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

Field Detail

TYPE

public static final String TYPE

See Also:

Constant Field Values

Constructor Detail

AsyncContinuationJobHandler

public AsyncContinuationJobHandler()

Method Detail

getType

public String getType()

Specified by:

getType in interface JobHandler<AsyncContinuationJobHandler.AsyncContinuationConfiguration>

execute

public void execute(AsyncContinuationJobHandler.AsyncContinuationConfiguration configuration,
           ExecutionEntity execution,
           CommandContext commandContext,
           String tenantId)

Specified by:

execute in interface JobHandler<AsyncContinuationJobHandler.AsyncContinuationConfiguration>

findMatchingAtomicOperation

public PvmAtomicOperation findMatchingAtomicOperation(String operationName)

isSupported

protected boolean isSupported(PvmAtomicOperation atomicOperation)

newConfiguration

public AsyncContinuationJobHandler.AsyncContinuationConfiguration newConfiguration(String canonicalString)

Specified by:

newConfiguration in interface JobHandler<AsyncContinuationJobHandler.AsyncContinuationConfiguration>

tokenizeJobConfiguration

protected String[] tokenizeJobConfiguration(String jobConfiguration)

Returns:

an array of length two with the following contents:

• First element: pvm atomic operation name
• Second element: transition id (may be null)

onDelete

public void onDelete(AsyncContinuationJobHandler.AsyncContinuationConfiguration configuration,
            JobEntity jobEntity)

Description copied from interface: JobHandler

Clean up before job is deleted. Like removing of auxiliary entities specific for this job handler.

Specified by:

onDelete in interface JobHandler<AsyncContinuationJobHandler.AsyncContinuationConfiguration>

Parameters:

configuration - the job handler configuration

jobEntity - the job entity to be deleted