Read messages from a queue, handle them, and propagate the message out on a pub sub.