Pull out some common functionality to use with a consumer
1000 msg / s is a little aggressive on my laptop