- fix tests
 - create a runnable for each message. This insulates our queue handler from exceptions on sending
   which kills our message processor
 - create a runnable for each message from redis pubsub
 - create runnalbe for each task