Merge "[messaging] Using get_notification_transport()"
This commit is contained in:
commit
835a6a4f18
@ -226,7 +226,7 @@ class NotificationService(Service):
|
|||||||
def start(self):
|
def start(self):
|
||||||
endpoints = [report_notification, track_instance, untrack_instance]
|
endpoints = [report_notification, track_instance, untrack_instance]
|
||||||
|
|
||||||
transport = messaging.get_transport(CONF)
|
transport = messaging.get_notification_transport(CONF)
|
||||||
s_target = target.Target(topic='murano', server=str(uuid.uuid4()))
|
s_target = target.Target(topic='murano', server=str(uuid.uuid4()))
|
||||||
|
|
||||||
self.server = messaging.get_notification_listener(
|
self.server = messaging.get_notification_listener(
|
||||||
|
@ -31,7 +31,8 @@ class StatusReporter(object):
|
|||||||
|
|
||||||
def __init__(self, environment):
|
def __init__(self, environment):
|
||||||
if StatusReporter.transport is None:
|
if StatusReporter.transport is None:
|
||||||
StatusReporter.transport = messaging.get_transport(CONF)
|
StatusReporter.transport = messaging.get_notification_transport(
|
||||||
|
CONF)
|
||||||
self._notifier = messaging.Notifier(
|
self._notifier = messaging.Notifier(
|
||||||
StatusReporter.transport,
|
StatusReporter.transport,
|
||||||
publisher_id=uuidutils.generate_uuid(),
|
publisher_id=uuidutils.generate_uuid(),
|
||||||
|
@ -0,0 +1,6 @@
|
|||||||
|
features:
|
||||||
|
- It is now possible to configure the notifications to use a different
|
||||||
|
transport URL than the RPCs. These could potentially be completely
|
||||||
|
different message broker hosts (though they doesn't need to be). If the
|
||||||
|
notification-specific configuration is not provided, the notifier will use
|
||||||
|
the same transport as the RPCs.
|
Loading…
Reference in New Issue
Block a user