diff options
| author | Julien Danjou <julien@danjou.info> | 2018-07-09 17:27:09 +0200 |
|---|---|---|
| committer | Julien Danjou <julien@danjou.info> | 2018-09-06 10:38:25 +0200 |
| commit | 152fbec8f17851ac2917e57516a76eacb2f2e631 (patch) | |
| tree | e8aaaaf2eb90e825d9cfb0bef13f727b1097760e /ceilometer/pipeline | |
| parent | f7b1218b8e26a0f9a5924a15b029a961413cc40a (diff) | |
| download | ceilometer-152fbec8f17851ac2917e57516a76eacb2f2e631.tar.gz | |
pipeline: simplfy classes
Change-Id: I40a54a3cf94f8171db17f2b9ae2def4d0e9d1ab1
Diffstat (limited to 'ceilometer/pipeline')
| -rw-r--r-- | ceilometer/pipeline/base.py | 18 | ||||
| -rw-r--r-- | ceilometer/pipeline/event.py | 2 | ||||
| -rw-r--r-- | ceilometer/pipeline/sample.py | 2 |
3 files changed, 9 insertions, 13 deletions
diff --git a/ceilometer/pipeline/base.py b/ceilometer/pipeline/base.py index c109c92d..d121e50c 100644 --- a/ceilometer/pipeline/base.py +++ b/ceilometer/pipeline/base.py @@ -335,14 +335,10 @@ class NotificationEndpoint(object): # for the generic notification exchange we have to consume all its # queues - -class MainNotificationEndpoint(NotificationEndpoint): - """Listens to queues on all priority levels and clears by default.""" - - audit = NotificationEndpoint._consume_and_drop - critical = NotificationEndpoint._consume_and_drop - debug = NotificationEndpoint._consume_and_drop - error = NotificationEndpoint._consume_and_drop - info = NotificationEndpoint._consume_and_drop - sample = NotificationEndpoint._consume_and_drop - warn = NotificationEndpoint._consume_and_drop + audit = _consume_and_drop + critical = _consume_and_drop + debug = _consume_and_drop + error = _consume_and_drop + info = _consume_and_drop + sample = _consume_and_drop + warn = _consume_and_drop diff --git a/ceilometer/pipeline/event.py b/ceilometer/pipeline/event.py index 996c9bf3..5cbba737 100644 --- a/ceilometer/pipeline/event.py +++ b/ceilometer/pipeline/event.py @@ -22,7 +22,7 @@ from ceilometer.pipeline import base LOG = log.getLogger(__name__) -class EventEndpoint(base.MainNotificationEndpoint): +class EventEndpoint(base.NotificationEndpoint): event_types = [] diff --git a/ceilometer/pipeline/sample.py b/ceilometer/pipeline/sample.py index 429a8fed..79999d0b 100644 --- a/ceilometer/pipeline/sample.py +++ b/ceilometer/pipeline/sample.py @@ -19,7 +19,7 @@ from ceilometer.pipeline import base LOG = log.getLogger(__name__) -class SampleEndpoint(base.MainNotificationEndpoint): +class SampleEndpoint(base.NotificationEndpoint): def info(self, notifications): """Convert message at info level to Ceilometer sample. |