summaryrefslogtreecommitdiff
path: root/ceilometer/notification.py
diff options
context:
space:
mode:
authorJulien Danjou <julien@danjou.info>2018-09-06 10:40:18 +0200
committerJulien Danjou <julien@danjou.info>2018-09-06 10:46:30 +0200
commitb058b9bdbdc1c9d5f3bda0cbbc3d97ced1c46b01 (patch)
treeb9b9fc9ab8122ab969e4741057d79d9a48c62197 /ceilometer/notification.py
parent152fbec8f17851ac2917e57516a76eacb2f2e631 (diff)
downloadceilometer-b058b9bdbdc1c9d5f3bda0cbbc3d97ced1c46b01.tar.gz
notification: remove unused pipeline listener
Change-Id: If004104d8920f33ab89c7584e685c67208c59675
Diffstat (limited to 'ceilometer/notification.py')
-rw-r--r--ceilometer/notification.py6
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()