This code has been copied with permission from:
    https://github.com/samrushing/amqp-shrapnel
It also has been changed to pass pep8 and to work in the
coro package.