public class EventSubscriptionEntity extends Object implements EventSubscription, DbEntity, HasDbRevision, HasDbReferences, Serializable
Modifier and Type | Field and Description |
---|---|
protected ActivityImpl |
activity |
protected String |
activityId |
protected String |
configuration |
protected Date |
created |
protected String |
eventName |
protected String |
eventType |
protected ExecutionEntity |
execution |
protected String |
executionId |
protected String |
id |
protected EventSubscriptionJobDeclaration |
jobDeclaration |
protected String |
processInstanceId |
protected int |
revision |
protected String |
tenantId |
Constructor and Description |
---|
EventSubscriptionEntity() |
EventSubscriptionEntity(EventType eventType) |
EventSubscriptionEntity(ExecutionEntity executionEntity,
EventType eventType) |
Modifier and Type | Method and Description |
---|---|
protected void |
addToExecution() |
static EventSubscriptionEntity |
createAndInsert(ExecutionEntity executionEntity,
EventType eventType,
ActivityImpl activity) |
static EventSubscriptionEntity |
createAndInsert(ExecutionEntity executionEntity,
EventType eventType,
ActivityImpl activity,
String configuration) |
void |
delete() |
boolean |
equals(Object obj) |
void |
eventReceived(Object payload,
boolean processASync) |
void |
eventReceived(Object payload,
Object payloadLocal,
String businessKey,
boolean processASync) |
ActivityImpl |
getActivity() |
String |
getActivityId()
The identifier of the activity that this event subscription belongs to.
|
String |
getConfiguration() |
Date |
getCreated()
The time this event subscription was created.
|
String |
getEventName()
The name of the event this subscription belongs to as defined in the process model.
|
String |
getEventType()
The event subscriptions type.
|
ExecutionEntity |
getExecution() |
String |
getExecutionId()
The execution that is subscribed on the referenced event.
|
String |
getId()
The unique identifier of the event subscription.
|
EventSubscriptionJobDeclaration |
getJobDeclaration() |
Object |
getPersistentState()
Returns a representation of the object,
as would be stored in the database.
|
ProcessDefinitionEntity |
getProcessDefinition() |
String |
getProcessInstanceId()
The process instance this subscription belongs to.
|
Map<String,Class> |
getReferencedEntitiesIdAndClass()
Scope: IN-MEMORY references
|
Set<String> |
getReferencedEntityIds()
Scope: IN-MEMORY references
|
int |
getRevision() |
int |
getRevisionNext() |
String |
getTenantId()
The id of the tenant this event subscription belongs to.
|
int |
hashCode() |
void |
insert() |
boolean |
isSubscriptionForEventType(EventType eventType) |
protected void |
processEventSync(Object payload) |
protected void |
processEventSync(Object payload,
Object payloadLocal,
String businessKey) |
protected void |
removeFromExecution() |
protected void |
scheduleEventAsync(Object payload,
Object payloadLocal,
String businessKey) |
void |
setActivity(ActivityImpl activity) |
void |
setActivityId(String activityId) |
void |
setConfiguration(String configuration) |
void |
setCreated(Date created) |
void |
setEventName(String eventName) |
void |
setEventType(String eventType) |
void |
setExecution(ExecutionEntity execution) |
void |
setExecutionId(String executionId) |
void |
setId(String id) |
void |
setProcessInstanceId(String processInstanceId) |
void |
setRevision(int revision) |
void |
setTenantId(String tenantId) |
String |
toString() |
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
getDependentEntities
protected String id
protected int revision
protected String eventType
protected String eventName
protected String executionId
protected String processInstanceId
protected String activityId
protected String configuration
protected Date created
protected String tenantId
protected ExecutionEntity execution
protected ActivityImpl activity
protected EventSubscriptionJobDeclaration jobDeclaration
public EventSubscriptionEntity()
public EventSubscriptionEntity(EventType eventType)
public EventSubscriptionEntity(ExecutionEntity executionEntity, EventType eventType)
public void eventReceived(Object payload, boolean processASync)
public void eventReceived(Object payload, Object payloadLocal, String businessKey, boolean processASync)
protected void processEventSync(Object payload)
protected void processEventSync(Object payload, Object payloadLocal, String businessKey)
protected void scheduleEventAsync(Object payload, Object payloadLocal, String businessKey)
public void delete()
public void insert()
public static EventSubscriptionEntity createAndInsert(ExecutionEntity executionEntity, EventType eventType, ActivityImpl activity)
public static EventSubscriptionEntity createAndInsert(ExecutionEntity executionEntity, EventType eventType, ActivityImpl activity, String configuration)
protected void addToExecution()
protected void removeFromExecution()
public Object getPersistentState()
DbEntity
getPersistentState
in interface DbEntity
public ExecutionEntity getExecution()
public void setExecution(ExecutionEntity execution)
public ActivityImpl getActivity()
public ProcessDefinitionEntity getProcessDefinition()
public void setActivity(ActivityImpl activity)
public EventSubscriptionJobDeclaration getJobDeclaration()
public String getId()
EventSubscription
getId
in interface DbEntity
getId
in interface EventSubscription
public int getRevision()
getRevision
in interface HasDbRevision
public void setRevision(int revision)
setRevision
in interface HasDbRevision
public int getRevisionNext()
getRevisionNext
in interface HasDbRevision
public boolean isSubscriptionForEventType(EventType eventType)
public String getEventType()
EventSubscription
getEventType
in interface EventSubscription
public void setEventType(String eventType)
public String getEventName()
EventSubscription
getEventName
in interface EventSubscription
public void setEventName(String eventName)
public String getExecutionId()
EventSubscription
getExecutionId
in interface EventSubscription
public void setExecutionId(String executionId)
public String getProcessInstanceId()
EventSubscription
getProcessInstanceId
in interface EventSubscription
public void setProcessInstanceId(String processInstanceId)
public String getConfiguration()
public void setConfiguration(String configuration)
public String getActivityId()
EventSubscription
getActivityId
in interface EventSubscription
public void setActivityId(String activityId)
public Date getCreated()
EventSubscription
getCreated
in interface EventSubscription
public void setCreated(Date created)
public String getTenantId()
EventSubscription
null
if the subscription belongs to no single tenant.getTenantId
in interface EventSubscription
public void setTenantId(String tenantId)
public Set<String> getReferencedEntityIds()
HasDbReferences
Scope: IN-MEMORY references
getReferencedEntityIds
in interface HasDbReferences
public Map<String,Class> getReferencedEntitiesIdAndClass()
HasDbReferences
Scope: IN-MEMORY references
getReferencedEntitiesIdAndClass
in interface HasDbReferences
Copyright © 2022. All rights reserved.