added a notify system for consumers per queue

I don't think these sleeps are necessary anymore, since this thread ends once you break. We should probably add a TODO that we need to handle the case of the connection closing.