From 267ba61e9c731a91bdb45c3015eb499cd9dcc6dc Mon Sep 17 00:00:00 2001 From: Russell Bryant Date: Fri, 7 Nov 2014 22:10:09 +0100 Subject: [PATCH] Drop RpcProxy usage from MetadataPluginApi Drop the usage of the RpcProxy compatibility class from MetadataPluginApi. The equivalent direct usage of oslo.messaging APIs are used instead. Part of blueprint drop-rpc-compat. Change-Id: I1764dd715237bc76dae2789121850f69b8f82888 --- neutron/agent/metadata/agent.py | 13 +++++-------- 1 file changed, 5 insertions(+), 8 deletions(-) diff --git a/neutron/agent/metadata/agent.py b/neutron/agent/metadata/agent.py index 1d6cdfed9..1a9e84774 100644 --- a/neutron/agent/metadata/agent.py +++ b/neutron/agent/metadata/agent.py @@ -46,23 +46,20 @@ from neutron import wsgi LOG = logging.getLogger(__name__) -class MetadataPluginAPI(n_rpc.RpcProxy): +class MetadataPluginAPI(object): """Agent-side RPC (stub) for agent-to-plugin interaction. API version history: 1.0 - Initial version. """ - BASE_RPC_API_VERSION = '1.0' - def __init__(self, topic): - super(MetadataPluginAPI, self).__init__( - topic=topic, default_version=self.BASE_RPC_API_VERSION) + target = messaging.Target(topic=topic, version='1.0') + self.client = n_rpc.get_client(target) def get_ports(self, context, filters): - return self.call(context, - self.make_msg('get_ports', - filters=filters)) + cctxt = self.client.prepare() + return cctxt.call(context, 'get_ports', filters=filters) class MetadataProxyHandler(object): -- 2.45.2