added a notify system for consumers per queue

What's this for?