added a notify system for consumers per queue

We should check the reply for an error here, and not bother with checking if `reply.Type == pubsub.SubscribeReply` later