public synchronized void shutdown(boolean immediate){
  logger.info("Shutting down pipeline: " + name);
  for (  Stage stage : stages)   stage.shutdown(immediate);
  shutdownTaskExec.shutdownNow();
}

public synchronized void shutdown ( boolean immediate ) { logger . info ( "Shutting down pipeline: " + name ) ; for ( Stage stage : stages ) stage . shutdown ( immediate ) ; shutdownTaskExec . shutdownNow ( ) ; }
stop pipeline operation . this is called when replication goes offline .
