Arnike/watcher
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge "Remove deprecated oslo_messaging.get_transport"

Browse Source
This commit is contained in:
Jenkins
2017-06-14 13:13:34 +00:00
committed by Gerrit Code Review
parent 43da4a6d21 d0f5a9fdf5
commit fe34b420a5
2 changed files with 4 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
watcher/common/rpc.py
View File

@@ -53,11 +53,10 @@ JsonPayloadSerializer = messaging.JsonPayloadSerializer
def init(conf): def init(conf):
global TRANSPORT, NOTIFICATION_TRANSPORT, NOTIFIER global TRANSPORT, NOTIFICATION_TRANSPORT, NOTIFIER
exmods = get_allowed_exmods() exmods = get_allowed_exmods()
TRANSPORT = messaging.get_transport(conf, TRANSPORT = messaging.get_rpc_transport(
allowed_remote_exmods=exmods) conf, allowed_remote_exmods=exmods)
NOTIFICATION_TRANSPORT = messaging.get_notification_transport( NOTIFICATION_TRANSPORT = messaging.get_notification_transport(
conf, conf, allowed_remote_exmods=exmods)
allowed_remote_exmods=exmods)
serializer = RequestContextSerializer(JsonPayloadSerializer()) serializer = RequestContextSerializer(JsonPayloadSerializer())
if not conf.notification_level: if not conf.notification_level:

2
watcher/common/service.py
View File

@@ -210,7 +210,7 @@ class Service(service.ServiceBase):
@property @property
def transport(self): def transport(self):
if self._transport is None: if self._transport is None:
self._transport = om.get_transport(CONF) self._transport = om.get_rpc_transport(CONF)
return self._transport return self._transport
@property @property