@Override public void run(){
  while (!shutdownRequestMade) {
    try {
      ObjectAndMethod objectAndMethod=taskQueue.poll(THREAD_SHUTDOWN_CHECK_INTERVAL,TimeUnit.MILLISECONDS);
      if (objectAndMethod != null) {
        callCorrectMethod(objectAndMethod);
      }
    }
 catch (    InterruptedException e) {
      LOGGER.warn("Cache Listener thread interrupted in MultiThreadedListener.",e);
    }
  }
  ObjectAndMethod objectAndMethod;
  while ((objectAndMethod=taskQueue.poll()) != null) {
    callCorrectMethod(objectAndMethod);
  }
}

@ Override public void run ( ) { while ( ! shutdownRequestMade ) { try { ObjectAndMethod objectAndMethod = taskQueue . poll ( THREAD_SHUTDOWN_CHECK_INTERVAL , TimeUnit . MILLISECONDS ) ; if ( objectAndMethod != null ) { callCorrectMethod ( objectAndMethod ) ; } } catch ( InterruptedException e ) { LOGGER . warn ( "Cache Listener thread interrupted in MultiThreadedListener." , e ) ; } } ObjectAndMethod objectAndMethod ; while ( ( objectAndMethod = taskQueue . poll ( ) ) != null ) { callCorrectMethod ( objectAndMethod ) ; } }
runs from start up to shutdown and listens for updates .
