Package org.jbpm.services.task.audit.jms
Class AsyncTaskLifeCycleEventProducer
- java.lang.Object
-
- org.jbpm.services.task.persistence.PersistableEventListener
-
- org.jbpm.services.task.audit.jms.AsyncTaskLifeCycleEventProducer
-
- All Implemented Interfaces:
EventListener,TaskLifeCycleEventListener,org.kie.api.task.TaskLifeCycleEventListener
public class AsyncTaskLifeCycleEventProducer extends PersistableEventListener implements TaskLifeCycleEventListener
-
-
Constructor Summary
Constructors Constructor Description AsyncTaskLifeCycleEventProducer()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidafterTaskActivatedEvent(org.kie.api.task.TaskEvent event)voidafterTaskAddedEvent(org.kie.api.task.TaskEvent event)voidafterTaskAssignmentsAddedEvent(org.kie.api.task.TaskEvent event, org.kie.api.task.TaskLifeCycleEventListener.AssignmentType type, List<org.kie.api.task.model.OrganizationalEntity> entities)voidafterTaskAssignmentsRemovedEvent(org.kie.api.task.TaskEvent event, org.kie.api.task.TaskLifeCycleEventListener.AssignmentType type, List<org.kie.api.task.model.OrganizationalEntity> entities)voidafterTaskClaimedEvent(org.kie.api.task.TaskEvent event)voidafterTaskCompletedEvent(org.kie.api.task.TaskEvent event)voidafterTaskDelegatedEvent(org.kie.api.task.TaskEvent event)voidafterTaskExitedEvent(org.kie.api.task.TaskEvent event)voidafterTaskFailedEvent(org.kie.api.task.TaskEvent event)voidafterTaskForwardedEvent(org.kie.api.task.TaskEvent event)voidafterTaskInputVariableChangedEvent(org.kie.api.task.TaskEvent event, Map<String,Object> variables)voidafterTaskNominatedEvent(org.kie.api.task.TaskEvent event)voidafterTaskNotificationEvent(org.kie.api.task.TaskEvent event)voidafterTaskOutputVariableChangedEvent(org.kie.api.task.TaskEvent event, Map<String,Object> variables)voidafterTaskReassignedEvent(org.kie.api.task.TaskEvent event)voidafterTaskReleasedEvent(org.kie.api.task.TaskEvent event)voidafterTaskResumedEvent(org.kie.api.task.TaskEvent event)voidafterTaskSkippedEvent(org.kie.api.task.TaskEvent event)voidafterTaskStartedEvent(org.kie.api.task.TaskEvent event)voidafterTaskStoppedEvent(org.kie.api.task.TaskEvent event)voidafterTaskSuspendedEvent(org.kie.api.task.TaskEvent event)voidafterTaskUpdatedEvent(org.kie.api.task.TaskEvent event)protected voidassignmentsUpdated(org.kie.api.task.TaskEvent event, org.kie.api.task.TaskLifeCycleEventListener.AssignmentType type, List<org.kie.api.task.model.OrganizationalEntity> entities, String messageSufix)voidbeforeTaskActivatedEvent(org.kie.api.task.TaskEvent event)voidbeforeTaskAddedEvent(org.kie.api.task.TaskEvent event)voidbeforeTaskClaimedEvent(org.kie.api.task.TaskEvent event)voidbeforeTaskCompletedEvent(org.kie.api.task.TaskEvent event)voidbeforeTaskDelegatedEvent(org.kie.api.task.TaskEvent event)voidbeforeTaskExitedEvent(org.kie.api.task.TaskEvent event)voidbeforeTaskFailedEvent(org.kie.api.task.TaskEvent event)voidbeforeTaskForwardedEvent(org.kie.api.task.TaskEvent event)voidbeforeTaskNominatedEvent(org.kie.api.task.TaskEvent event)voidbeforeTaskNotificationEvent(org.kie.api.task.TaskEvent event)voidbeforeTaskReassignedEvent(org.kie.api.task.TaskEvent event)voidbeforeTaskReleasedEvent(org.kie.api.task.TaskEvent event)voidbeforeTaskResumedEvent(org.kie.api.task.TaskEvent event)voidbeforeTaskSkippedEvent(org.kie.api.task.TaskEvent event)voidbeforeTaskStartedEvent(org.kie.api.task.TaskEvent event)voidbeforeTaskStoppedEvent(org.kie.api.task.TaskEvent event)voidbeforeTaskSuspendedEvent(org.kie.api.task.TaskEvent event)voidbeforeTaskUpdatedEvent(org.kie.api.task.TaskEvent event)protected AuditTaskImplcreateAuditTask(org.kie.api.task.model.Task ti, Date date)booleanequals(Object obj)protected StringgetActualOwner(org.kie.api.task.model.Task ti)protected AuditTaskImplgetAuditTask(org.kie.internal.task.api.TaskPersistenceContext persistenceContext, org.kie.api.task.model.Task ti)javax.jms.ConnectionFactorygetConnectionFactory()javax.jms.QueuegetQueue()protected StringgetUpdateFieldLog(String fieldName, String previousValue, String value)inthashCode()protected List<TaskVariableImpl>indexVariables(org.kie.api.task.model.Task task, Map<String,Object> variables, org.kie.internal.task.api.TaskVariable.VariableType type)booleanisTransacted()protected voidsendMessage(AuditTaskData auditTaskData, int priority)voidsetConnectionFactory(javax.jms.ConnectionFactory connectionFactory)voidsetQueue(javax.jms.Queue queue)voidsetTransacted(boolean transacted)-
Methods inherited from class org.jbpm.services.task.persistence.PersistableEventListener
cleanup, getPersistenceContext
-
-
-
-
Method Detail
-
getConnectionFactory
public javax.jms.ConnectionFactory getConnectionFactory()
-
setConnectionFactory
public void setConnectionFactory(javax.jms.ConnectionFactory connectionFactory)
-
getQueue
public javax.jms.Queue getQueue()
-
setQueue
public void setQueue(javax.jms.Queue queue)
-
isTransacted
public boolean isTransacted()
-
setTransacted
public void setTransacted(boolean transacted)
-
afterTaskStartedEvent
public void afterTaskStartedEvent(org.kie.api.task.TaskEvent event)
- Specified by:
afterTaskStartedEventin interfaceorg.kie.api.task.TaskLifeCycleEventListener
-
afterTaskActivatedEvent
public void afterTaskActivatedEvent(org.kie.api.task.TaskEvent event)
- Specified by:
afterTaskActivatedEventin interfaceorg.kie.api.task.TaskLifeCycleEventListener
-
afterTaskClaimedEvent
public void afterTaskClaimedEvent(org.kie.api.task.TaskEvent event)
- Specified by:
afterTaskClaimedEventin interfaceorg.kie.api.task.TaskLifeCycleEventListener
-
afterTaskSkippedEvent
public void afterTaskSkippedEvent(org.kie.api.task.TaskEvent event)
- Specified by:
afterTaskSkippedEventin interfaceorg.kie.api.task.TaskLifeCycleEventListener
-
afterTaskStoppedEvent
public void afterTaskStoppedEvent(org.kie.api.task.TaskEvent event)
- Specified by:
afterTaskStoppedEventin interfaceorg.kie.api.task.TaskLifeCycleEventListener
-
afterTaskCompletedEvent
public void afterTaskCompletedEvent(org.kie.api.task.TaskEvent event)
- Specified by:
afterTaskCompletedEventin interfaceorg.kie.api.task.TaskLifeCycleEventListener
-
afterTaskFailedEvent
public void afterTaskFailedEvent(org.kie.api.task.TaskEvent event)
- Specified by:
afterTaskFailedEventin interfaceorg.kie.api.task.TaskLifeCycleEventListener
-
afterTaskAddedEvent
public void afterTaskAddedEvent(org.kie.api.task.TaskEvent event)
- Specified by:
afterTaskAddedEventin interfaceorg.kie.api.task.TaskLifeCycleEventListener
-
afterTaskExitedEvent
public void afterTaskExitedEvent(org.kie.api.task.TaskEvent event)
- Specified by:
afterTaskExitedEventin interfaceorg.kie.api.task.TaskLifeCycleEventListener
-
afterTaskReleasedEvent
public void afterTaskReleasedEvent(org.kie.api.task.TaskEvent event)
- Specified by:
afterTaskReleasedEventin interfaceorg.kie.api.task.TaskLifeCycleEventListener
-
afterTaskResumedEvent
public void afterTaskResumedEvent(org.kie.api.task.TaskEvent event)
- Specified by:
afterTaskResumedEventin interfaceorg.kie.api.task.TaskLifeCycleEventListener
-
afterTaskSuspendedEvent
public void afterTaskSuspendedEvent(org.kie.api.task.TaskEvent event)
- Specified by:
afterTaskSuspendedEventin interfaceorg.kie.api.task.TaskLifeCycleEventListener
-
afterTaskForwardedEvent
public void afterTaskForwardedEvent(org.kie.api.task.TaskEvent event)
- Specified by:
afterTaskForwardedEventin interfaceorg.kie.api.task.TaskLifeCycleEventListener
-
afterTaskDelegatedEvent
public void afterTaskDelegatedEvent(org.kie.api.task.TaskEvent event)
- Specified by:
afterTaskDelegatedEventin interfaceorg.kie.api.task.TaskLifeCycleEventListener
-
afterTaskNominatedEvent
public void afterTaskNominatedEvent(org.kie.api.task.TaskEvent event)
- Specified by:
afterTaskNominatedEventin interfaceorg.kie.api.task.TaskLifeCycleEventListener
-
beforeTaskReleasedEvent
public void beforeTaskReleasedEvent(org.kie.api.task.TaskEvent event)
- Specified by:
beforeTaskReleasedEventin interfaceorg.kie.api.task.TaskLifeCycleEventListener
-
afterTaskUpdatedEvent
public void afterTaskUpdatedEvent(org.kie.api.task.TaskEvent event)
- Specified by:
afterTaskUpdatedEventin interfaceorg.kie.api.task.TaskLifeCycleEventListener
-
afterTaskReassignedEvent
public void afterTaskReassignedEvent(org.kie.api.task.TaskEvent event)
- Specified by:
afterTaskReassignedEventin interfaceorg.kie.api.task.TaskLifeCycleEventListener
-
afterTaskOutputVariableChangedEvent
public void afterTaskOutputVariableChangedEvent(org.kie.api.task.TaskEvent event, Map<String,Object> variables)- Specified by:
afterTaskOutputVariableChangedEventin interfaceorg.kie.api.task.TaskLifeCycleEventListener
-
afterTaskInputVariableChangedEvent
public void afterTaskInputVariableChangedEvent(org.kie.api.task.TaskEvent event, Map<String,Object> variables)- Specified by:
afterTaskInputVariableChangedEventin interfaceorg.kie.api.task.TaskLifeCycleEventListener
-
indexVariables
protected List<TaskVariableImpl> indexVariables(org.kie.api.task.model.Task task, Map<String,Object> variables, org.kie.internal.task.api.TaskVariable.VariableType type)
-
afterTaskAssignmentsAddedEvent
public void afterTaskAssignmentsAddedEvent(org.kie.api.task.TaskEvent event, org.kie.api.task.TaskLifeCycleEventListener.AssignmentType type, List<org.kie.api.task.model.OrganizationalEntity> entities)- Specified by:
afterTaskAssignmentsAddedEventin interfaceorg.kie.api.task.TaskLifeCycleEventListener
-
afterTaskAssignmentsRemovedEvent
public void afterTaskAssignmentsRemovedEvent(org.kie.api.task.TaskEvent event, org.kie.api.task.TaskLifeCycleEventListener.AssignmentType type, List<org.kie.api.task.model.OrganizationalEntity> entities)- Specified by:
afterTaskAssignmentsRemovedEventin interfaceorg.kie.api.task.TaskLifeCycleEventListener
-
assignmentsUpdated
protected void assignmentsUpdated(org.kie.api.task.TaskEvent event, org.kie.api.task.TaskLifeCycleEventListener.AssignmentType type, List<org.kie.api.task.model.OrganizationalEntity> entities, String messageSufix)
-
getUpdateFieldLog
protected String getUpdateFieldLog(String fieldName, String previousValue, String value)
-
getActualOwner
protected String getActualOwner(org.kie.api.task.model.Task ti)
-
createAuditTask
protected AuditTaskImpl createAuditTask(org.kie.api.task.model.Task ti, Date date)
-
sendMessage
protected void sendMessage(AuditTaskData auditTaskData, int priority)
-
getAuditTask
protected AuditTaskImpl getAuditTask(org.kie.internal.task.api.TaskPersistenceContext persistenceContext, org.kie.api.task.model.Task ti)
-
beforeTaskActivatedEvent
public void beforeTaskActivatedEvent(org.kie.api.task.TaskEvent event)
- Specified by:
beforeTaskActivatedEventin interfaceorg.kie.api.task.TaskLifeCycleEventListener
-
beforeTaskClaimedEvent
public void beforeTaskClaimedEvent(org.kie.api.task.TaskEvent event)
- Specified by:
beforeTaskClaimedEventin interfaceorg.kie.api.task.TaskLifeCycleEventListener
-
beforeTaskSkippedEvent
public void beforeTaskSkippedEvent(org.kie.api.task.TaskEvent event)
- Specified by:
beforeTaskSkippedEventin interfaceorg.kie.api.task.TaskLifeCycleEventListener
-
beforeTaskStartedEvent
public void beforeTaskStartedEvent(org.kie.api.task.TaskEvent event)
- Specified by:
beforeTaskStartedEventin interfaceorg.kie.api.task.TaskLifeCycleEventListener
-
beforeTaskStoppedEvent
public void beforeTaskStoppedEvent(org.kie.api.task.TaskEvent event)
- Specified by:
beforeTaskStoppedEventin interfaceorg.kie.api.task.TaskLifeCycleEventListener
-
beforeTaskCompletedEvent
public void beforeTaskCompletedEvent(org.kie.api.task.TaskEvent event)
- Specified by:
beforeTaskCompletedEventin interfaceorg.kie.api.task.TaskLifeCycleEventListener
-
beforeTaskFailedEvent
public void beforeTaskFailedEvent(org.kie.api.task.TaskEvent event)
- Specified by:
beforeTaskFailedEventin interfaceorg.kie.api.task.TaskLifeCycleEventListener
-
beforeTaskAddedEvent
public void beforeTaskAddedEvent(org.kie.api.task.TaskEvent event)
- Specified by:
beforeTaskAddedEventin interfaceorg.kie.api.task.TaskLifeCycleEventListener
-
beforeTaskExitedEvent
public void beforeTaskExitedEvent(org.kie.api.task.TaskEvent event)
- Specified by:
beforeTaskExitedEventin interfaceorg.kie.api.task.TaskLifeCycleEventListener
-
beforeTaskResumedEvent
public void beforeTaskResumedEvent(org.kie.api.task.TaskEvent event)
- Specified by:
beforeTaskResumedEventin interfaceorg.kie.api.task.TaskLifeCycleEventListener
-
beforeTaskSuspendedEvent
public void beforeTaskSuspendedEvent(org.kie.api.task.TaskEvent event)
- Specified by:
beforeTaskSuspendedEventin interfaceorg.kie.api.task.TaskLifeCycleEventListener
-
beforeTaskForwardedEvent
public void beforeTaskForwardedEvent(org.kie.api.task.TaskEvent event)
- Specified by:
beforeTaskForwardedEventin interfaceorg.kie.api.task.TaskLifeCycleEventListener
-
beforeTaskDelegatedEvent
public void beforeTaskDelegatedEvent(org.kie.api.task.TaskEvent event)
- Specified by:
beforeTaskDelegatedEventin interfaceorg.kie.api.task.TaskLifeCycleEventListener
-
beforeTaskNominatedEvent
public void beforeTaskNominatedEvent(org.kie.api.task.TaskEvent event)
- Specified by:
beforeTaskNominatedEventin interfaceorg.kie.api.task.TaskLifeCycleEventListener
-
beforeTaskUpdatedEvent
public void beforeTaskUpdatedEvent(org.kie.api.task.TaskEvent event)
- Specified by:
beforeTaskUpdatedEventin interfaceorg.kie.api.task.TaskLifeCycleEventListener
-
beforeTaskReassignedEvent
public void beforeTaskReassignedEvent(org.kie.api.task.TaskEvent event)
- Specified by:
beforeTaskReassignedEventin interfaceorg.kie.api.task.TaskLifeCycleEventListener
-
beforeTaskNotificationEvent
public void beforeTaskNotificationEvent(org.kie.api.task.TaskEvent event)
- Specified by:
beforeTaskNotificationEventin interfaceorg.kie.api.task.TaskLifeCycleEventListener
-
afterTaskNotificationEvent
public void afterTaskNotificationEvent(org.kie.api.task.TaskEvent event)
- Specified by:
afterTaskNotificationEventin interfaceorg.kie.api.task.TaskLifeCycleEventListener
-
-