diff --git a/osprofiler/_notifiers/messaging.py b/osprofiler/_notifiers/messaging.py index 522b1e6..ee19c83 100644 --- a/osprofiler/_notifiers/messaging.py +++ b/osprofiler/_notifiers/messaging.py @@ -29,7 +29,8 @@ class Messaging(base.Notifier): self.service = service self.notifier = messaging.Notifier( - transport, publisher_id=host, driver="messaging", topic="profiler") + transport, publisher_id=host, driver="messaging", + topic="profiler", retry=0) def notify(self, info, context=None): """Send notifications to Ceilometer via oslo.messaging notifier API. diff --git a/tests/notifiers/test_messaging.py b/tests/notifiers/test_messaging.py index 4d8ecaa..e982892 100644 --- a/tests/notifiers/test_messaging.py +++ b/tests/notifiers/test_messaging.py @@ -34,7 +34,8 @@ class MessagingTestCase(test.TestCase): transport, project, service, host) messaging.Notifier.assert_called_once_with( - transport, publisher_id=host, driver="messaging", topic="profiler") + transport, publisher_id=host, driver="messaging", + topic="profiler", retry=0) info = { "a": 10