public List<ClusterOperateListener> getQueueOperateListener(WorkflowContext context) {
        List<ClusterOperateListener> listeners = new ArrayList<>();
        for (ClusterOperateListener listener : clusterOperateListeners) {
            if (listener != null && listener.accept(context)) {
                listeners.add(listener);
            }
        }
        return listeners;
    }
Get cluster queue operate listener list.
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/listener/ClusterTaskListenerFactory.java