Updated to reflect the fact that subscribe is a non-blocking call (and creates it's own thread to consume messages)