Package org.camunda.bpm.engine.impl.jobexecutor

Class EventSubscriptionJobDeclaration

java.lang.Object

org.camunda.bpm.engine.impl.jobexecutor.JobDeclaration<EventSubscriptionEntity,MessageEntity>

org.camunda.bpm.engine.impl.jobexecutor.EventSubscriptionJobDeclaration

All Implemented Interfaces:

Serializable

public class EventSubscriptionJobDeclaration
extends JobDeclaration<EventSubscriptionEntity,MessageEntity>

Describes and creates jobs for handling an event asynchronously. These jobs are created in the context of an EventSubscriptionEntity and are of type MessageEntity.

Author:

Thorben Lindhauer

See Also:

• Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
protected EventSubscriptionDeclaration	eventSubscriptionDeclaration

Fields inherited from class org.camunda.bpm.engine.impl.jobexecutor.JobDeclaration

activity, exclusive, jobConfiguration, jobDefinitionId, jobHandlerConfiguration, jobHandlerType, jobPriorityProvider

Constructor Summary

Constructors

Constructor	Description
EventSubscriptionJobDeclaration(EventSubscriptionDeclaration eventSubscriptionDeclaration)

Method Summary

Modifier and Type	Method	Description
static EventSubscriptionJobDeclaration	findDeclarationForSubscription(EventSubscriptionEntity eventSubscription)	Assumes that an activity has at most one declaration of a certain eventType.
String	getActivityId()
static List<EventSubscriptionJobDeclaration>	getDeclarationsForActivity(PvmActivity activity)
String	getEventName()
String	getEventType()
protected MessageEntity	newJobInstance(EventSubscriptionEntity eventSubscription)
protected ExecutionEntity	resolveExecution(EventSubscriptionEntity context)	Returns the execution in which context the job is created.
protected JobHandlerConfiguration	resolveJobHandlerConfiguration(EventSubscriptionEntity context)

Methods inherited from class org.camunda.bpm.engine.impl.jobexecutor.JobDeclaration

createJobInstance, getActivity, getJobConfiguration, getJobDefinitionId, getJobHandlerType, getJobPriorityProvider, getProcessDefinition, isExclusive, postInitialize, reconfigure, resolveDueDate, resolveExclusive, resolveJobDefinitionId, resolveJobHandler, resolveJobHandlerType, resolveRetries, setActivity, setExclusive, setJobConfiguration, setJobDefinitionId, setJobPriorityProvider

Methods inherited from class java.lang.Object

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

Field Details

eventSubscriptionDeclaration

protected EventSubscriptionDeclaration eventSubscriptionDeclaration

Constructor Details

EventSubscriptionJobDeclaration

public EventSubscriptionJobDeclaration(EventSubscriptionDeclaration eventSubscriptionDeclaration)

Method Details

newJobInstance

protected MessageEntity newJobInstance(EventSubscriptionEntity eventSubscription)

Specified by:

newJobInstance in class JobDeclaration<EventSubscriptionEntity,MessageEntity>

getEventType

public String getEventType()

getEventName

public String getEventName()

getActivityId

public String getActivityId()

Overrides:

getActivityId in class JobDeclaration<EventSubscriptionEntity,MessageEntity>

resolveExecution

protected ExecutionEntity resolveExecution(EventSubscriptionEntity context)

Description copied from class: JobDeclaration

Returns the execution in which context the job is created. The execution is used to determine the job's priority based on a BPMN activity the execution is currently executing. May be null.

Specified by:

resolveExecution in class JobDeclaration<EventSubscriptionEntity,MessageEntity>

resolveJobHandlerConfiguration

protected JobHandlerConfiguration resolveJobHandlerConfiguration(EventSubscriptionEntity context)

Specified by:

resolveJobHandlerConfiguration in class JobDeclaration<EventSubscriptionEntity,MessageEntity>

getDeclarationsForActivity

public static List<EventSubscriptionJobDeclaration> getDeclarationsForActivity(PvmActivity activity)

findDeclarationForSubscription

public static EventSubscriptionJobDeclaration findDeclarationForSubscription(EventSubscriptionEntity eventSubscription)

Assumes that an activity has at most one declaration of a certain eventType.