Rewrite for multiple AMQP connection support