From d42bf76dc9d0a14a337e37640a9fe64f56f81a04 Mon Sep 17 00:00:00 2001 From: Russell Bryant Date: Fri, 21 Nov 2014 20:00:06 +0000 Subject: [PATCH] Drop RpcProxy usage from ibm plugin Drop usage of the RpcProxy compatibility class from the ibm plugin. Direct usage of oslo.messaging APIs is now done instead. Part of blueprint drop-rpc-compat. Change-Id: I3163d0a5e5f042c02e83995e84eb962e002f27cb --- neutron/plugins/ibm/sdnve_neutron_plugin.py | 16 ++++++---------- 1 file changed, 6 insertions(+), 10 deletions(-) diff --git a/neutron/plugins/ibm/sdnve_neutron_plugin.py b/neutron/plugins/ibm/sdnve_neutron_plugin.py index b48a87849..f90e18d8f 100644 --- a/neutron/plugins/ibm/sdnve_neutron_plugin.py +++ b/neutron/plugins/ibm/sdnve_neutron_plugin.py @@ -18,6 +18,7 @@ import functools from oslo.config import cfg +from oslo import messaging from neutron.common import constants as n_const from neutron.common import exceptions as n_exc @@ -54,24 +55,19 @@ class SdnveRpcCallbacks(): return info -class AgentNotifierApi(n_rpc.RpcProxy): +class AgentNotifierApi(object): '''Agent side of the SDN-VE rpc API.''' - BASE_RPC_API_VERSION = '1.0' - def __init__(self, topic): - super(AgentNotifierApi, 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) self.topic_info_update = topics.get_topic_name(topic, constants.INFO, topics.UPDATE) def info_update(self, context, info): - self.fanout_cast(context, - self.make_msg('info_update', - info=info), - topic=self.topic_info_update) + cctxt = self.client.prepare(topic=self.topic_info_update, fanout=True) + cctxt.cast(context, 'info_update', info=info) def _ha(func): -- 2.45.2