MQ pub/sub as streams - based on mqemitter - View it on GitHub