messaging use blocking instead of threading
collector notification topic name change Change-Id: I6ed7ff08ff8c79f656b22731ecb7897ea0df82b1
This commit is contained in:
parent
41f863bbb7
commit
e2427934b0
@ -49,7 +49,7 @@ OPTS = [
|
|||||||
default='vitrage_notifications',
|
default='vitrage_notifications',
|
||||||
help='Vitrage configured notifications topic'),
|
help='Vitrage configured notifications topic'),
|
||||||
cfg.StrOpt('notification_topic_collector',
|
cfg.StrOpt('notification_topic_collector',
|
||||||
default='collector_event_notification',
|
default='vitrage_collector_notifications',
|
||||||
help='The topic on which event will be sent from the '
|
help='The topic on which event will be sent from the '
|
||||||
'datasources to the graph processor')
|
'datasources to the graph processor')
|
||||||
]
|
]
|
||||||
|
@ -52,7 +52,7 @@ def get_notification_listener(transport, targets, endpoints,
|
|||||||
allow_requeue=False):
|
allow_requeue=False):
|
||||||
"""Return a configured oslo_messaging notification listener."""
|
"""Return a configured oslo_messaging notification listener."""
|
||||||
return oslo_messaging.get_notification_listener(
|
return oslo_messaging.get_notification_listener(
|
||||||
transport, targets, endpoints, executor='threading',
|
transport, targets, endpoints, executor='blocking',
|
||||||
allow_requeue=allow_requeue)
|
allow_requeue=allow_requeue)
|
||||||
|
|
||||||
|
|
||||||
|
Loading…
x
Reference in New Issue
Block a user