Improved AMQP subscriber driver.