public void stop ( ) { running = false ; if ( server != null ) server . stop ( ) ; if ( aggregateDaemon != null ) aggregateDaemon . interrupt ( ) ; }
Stop all Collector threads and wait for all to finish .