监听

目录

ActivitiEventListener

事件监听类型

监听类型说明
ENGINE_CREATED监听器监听的流程引擎已经创建完毕，并准备好接受API调用。
ENGINE_CLOSED监听器监听的流程引擎已经关闭，不再接受API调用。
ENTITY_CREATED创建了一个新实体。实体包含在事件中。
ENTITY_INITIALIZED创建了一个新实体，初始化也完成了。如果这个实体的创建会包含子实体的创建，这个事件会在子实体都创建/初始化完成后被触发，这是与ENTITY_CREATED的区别。
ENTITY_UPDATED更新了已存在的实体。实体包含在事件中。
ENTITY_DELETED删除了已存在的实体。实体包含在事件中。
ENTITY_SUSPENDED暂停了已存在的实体。实体包含在事件中。会被ProcessDefinitions, ProcessInstances 和 Tasks抛出。
ENTITY_ACTIVATED激活了已存在的实体，实体包含在事件中。会被ProcessDefinitions, ProcessInstances 和 Tasks抛出。
JOB_EXECUTION_SUCCESS作业执行成功。job包含在事件中。
JOB_EXECUTION_FAILURE作业执行失败。作业和异常信息包含在事件中。
JOB_RETRIES_DECREMENTED因为作业执行失败，导致重试次数减少。作业包含在事件中。
TIMER_FIRED触发了定时器。job包含在事件中。
JOB_CANCELED取消了一个作业。事件包含取消的作业。作业可以通过API调用取消， 任务完成后对应的边界定时器也会取消，在新流程定义发布时也会取消。
ACTIVITY_STARTED一个节点开始执行
ACTIVITY_COMPLETED一个节点成功结束
ACTIVITY_SIGNALED一个节点收到了一个信号
ACTIVITY_MESSAGE_RECEIVED一个节点收到了一个消息。在节点收到消息之前触发。收到后，会触发ACTIVITY_SIGNAL或ACTIVITY_STARTED，这会根据节点的类型（边界事件，事件子流程开始事件）
ACTIVITY_ERROR_RECEIVED一个节点收到了一个错误事件。在节点实际处理错误之前触发。 事件的activityId对应着处理错误的节点。 这个事件后续会是ACTIVITY_SIGNALLED或ACTIVITY_COMPLETE， 如果错误发送成功的话。
UNCAUGHT_BPMN_ERROR抛出了未捕获的BPMN错误。流程没有提供针对这个错误的处理器。 事件的activityId为空。
ACTIVITY_COMPENSATE一个节点将要被补偿。事件包含了将要执行补偿的节点id。
VARIABLE_CREATED创建了一个变量。事件包含变量名，变量值和对应的分支或任务（如果存在）。
VARIABLE_UPDATED更新了一个变量。事件包含变量名，变量值和对应的分支或任务（如果存在）。
VARIABLE_DELETED删除了一个变量。事件包含变量名，变量值和对应的分支或任务（如果存在）。
TASK_ASSIGNED任务被分配给了一个人员。事件包含任务。
TASK_CREATED创建了新任务。它位于ENTITY_CREATE事件之后。当任务是由流程创建时， 这个事件会在TaskListener执行之前被执行。
TASK_COMPLETED任务被完成了。它会在ENTITY_DELETE事件之前触发。当任务是流程一部分时，事件会在流程继续运行之前， 后续事件将是ACTIVITY_COMPLETE，对应着完成任务的节点。
TASK_TIMEOUT任务已超时，在TIMER_FIRED事件之后，会触发用户任务的超时事件， 当这个任务分配了一个定时器的时候。
PROCESS_COMPLETED流程已结束。在最后一个节点的ACTIVITY_COMPLETED事件之后触发。 当流程到达的状态，没有任何后续连线时， 流程就会结束。
PROCESS_CANCELLED流程已经被取消。在流程实例从运行时中删除前分发。流程实例由API调用RuntimeService.deleteProcessInstance取消。
MEMBERSHIP_CREATED用户被添加到一个组里。事件包含了用户和组的id。
MEMBERSHIP_DELETED用户被从一个组中删除。事件包含了用户和组的id。
MEMBERSHIPS_DELETED所有成员被从一个组中删除。在成员删除之前触发这个事件，所以他们都是可以访问的。 因为性能方面的考虑，不会为每个成员触发单独的MEMBERSHIP_DELETED事件。

示例

@Slf4j
@Component
public class ActivitiGlobalEventListener implements ActivitiEventListener {
    /**
     * Called when an event has been fired
     *
     * @param event the event
     */
    @Override
    public void onEvent(ActivitiEvent event) {
        Objects.requireNonNull(event.getType());
        switch (event.getType()) {
            case PROCESS_COMPLETED:
                processCompleted(event);
                break;
            case TASK_CREATED:
                taskCreated(event);
                break;
            default:
                break;
        }
    }
}