question: public void stop ( ) { try { discoverySchedulingSelector . close ( ) ; _dataCollectionExecutorService . shutdown ( ) ; _dataCollectionExecutorService . awaitTermination ( 120 , TimeUnit . SECONDS ) ; } catch ( Exception e ) { _logger . error ( "TimeOut occured after waiting Client Threads to finish" ) ; } }
target:  Stopping DisocveryConsumer, would close the execService.