@Override
    public boolean accept(WorkflowContext context) {
        ProcessForm processForm = context.getProcessForm();
        return processForm instanceof ClusterResourceProcessForm;
    }
Create task listener for MQ Topic
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/listener/queue/ClusterQueueResourceListener.java