def process_schedules

      now = Time.now.utc
      delta = now - @last_time

      return if delta < 0.8
        #
        # consider schedules at most twice per second (don't do that job
        # too often)

      @last_time = now

      @storage.get_schedules(delta, now).each { |s| turn_schedule_to_msg(s) }
    end
def process_schedules

      now = Time.now.utc
      delta = now - @last_time

      return if delta < 0.8
        #
        # consider schedules at most twice per second (don't do that job
        # too often)

      @last_time = now

      @storage.get_schedules(delta, now).each { |s| turn_schedule_to_msg(s) }
    end
Gets schedules from the storage and if their time has come,
 turns them into msg (for immediate execution).