added a notify system for consumers per queue

Do we even need to have this `time.After` anymore? Seems like we'll always get updateNotifyCh when we need to re-subscribe