x/valet
Code Issues Proposed changes

Merge "Remove deprecated oslo.messaging.get_transport"

Browse Source
This commit is contained in:
Jenkins 2017-06-06 15:37:50 +00:00 committed by Gerrit Code Review
commit 4dcf7970e4
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
etc/valet/openstack/notification_listener/notification_listener.py
View File

@ -36,7 +36,7 @@ class NotificationEndpoint(object):
"""Error.""" """Error."""
None None
transport = oslo_messaging.get_transport(cfg.CONF) transport = oslo_messaging.get_notification_transport(cfg.CONF)
targets = [oslo_messaging.Target(topic='notifications')] targets = [oslo_messaging.Target(topic='notifications')]
endpoints = [NotificationEndpoint()] endpoints = [NotificationEndpoint()]

2
valet/api/common/messaging.py
View File

@ -23,7 +23,7 @@ from pecan import conf
def _messaging_notifier_from_config(config): def _messaging_notifier_from_config(config):
"""Initialize the messaging engine based on supplied config.""" """Initialize the messaging engine based on supplied config."""
transport_url = config.get('transport_url') transport_url = config.get('transport_url')
transport = messaging.get_transport(cfg.CONF, transport_url) transport = messaging.get_notification_transport(cfg.CONF, transport_url)
notifier = messaging.Notifier(transport, driver='messaging', notifier = messaging.Notifier(transport, driver='messaging',
publisher_id='valet', publisher_id='valet',
topic='notifications', retry=10) topic='notifications', retry=10)