Merge "Fix the deprecated usage of "get_transport""
This commit is contained in:
commit
45f6dba502
@ -51,7 +51,7 @@ class VitrageNotifier(CollectDPlugin):
|
|||||||
"""Set up the Vitrage API client and add the notification callback. """
|
"""Set up the Vitrage API client and add the notification callback. """
|
||||||
|
|
||||||
url = self.config['transport_url']
|
url = self.config['transport_url']
|
||||||
transport = messaging.get_transport(cfg.CONF, url)
|
transport = messaging.get_notification_transport(cfg.CONF, url)
|
||||||
self.notifier = messaging.Notifier(transport,
|
self.notifier = messaging.Notifier(transport,
|
||||||
driver='messagingv2',
|
driver='messagingv2',
|
||||||
publisher_id=COLLECTD_DATASOURCE,
|
publisher_id=COLLECTD_DATASOURCE,
|
||||||
|
@ -66,7 +66,7 @@ def main():
|
|||||||
args.sendto, args.topic, args.body)
|
args.sendto, args.topic, args.body)
|
||||||
|
|
||||||
transport_url = args.sendto
|
transport_url = args.sendto
|
||||||
transport = messaging.get_transport(cfg.CONF, transport_url)
|
transport = messaging.get_notification_transport(cfg.CONF, transport_url)
|
||||||
driver = 'messagingv2'
|
driver = 'messagingv2'
|
||||||
publisher = 'zabbix_%s' % socket.gethostname()
|
publisher = 'zabbix_%s' % socket.gethostname()
|
||||||
notifier = messaging.Notifier(transport,
|
notifier = messaging.Notifier(transport,
|
||||||
|
Loading…
Reference in New Issue
Block a user