diff options
| author | Mehdi Abaakouk <sileht@redhat.com> | 2016-10-10 19:24:47 +0200 |
|---|---|---|
| committer | Mehdi Abaakouk <sileht@redhat.com> | 2016-10-11 14:59:52 +0200 |
| commit | 32c5d726470569f9a441346a0969f66fe5caab2a (patch) | |
| tree | 07ba99b407f8ac1647e63fb4191b8e60729310d0 /ceilometer/notification.py | |
| parent | 5901528d1280ad8555d208ef86c614afd744c7c2 (diff) | |
| download | ceilometer-32c5d726470569f9a441346a0969f66fe5caab2a.tar.gz | |
messaging: stop using global config
Change-Id: I97840aa9d1249deeba91dcdb6a5d23eca2fecdf1
Diffstat (limited to 'ceilometer/notification.py')
| -rw-r--r-- | ceilometer/notification.py | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/ceilometer/notification.py b/ceilometer/notification.py index 0bc42a11..35d9c027 100644 --- a/ceilometer/notification.py +++ b/ceilometer/notification.py @@ -160,7 +160,7 @@ class NotificationService(service_base.PipelineBasedService): self.event_pipeline_manager = pipeline.setup_event_pipeline() - self.transport = messaging.get_transport() + self.transport = messaging.get_transport(cfg.CONF) if cfg.CONF.notification.workload_partitioning: self.group_id = self.NOTIFICATION_NAMESPACE @@ -252,7 +252,7 @@ class NotificationService(service_base.PipelineBasedService): urls = cfg.CONF.notification.messaging_urls or [None] for url in urls: - transport = messaging.get_transport(url) + transport = messaging.get_transport(cfg.CONF, url) # NOTE(gordc): ignore batching as we want pull # to maintain sequencing as much as possible. listener = messaging.get_batch_notification_listener( @@ -271,7 +271,7 @@ class NotificationService(service_base.PipelineBasedService): def _configure_pipeline_listener(self): ev_pipes = self.event_pipeline_manager.pipelines pipelines = self.pipeline_manager.pipelines + ev_pipes - transport = messaging.get_transport() + transport = messaging.get_transport(cfg.CONF) partitioned = self.partition_coordinator.extract_my_subset( self.group_id, range(cfg.CONF.notification.pipeline_processing_queues)) |