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();
  }
}

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 ( ) ; } }
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
