public void initListeners(WorkflowContext workflowContext) {
        if (isInit.compareAndSet(false, true)) {
            if (listenerFactory == null || taskType == null) {
                return;
            }
            List<TaskEventListener> listeners = Lists.newArrayList(listenerFactory.get(workflowContext, taskType));
            List<String> listenerNames = listeners.stream().map(EventListener::name).collect(Collectors.toList());
            log.info("ServiceTask: [{}] is init for listeners: {}", getName(), listenerNames);
            addListeners(listeners);
        } else {
            log.warn("ServiceTask [{}] was already init", getName());
        }
    }
Init the listeners for current Service Task.
inlong-manager/manager-workflow/src/main/java/org/apache/inlong/manager/workflow/definition/ServiceTask.java