private void sendOnRecordErrorExceptionToHandler ( Record record , Errors error , StageException ex ) throws StageException { errorRecordHandler . onError ( new OnRecordErrorException ( record , error , record . getHeader ( ) . getSourceId ( ) , ex . toString ( ) , ex ) ) ; }
Send exception ex to errorRecordHandler in order to let the handler process it .