'Initialize agent extension.'

def initialize(self, connection, driver_type):

    self.resource_rpc = resources_rpc.ResourcesPullRpcApi()
    self.qos_driver = manager.NeutronManager.load_class_for_provider('neutron.qos.agent_drivers', driver_type)()
    self.qos_driver.consume_api(self.agent_api)
    self.qos_driver.initialize()
    self.policy_map = PortPolicyMap()
    self._register_rpc_consumers(connection)
