public boolean onRecordErrorStopPipeline ( ) { for ( Pipe pipe : pipes ) { StageContext stageContext = pipe . getStage ( ) . getContext ( ) ; if ( stageContext . getOnErrorRecord ( ) == OnRecordError . STOP_PIPELINE ) { return true ; } } return false ; }
Return true if at least one stage is configured with STOP_PIPELINE for OnRecordError policy .