Fix consumer pausing again

We need to pause at the end of the current message, not the whole queue.