added a notify system for consumers per queue

We should move this logic into `db`, so if the key format ever changes we'll have a better chance of remembering to update this as well.