private boolean isExecutionPaused ( Execution nextStepExecution ) { // If execution was paused if ( nextStepExecution == null ) { //set current step to finished executionMessage . setStatus ( ExecStatus . FINISHED ) ; executionMessage . incMsgSeqId ( ) ; executionMessage . setPayload ( null ) ; //execution was paused - send only the FINISHED message! try { outBuffer . put ( executionMessage ) ; } catch ( InterruptedException e ) { logger . warn ( "Thread was interrupted! Exiting the execution... " , e ) ; } return true ; } else { return false ; } }
If execution was paused it sends the current step with status FINISHED and that is all ...