The amqp example seems using the same channel for publishing and consuming which is an anti-pattern? https://github.com/streadway/amqp/issues/327 https://github.com/streadway/amqp/issues/270