::
- from oslo import messaging
+ import oslo_messaging
from neutron.common import rpc as n_rpc
"""
def __init__(self, topic):
- target = messaging.Target(topic=topic, version='1.0')
+ target = oslo_messaging.Target(topic=topic, version='1.0')
self.client = n_rpc.get_client(target)
def my_remote_method(self, context, arg1, arg2):
::
- from oslo import messaging
+ import oslo_messaging
class ServerAPI(object):
- target = messaging.Target(version='1.1')
+ target = oslo_messaging.Target(version='1.1')
def my_remote_method(self, context, arg1, arg2):
return 'foo'
return 'bar'
-This class implements the server side of the interface. The messaging.Target()
-defined says that this class currently implements version 1.1 of the interface.
+This class implements the server side of the interface. The
+oslo_messaging.Target() defined says that this class currently implements
+version 1.1 of the interface.
Versioning
==========
::
- from oslo import messaging
+ import oslo_messaging
class ServerAPI(object):
- target = messaging.Target(version='1.2')
+ target = oslo_messaging.Target(version='1.2')
def my_remote_method(self, context, arg1, arg2):
return 'foo'
::
- from oslo import messaging
+ import oslo_messaging
from neutron.common import rpc as n_rpc
"""
def __init__(self, topic):
- target = messaging.Target(topic=topic, version='1.0')
+ target = oslo_messaging.Target(topic=topic, version='1.0')
self.client = n_rpc.get_client(target)
def my_remote_method(self, context, arg1, arg2):