Implements basic job processing.
Re-publish 'stale' pending jobs on queue startup.