public void registerListener(TimerListener listener) {
    timerListener = listener;

    if (!readyTimers.isEmpty()) {
      timerListener.onTimer();
    }
  }
For run loop to listen to timer firing so it can schedule the callbacks.
samza-core/src/main/java/org/apache/samza/scheduler/EpochTimeScheduler.java