fix(v3): eagerly dequeue messages from a queue when that queue is add…

fix(v3): eagerly dequeue messages from a queue when that queue is add… #2409