Package 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	Description
static class	AsyncContinuationJobHandler.AsyncContinuationConfiguration

Field Summary

Fields

Modifier and Type	Field	Description
static final String	TYPE

Constructor Summary

Constructors

Constructor	Description
AsyncContinuationJobHandler()

Method Summary

Modifier and Type	Method	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 Details

TYPE

public static final String TYPE

See Also:

• Constant Field Values

Constructor Details

AsyncContinuationJobHandler

public AsyncContinuationJobHandler()

Method Details

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