Instead of handling messages as they arrive we handle them in batches,
giving us better error handling and insight into what state we are in.

Relates to #42