public void addListener(StageListener listener) {
        if (logger.isDebugEnabled()) {
            logger.debug("## pipeline[{}] add listener [{}]", getPipelineId(),
                         ClassUtils.getShortClassName(listener.getClass()));
        }

        this.listeners.add(listener);
    }
public void addListener ( StageListener listener ) { if ( logger . isDebugEnabled ( ) ) { logger . debug ( "## pipeline[{}] add listener [{}]" , getPipelineId ( ) , ClassUtils . getShortClassName ( listener . getClass ( ) ) ) ; } this . listeners . add ( listener ) ; }
======================== listener处理 ======================