diff options
author | Julien Danjou <julien@danjou.info> | 2018-09-06 10:40:18 +0200 |
---|---|---|
committer | Julien Danjou <julien@danjou.info> | 2018-09-06 10:46:30 +0200 |
commit | b058b9bdbdc1c9d5f3bda0cbbc3d97ced1c46b01 (patch) | |
tree | b9b9fc9ab8122ab969e4741057d79d9a48c62197 /ceilometer/notification.py | |
parent | 152fbec8f17851ac2917e57516a76eacb2f2e631 (diff) | |
download | ceilometer-b058b9bdbdc1c9d5f3bda0cbbc3d97ced1c46b01.tar.gz |
notification: remove unused pipeline listener
Change-Id: If004104d8920f33ab89c7584e685c67208c59675
Diffstat (limited to 'ceilometer/notification.py')
-rw-r--r-- | ceilometer/notification.py | 6 |
1 files changed, 0 insertions, 6 deletions
diff --git a/ceilometer/notification.py b/ceilometer/notification.py index af228f07..15e6dfab 100644 --- a/ceilometer/notification.py +++ b/ceilometer/notification.py @@ -89,11 +89,7 @@ class NotificationService(cotyledon.Service): super(NotificationService, self).__init__(worker_id) self.startup_delay = worker_id self.conf = conf - self.listeners = [] - # NOTE(kbespalov): for the pipeline queues used a single amqp host - # hence only one listener is required - self.pipeline_listener = None def get_targets(self): """Return a sequence of oslo_messaging.Target @@ -159,8 +155,6 @@ class NotificationService(cotyledon.Service): listener.wait() def terminate(self): - if self.pipeline_listener: - self.kill_listeners([self.pipeline_listener]) self.kill_listeners(self.listeners) super(NotificationService, self).terminate() |