Merge "Fix the deprecated usage of "get_transport""

This commit is contained in:
Zuul 2017-12-27 02:50:30 +00:00 committed by Gerrit Code Review
commit e6c024f977
2 changed files with 4 additions and 3 deletions

View File

@ -239,7 +239,7 @@ def get_notification_listener():
def get_rpc_server():
endpoints = [ResultEndpoint()]
transport = messaging.get_transport(CONF)
transport = messaging.get_rpc_transport(CONF)
s_target = target.Target('murano', 'results', server=str(uuid.uuid4()))
access_policy = dispatcher.DefaultRPCAccessPolicy
server = messaging.get_rpc_server(
@ -272,7 +272,7 @@ class ApiService(Service):
def start(self):
endpoints = [ResultEndpoint()]
transport = messaging.get_transport(CONF)
transport = messaging.get_rpc_transport(CONF)
s_target = target.Target('murano', 'results', server=str(uuid.uuid4()))
access_policy = dispatcher.DefaultRPCAccessPolicy
self.server = messaging.get_rpc_server(

View File

@ -32,7 +32,8 @@ class InstanceReportNotifier(object):
def __init__(self, environment):
if InstanceReportNotifier.transport is None:
InstanceReportNotifier.transport = messaging.get_transport(CONF)
InstanceReportNotifier.transport = \
messaging.get_notification_transport(CONF)
self._notifier = messaging.Notifier(
InstanceReportNotifier.transport,
publisher_id=uuidutils.generate_uuid(),