Refactor
Cover consumer exception handling w/ basic.cancel
Factor out duplication