Worker now has a dedicated consumer from the broker so each thread doesn't
need to poll on its own. Should be more efficient for multi-threaded
workers.