Merge "Fix the deprecated usage of "get_transport""
This commit is contained in:
commit
e6c024f977
|
@ -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(
|
||||
|
|
|
@ -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(),
|
||||
|
|
Loading…
Reference in New Issue