added a notify system for consumers per queue

Don't think we need this anymore