question: public void run ( ) { start ( ) ; try { while ( true ) { Thread . sleep ( interval ) ; processConfigMessages ( ) ; } } catch ( InterruptedException e ) { e . printStackTrace ( ) ; log . warn ( "Got interrupt in config manager thread, so shutting down" ) ; } finally { log . info ( "Stopping the config manager" ) ; stop ( ) ; } }
target:  This method is an infinite loop that periodically checks if there are any new messages in the job coordinator stream, and reads them if they exist. Then it reacts accordingly based on the configuration that is being set. The method the calls the start() method to initialized the system, runs in a infinite loop, and calls the stop() method at the end to stop the consumer and the system