common notification endpoint

make samples and events use a common endpoint class

Change-Id: I1d15783721f91ee90adfbac88cef2a44e0b23868

1 files changed, 0 insertions, 59 deletions

diff --git a/ceilometer/event/endpoint.py b/ceilometer/event/endpoint.py
deleted file mode 100644
index 8aa9cf28..00000000
--- a/ceilometer/event/endpoint.py
+++ /dev/null
@@ -1,59 +0,0 @@
-# Copyright 2012-2014 eNovance <licensing@enovance.com>
-#
-# Licensed under the Apache License, Version 2.0 (the "License"); you may
-# not use this file except in compliance with the License. You may obtain
-# a copy of the License at
-#
-#      http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
-# WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
-# License for the specific language governing permissions and limitations
-# under the License.
-
-from oslo_log import log
-import oslo_messaging
-from stevedore import extension
-
-from ceilometer.event import converter
-
-LOG = log.getLogger(__name__)
-
-
-class EventsNotificationEndpoint(object):
-    def __init__(self, manager):
-        super(EventsNotificationEndpoint, self).__init__()
-        LOG.debug('Loading event definitions')
-        self.event_converter = converter.setup_events(
-            manager.conf,
-            extension.ExtensionManager(
-                namespace='ceilometer.event.trait_plugin'))
-        self.manager = manager
-
-    def info(self, notifications):
-        """Convert message at info level to Ceilometer Event.
-
-        :param notifications: list of notifications
-        """
-        return self.process_notification('info', notifications)
-
-    def error(self, notifications):
-        """Convert message at error level to Ceilometer Event.
-
-        :param notifications: list of notifications
-        """
-        return self.process_notification('error', notifications)
-
-    def process_notification(self, priority, notifications):
-        for notification in notifications:
-            try:
-                event = self.event_converter.to_event(priority, notification)
-                if event is not None:
-                    with self.manager.publisher() as p:
-                        p(event)
-            except Exception:
-                if not self.manager.conf.notification.ack_on_event_error:
-                    return oslo_messaging.NotificationResult.REQUEUE
-                LOG.error('Fail to process a notification', exc_info=True)
-        return oslo_messaging.NotificationResult.HANDLED