amqp connection recovery