reliably pull messages off the queue
Reprocess any inprogress messages on startup