Threaded consumers.

See http://threebean.org/blog/threading-moksha

This should break apart the consumers given each consumer its own thread(s)
fed by a thread-safe queue.