summaryrefslogtreecommitdiff
path: root/openstack_dashboard/openstack/common/notifier/rpc_notifier2.py
diff options
context:
space:
mode:
Diffstat (limited to 'openstack_dashboard/openstack/common/notifier/rpc_notifier2.py')
-rw-r--r--openstack_dashboard/openstack/common/notifier/rpc_notifier2.py52
1 files changed, 0 insertions, 52 deletions
diff --git a/openstack_dashboard/openstack/common/notifier/rpc_notifier2.py b/openstack_dashboard/openstack/common/notifier/rpc_notifier2.py
deleted file mode 100644
index 79a8354d..00000000
--- a/openstack_dashboard/openstack/common/notifier/rpc_notifier2.py
+++ /dev/null
@@ -1,52 +0,0 @@
-# Copyright 2011 OpenStack Foundation.
-# All Rights Reserved.
-#
-# 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.
-
-'''messaging based notification driver, with message envelopes'''
-
-from oslo.config import cfg
-
-from openstack_dashboard.openstack.common import context as req_context
-from openstack_dashboard.openstack.common.gettextutils import _
-from openstack_dashboard.openstack.common import log as logging
-from openstack_dashboard.openstack.common import rpc
-
-LOG = logging.getLogger(__name__)
-
-notification_topic_opt = cfg.ListOpt(
- 'topics', default=['notifications', ],
- help='AMQP topic(s) used for openstack notifications')
-
-opt_group = cfg.OptGroup(name='rpc_notifier2',
- title='Options for rpc_notifier2')
-
-CONF = cfg.CONF
-CONF.register_group(opt_group)
-CONF.register_opt(notification_topic_opt, opt_group)
-
-
-def notify(context, message):
- """Sends a notification via RPC."""
- if not context:
- context = req_context.get_admin_context()
- priority = message.get('priority',
- CONF.default_notification_level)
- priority = priority.lower()
- for topic in CONF.rpc_notifier2.topics:
- topic = '%s.%s' % (topic, priority)
- try:
- rpc.notify(context, topic, message, envelope=True)
- except Exception:
- LOG.exception(_("Could not send notification to %(topic)s. "
- "Payload=%(message)s"), locals())