Make it all work

This is the refactored version of emque with focus on making this consumer centric.  It eliminates the retry/failure topics, while adding context to errors so that services can decide how to retry things after making any necessary fixes.  It also works to adopt the functional/pipe approaches from APIv3.
is there a reason you left this commented out?