Squashed commit of the amqp3 branch:

* Add AMQP queue processing