First pass at consumer. Still need to check connection reliability, not
acking until processing complete, a better test involving publisher and consumer