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