Pause/resume the queue processing.

In the event of an error downstream, we want to be able to pause
the processing of further messages without causing unnecessary
overhead.