MQ pub/sub as streams - based on mqemitter