'Run all ready items through their processing hook.'

@classmethod
def run(cls):

    from r2.lib import amqp
    from r2.lib.hooks import all_hooks
    for (hook_name, hook) in all_hooks().items():
        if hook_name.startswith('trylater.'):
            rowkey = hook_name[len('trylater.'):]
            def ready_fn(ready_items):
                return hook.call(data=ready_items)
            g.log.info('Trying    %s', rowkey)
            cls.process_ready_items(rowkey, ready_fn)
    amqp.worker.join()
    g.stats.flush()
