added a notify system for consumers per queue

We should probably log this error